php用redis重写session机制

php文档地址
参考文章
基本是对原博的搬运。加上一些7.1版本的小修改

<?php

/**
 * ************
 * onmpwSessionHandler类  重写session机制
 * 将session存到redis数据库中
 * ************
 */
class OwnSession implements SessionHandlerInterface
{

    private $save_handle = '';
    private $reconnect = false;  //是否重新连接  默认不重新连接
    private $handle = '';
    private $auth = null;   //是否有用户验证，默认无密码验证。如果不是为null，则为验证密码
    private $prefix = 'own_PHPSESSION';
    private $expire = null;
    private $config = array(
        'SAVE_HANDLE' => 'Redis',
        'HOST' => '127.0.0.1',
        'PORT' => 6379,
        'AUTH' => null,    //是否有用户验证，默认无密码验证。如果不是为null，则为验证密码
        'TIMEOUT' => 0,   //连接超时
        'RESERVED' => null,
        'RETRY_INTERVAL' => 100,  //单位是 ms 毫秒
        'RECONNECT' => false, //连接超时是否重连  默认不重连
        'EXPIRE'=>1800//session垃圾回收时间 单位s  在此也是session的过期时间
    );

    public function __construct($config = array())
    {

        if (!empty($config)) $this->config = array_merge($this->config, $config);

        $this->parseConfig();
    }

    public function parseConfig()
    {

        $this->save_handle = $this->config['SAVE_HANDLE'];

        $this->reconnect = $this->config['RECONNECT'];

        $this->auth = $this->config['AUTH'];

        $this->expire= $this->config['EXPIRE'];
    }

    /**
     * Redis服务器连接
     * @param string $host 主机地址
     * @param number $port 连接端口
     * @param number $timeout 连接超时时间
     * @param string $reserved
     * @param number $retry_interval
     *
     * @throws RedisException
     *
     * @return boolean
     */
    public function redisConnect($host = '127.0.0.1', $port = 6379, $timeout = 0, $reserved = null, $retry_interval = 100)
    {
        //实例化Redis对象
        try {

            $this->handle = new \Redis();

        } catch (RedisException $e) {

            throw $e;

        }


        /*
         * 判断是否重新连接
         */
        if (!$this->reconnect) {

            $this->handle->connect($host, $port, $timeout);

        } else {

            $this->handle->connect($host, $port, $timeout, $reserved, $retry_interval);

        }
        /*
         * 判断是否有密码验证
         * 有密码验证则进行验证才可继续后续的操作
         */
        if (!is_null($this->auth)) {

            $this->handle->auth($this->auth);

        }
        return true;
    }

    /**
     * 解析连接
     */
    private function parseConnect()
    {

        if ($this->save_handle == 'Redis') {

            $this->redisConnect($this->config['HOST'], $this->config['PORT'], $this->config['TIMEOUT'], $this->config['RESERVED'], $this->config['RETRY_INTERVAL']);

        }

    }

    /**
     * 当session_start()函数被调用的时候该函数被触发
     *
     * @see SessionHandlerInterface::open()
     */
    public function open($save_path, $name)
    {
        /*
         * 首先连接服务器
         */
        $this->parseConnect();
        return true;

    }

    /**
     * 关闭当前session
     * 当session关闭的时候该函数自动被触发
     *
     * @see SessionHandlerInterface::close()
     */
    public function close()
    {
        return true;
    }

    /**
     * 从session存储空间读取session的数据。
     * 当调用session_start()函数的时候该函数会被触发
     * 但是在session_start()函数调用的时候先触发open函数，再触发该函数
     *
     * @see SessionHandlerInterface::read()
     */
    public function read($session_id)
    {
        /*
         * 根据sessionId 构造键名
         */
        $key = $this->prefix . ':' . $session_id;
        var_dump($key);
        //读取当前sessionid下的data数据
        $res = $this->handle->hGet($key, 'data');
        //读取完成以后 更新时间，说明已经操作过session
        $time=time();
        $this->handle->hSet($key, 'last_time', $time);
        return (string)$res;

    }

    /**
     * 将session的数据写入到session的存储空间内。
     * 当session准备好存储和关闭的时候调用该函数
     *
     * @see SessionHandlerInterface::write()
     */
    public function write($session_id, $session_data)
    {
        /*
         * 根据sessionId 构造键名
         */
        $key = $this->prefix . ':' . $session_id;
        $time = time();
        //查看该键内容是否存在
        if (!$this->handle->exists($key)) {
            /*
             * 不存在则插入新的内容
             * 插入最后更新时间
             */
            $this->handle->hset($key, 'last_time', $time);
        } else {
            /*
             * 存在，则更新该键值
             */
            $this->handle->hMset($key, array('last_time' => $time, 'data' => $session_data));
        }
        return true;

    }

    /**
     * 销毁session
     *
     * @see SessionHandlerInterface::destroy()
     */
    public function destroy($session_id)
    {
        /*
         * 根据sessionId 构造键名
         */
        $key = $this->prefix . ':' . $session_id;
        $this->handle->hDel($key, 'data');
    }

    /**
     * 清除垃圾session，也就是清除过期的session。
     * 该函数是基于php.ini中的配置选项
     * session.gc_divisor, session.gc_probability 和 session.gc_lifetime所设置的值的
     *
     * @see SessionHandlerInterface::gc()
     */
    public function gc($maxlifetime)
    {
        /*
         * 取出所有的 带有指定前缀的键
         */
        $keys = $this->handle->keys($this->prefix . '*');

        $now = time(); //取得现在的时间
        //垃圾回收
        foreach ($keys as $key) {
            //取得当前key的最后更新时间
            $last_time = $this->handle->hGet($key, 'last_time');
            /*
             * 查看当前时间和最后的更新时间的时间差是否超过最大生命周期
             */
            if (($now - $last_time) > $this->expire) {
                //超过了最大生命周期时间 则删除该key
                $this->handle->del($key);
            }

        }

    }
}

$session = new OwnSession(array(
    'HOST'=>'127.0.0.1',
    'PORT'=>6379
));
session_set_save_handler($session,true);
//session_id($_COOKIE['PHPSESSID']);
session_start();
$_SESSION['name'] = 'onmpw';
var_dump($_SESSION);
//var_dump($_COOKIE);