zoukankan      html  css  js  c++  java
  • session放入缓存(redis)、DB

    为什么要把SESSION保存在缓存

    就php来说,语言本身支持的session是以文件的方式保存到磁盘文件中,保存在指定的文件夹中,保存的路径可以在配置文件中设置或者在程序中使用函数session_save_path()进行设置,但是这么做有弊端,

    第一就是保存到文件系统中,效率低,只要有用到session就会从好多个文件中查找指定的sessionid,效率很低。

    第二就是当用到多台服务器的时候可能会出现,session丢失问题(其实是保存在了其他服务器上)。

    当然了,保存在缓存中可以解决上面的问题,如果使用php本身的session函数,可以使用session_set_save_handler()函数很方便的对session的处理过程进行重新控制。如果不用php的session系列函数,可以自己编写个类似的session函数,也是可以的,我现在做的这个项目就是这样,会根据用户的mid、登录时间进行求hash作为sessionId,每次请求的时候都必须加上sessionId才算合法(第一次登录的时候是不需要的,这个时候会创建sessionId,返回给客户端),这么做也很方便、简洁高效的。当然了,我这篇文章主要说的是在php自身的SESSION中”做做手脚”。

    SESSION保存在缓存中

    php将缓存保存到redis中,可以使用配置文件,对session的处理和保存做修改,当然了,在程序中使用ini_set()函数去修改也可以,这个很方便测试,我这里就使用这种方式,当然了,要是生产环境还是建议使用配置文件。

    <?php
    ini_set("session.save_handler", "redis");
    ini_set("session.save_path", "tcp://localhost:6379");
    session_start();
    header("Content-type:text/html;charset=utf-8");
    if(isset($_SESSION['view'])){
        $_SESSION['view'] = $_SESSION['view'] + 1;
    }else{
        $_SESSION['view'] = 1;
    }
    echo "【view】{$_SESSION['view']}";

    这里设置session.save_handler方式为redis,session.save_path为redis的地址和端口,设置之后刷新,再回头查看redis,会发现redis中的生成了sessionId,sessionId和浏览器请求的是一样的,

    是不是很方便呢,只需要改下配置文件就可以实现redis中保存session,但是我这里要说的是通过程序的方式来处理session保存到redis或者db,下面一起来看看。

    通过php提供的接口,自己改写session的处理函数

    这里可以先看看php的这个函数 session_set_save_handler ,php5.4及之后可以直接实现 SessionHandlerInterface 接口,代码会更加简洁。重写的时候主要有下面几个方法

    open(string $savePath, string $sessionName); //open类似于构造函数,开始会话的时候会调用,比如使用session_start()函数之后

    close(); //类似于类的析构函数,在write函数调用之后调用,session_write_close()之后之后也会执行

    read(string $sessionId); //读取session的时候调用

    write(string $sessionId, string $data); //保存数据的时候调用

    destory($sessionId); //销毁会话的时候(session_destory()或者session_regenerate_id())会调用

    gc($lifeTime); //垃圾清理函数,清理掉过期作废的数据

    主要就是实现这几个方法,根据不同的存储驱动可以自己设置不同的具体方法,我实现了mysql数据库和redis这两种保存session的驱动,如果有需要的话可以自己去扩展,扩展很方便很容易。

    下面是我的redis的实现(db和redis差不多,redis代码少,贴出来):

    我使用了接口的方式,这样扩展起来更方便,那天想用memcached了,直接添加就行了

    <?php
    include_once __DIR__."/interfaceSession.php";
    /**
     * 以db的方式存储session
     */
    class redisSession implements interfaceSession{
      /**
       * 保存session的数据库表的信息
       */
      private $_options = array(
        'handler' => null, //数据库连接句柄
        'host' => null,
        'port' => null,
        'lifeTime' => null,
      );
      /**
       * 构造函数
       * @param $options 设置信息数组
       */
      public function __construct($options=array()){
        if(!class_exists("redis", false)){
          die("必须安装redis扩展");
        }
        if(!isset($options['lifeTime']) || $options['lifeTime'] <= 0){
          $options['lifeTime'] = ini_get('session.gc_maxlifetime');
        }
        $this->_options = array_merge($this->_options, $options);
      }
      /**
       * 开始使用该驱动的session
       */
      public function begin(){
        if($this->_options['host'] === null ||
           $this->_options['port'] === null ||
           $this->_options['lifeTime'] === null
        ){
          return false;
        }
        //设置session处理函数
        session_set_save_handler(
          array($this, 'open'),
          array($this, 'close'),
          array($this, 'read'),
          array($this, 'write'),
          array($this, 'destory'),
          array($this, 'gc')
        );
      }
      /**
       * 自动开始回话或者session_start()开始回话后第一个调用的函数
       * 类似于构造函数的作用
       * @param $savePath 默认的保存路径
       * @param $sessionName 默认的参数名,PHPSESSID
       */
      public function open($savePath, $sessionName){
        if(is_resource($this->_options['handler'])) return true;
        //连接redis
        $redisHandle = new Redis();
        $redisHandle->connect($this->_options['host'], $this->_options['port']);
        if(!$redisHandle){
          return false;
        }
        $this->_options['handler'] = $redisHandle;
        $this->gc(null);
        return true;
      }
      /**
       * 类似于析构函数,在write之后调用或者session_write_close()函数之后调用
       */
      public function close(){
        return $this->_options['handler']->close();
      }
      /**
       * 读取session信息
       * @param $sessionId 通过该Id唯一确定对应的session数据
       * @return session信息/空串
       */
      public function read($sessionId){
        return $this->_options['handler']->get($sessionId);
      }
      /**
       * 写入或者修改session数据
       * @param $sessionId 要写入数据的session对应的id
       * @param $sessionData 要写入的数据,已经序列化过了
       */
      public function write($sessionId, $sessionData){
        return $this->_options['handler']->setex($sessionId, $this->_options['lifeTime'], $sessionData);
      }
      /**
       * 主动销毁session会话
       * @param $sessionId 要销毁的会话的唯一id
       */
      public function destory($sessionId){
        return $this->_options['handler']->delete($sessionId) >= 1 ? true : false;
      }
      /**
       * 清理绘画中的过期数据
       * @param 有效期
       */
      public function gc($lifeTime){
        //获取所有sessionid,让过期的释放掉
        $this->_options['handler']->keys("*");
        return true;
      }
    }
    

    看看简单工厂模式

    class session {
        /**
         * 驱动程序句柄保存
         */
        private static $_handler = null;
        /**
         * 创建session驱动程序
         */
        public static function getSession($type, $options){
      //单例
      if(isset($handler)){
          return self::$_handler;
      }
      switch ($type) {
          case 'db': //数据库驱动session类型
            include_once __DIR__."/driver/dbSession.php";
            $handler = new dbSession($options);
        break;
          case 'redis': //redis驱动session类型
            include_once __DIR__."/driver/redisSession.php";
            $handler = new redisSession($options);
        break;
          default:
            return false;
        break;
      }
      return self::$_handler = $handler;
        }
    }
    

    调用也很简单,

    session::getSession('redis',array(
            'host' => "localhost",
            'port' => "6379",
        ))->begin();
    
    session_start();
  • 相关阅读:
    ASP.NET MVC 4高级编程(第4版)
    Unity3d报告奇怪的错误CompareBaseObjectsInternal can only be called from the main thread.
    HDU 4862 Jump(更多的联合培训学校1)(最小费用最大流)
    0,22, 47, 120,(? ),290
    它们的定义Activity跳转动画
    ssh探头安全
    Netty:一种非易失堵塞client/server相框
    Swift类和结构
    php+mysql+nginx于linux部署对环境
    javascript 次序li
  • 原文地址:https://www.cnblogs.com/mhxsh/p/5371120.html
Copyright © 2011-2022 走看看