PHP设置Redis储存Session，自定义session驱动

<?php 

// 需要先引入自定义的SiamSession类（该类的实现逻辑于下面PHP5.4以后的实现相同），然后再设置到save_handler中去
// 也可以直接在参数处传递闭包

$siamSession = new SiamSession();
session_set_save_handler(
  [$siamSession,"open"],
  [$siamSession,"close"],
  [$siamSession,"read"],
  [$siamSession,"write"],
  [$siamSession,"destroy"],
  [$siamSession,"gc"]
);

// 开启
session_start();

<?php 

// 需要先引入自定义的Session处理程序，然后再设置到save_handler中去
// 也可以直接在参数处传递闭包

$siamSession = new SiamSession();
session_set_save_handler($siamSession, true);

// 开启
session_start();

<?php
// SessionHandler 实现了SessionHandlerInterface和SessionIdInterface两个接口
// 其中 SessionIdInterface 提供了 create_sid 接口，可以自定义session_id的生成规则
// 其他的方法则由 SessionHandlerInterface 提供，主要是session的回调处理，如打开、关闭、gc、写入、读取
SessionHandler implements SessionHandlerInterface , SessionIdInterface {
    /**
     * close方法，当session关闭的时候触发
     */
    public close ( void ) : bool
    /**
     * create_sid方法，返回一个新创建的session_id
     */
    public create_sid ( void ) : string
    /**
     * destroy方法，当调用session_destroy的时候触发
     */
    public destroy ( string $session_id ) : bool
    /**
     * gc方法，当php程序gc清理的时候触发，主要用于清除已经过期的session
     */
    public gc ( int $maxlifetime ) : int
    /**
     * open方法，当session打开的时候触发
     */
    public open ( string $save_path , string $session_name ) : bool
    /**
     * read方法，读取session的处理逻辑，可以在这里解密储存数据
     * 在session_start后会触发
     */
    public read ( string $session_id ) : string

    /**
     * write方法，将session数据写入到储存中，可以在这里加密数据
     */
    public write ( string $session_id , string $session_data ) : bool
}

SessionUpdateTimestampHandlerInterface {
    /**
     * 更新时间戳，即更新session过期时间的
     */
    abstract public updateTimestamp ( string $key , string $val ) : bool
    /**
     * 验证session_id 是否还在线
     */ 
    abstract public validateId ( string $key ) : bool
}

<?php

class SiamSession  implements \SessionHandlerInterface
{
    private $redis;
    private $expTime = 30; // 默认超时时间 根据业务场景设置

    function __construct(){
        // 连接redis
        $this->redis = new Redis();
        $this->redis->connect('127.0.0.1',6379);

        // 设置session处理回调 并且将session_write_close注册为register_shutdown_function函数
        session_set_save_handler($this, true);

        // 开启
        session_start();

    }

    function open($path, $name)
    {
        return true;
    }

    function close(){
        return true;
    }

    function read($session_id)
    {
        $value = $this->redis->get("siam_".$session_id);
        if ($value){
            return $value;
        }
        return '';
    }

    function write($session_id, $data)
    {
        if( $this->redis->set("siam_".$session_id, $data) ){
            $this->redis->expire("siam_".$session_id, $this->expTime);
            return true;
        }
        return false;
    }

    function destroy($session_id)
    {
        if ( $this->redis->delete("siam_".$session_id) )
        {
            return true;
        }
        return false;
    }

    function gc($maxlifetime)
    {
        return true; // 因为redis设置了过期时间，不需要再gc回收
    }

    function __destruct()
    {
        session_write_close();
    }
}

new SiamSession();

<?php
require_once "SiamSession.php";

$_SESSION['name'] = "siam";
echo $_SESSION['name'];