论坛 › Redis › 通过redis实现session共享

lovegigi 发表于 2017-12-20 21:03:44

通过redis实现session共享

<?php　　

class redisSession{/**　　* 保存session的数据库表的信息
*/　　private $_options = array(
　　'handler' => null, //数据库连接句柄
　　'host' => null,
　　'port' => null,
　　'lifeTime' => null,
　　'prefix'   => 'PHPREDIS_SESSION:'
　　);
　　

　　/**
　　* 构造函数
　　* @param $options 设置信息数组
　　*/
　　public function __construct($options=array()){
　　if(!("redis", false)){
　　die("必须安装redis扩展");
　　}
　　if(!isset($options['lifeTime']) || $options['lifeTime'] <= 0){
　　$options['lifeTime'] = ('session.gc_maxlifetime');
　　}
　　$this->_options = ($this->_options, $options);
　　}
　　

　　/**
　　* 开始使用该驱动的session
　　*/
　　public function begin(){
　　if($this->_options['host'] === null ||
　　$this->_options['port'] === null ||
　　$this->_options['lifeTime'] === null
　　){
　　return false;
　　}
　　//设置session处理函数
　　(
　　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(($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){
　　$sessionId = $this->_options['prefix'].$sessionId;
　　return $this->_options['handler']->get($sessionId);
　　}
　　

　　/**
　　* 写入或者修改session数据
　　* @param $sessionId 要写入数据的session对应的id
　　* @param $sessionData 要写入的数据，已经序列化过了
　　*/
　　public function write($sessionId, $sessionData){
　　$sessionId = $this->_options['prefix'].$sessionId;
　　return $this->_options['handler']->setex($sessionId, $this->_options['lifeTime'], $sessionData);
　　}
　　

　　/**
　　* 主动销毁session会话
　　* @param $sessionId 要销毁的会话的唯一id
　　*/
　　public function destory($sessionId){
　　$sessionId = $this->_options['prefix'].$sessionId;
　　
//      $array = $this->print_stack_trace();
　　
//      log::write($array);
　　return $this->_options['handler']->delete($sessionId) >= 1 ? true : false;
　　}
　　

　　/**
　　* 清理绘画中的过期数据
　　* @param 有效期
　　*/
　　public function gc($lifeTime){
　　//获取所有sessionid，让过期的释放掉
　　//$this->_options['handler']->keys("*");
　　return true;
　　}
　　//打印堆栈信息
　　public function print_stack_trace()
　　{
　　$array =();
　　//截取用户信息
　　$var = $this->read(());
　　$s = ($var, "index_dk_user|");
　　$e = ($var, "}authId|");
　　$user = ($var,$s+14,$e-13);
　　$user = ($user);
　　//print_r($array);//信息很齐全
　　unset ( $array );
　　if(!empty($user)){
　　$traceInfo = $user['id'].'|'.$user['user_name'].'|'.$user['user_phone'].'|'.$user['presona_name'].'++++++++++++++++\n';
　　}else{
　　$traceInfo = '++++++++++++++++\n';
　　}
　　$time =( "y-m-d H:i:m" );
　　foreach ( $array as $t ) {
　　$traceInfo .= '[' . $time . '] ' . $t ['file'] . ' (' . $t ['line'] . ') ';
　　$traceInfo .= $t ['class'] . $t ['type'] . $t ['function'] . '(';
　　$traceInfo .=( ', ', $t ['args'] );
　　$traceInfo .= ")\n";
　　}
　　$traceInfo .= '++++++++++++++++';
　　return $traceInfo;
　　}
　　

　　
}

查看完整版本: 通过redis实现session共享