php session类

2025-01-05 技术教程

<?phpnamespace dollarphp;use Medoo\Medoo;/** * @desc：session类 * @author [Lee] <[<complet@163.com>]> */class SessionDeal{ private $database; // 数据库对象 private $redis; // redis对象 public $config_db = array( // 数据库配置 'database_type' => 'mysql', # 数据库类型 'database_name' => 'test', # 数据库名 'server' => 'localhost', # 主机 'username' => 'root', # 用户名 'password' => '123456', # 密码 'port' => 3306, # 端口 'charset' => 'utf8' # 字符集 ); public $config_rs = array( // redis配置 'host' => 'x.x.x.x', # 主机 'port' => 'xx', # 端口 'pass' => 'xxxx' # 密码 ); /* session初始化函数（实例化数据库对象和redis对象） */ function open(){ $config_db = $this->config_db; $config_rs = $this->config_rs; $database = new Medoo($config_db); $redis = new phpredis($config_rs); $this->database = $database; $this->redis = $redis; return true; } /* 写入session @param id sessionID @param val session值 @param expire 超时时间单位：秒 */ function write($id,$val,$expire){ $database = $this->database; $redis = $this->redis; $db_expire = $expire + time(); $rs_expire = $expire; $sql = "insert into `session` (id,value,expire) values ('{$id}','{$val}','{$db_expire}')"; $ret_db = $database->query($sql)->rowCount(); $ret_rs = $redis->rsetexp($id,$val,$rs_expire); return true; } /* 获取session值 @param id sessionID @return val session值 */ function read($id){ $database = $this->database; $redis = $this->redis; $time = time(); $ret_rs = $redis->rget($id); if($ret_rs){ // 如果redis中有值 $val = $ret_rs; }else{ // 否则从数据库中取值 $sql = "select value from `session` where id='{$id}' and expire<{$time}"; $ret_db = $database->query($sql)->fetchColumn(); $val = $ret_db; } return $val; } /* 销毁session（删除数据库中的session） @param id sessionID */ function destroy($id){ $database = $this->database; $redis = $this->redis; $ret_rs = $redis->rdel($id); $sql = "delete from `session` where id='{$id}'"; $ret_db = $database->query($sql)->rowCount(); if($ret_rs && $ret_db){ return true; }else{ return false; } } /* session关闭函数（相当于析构函数，可以做数据库关闭操作） */ function close(){ $database = $this->database; $redis = $this->redis; $database->close(); $redis->close(); return true; } /* 垃圾回收（不定期销毁过期session） @param maxtime 最大时间 */ function gc($maxtime){ return true; }}// $handler = new SessionDeal();// session_set_save_handler(// array($handler, 'open'),// array($handler, 'close'),// array($handler, 'read'),// array($handler, 'write'),// array($handler, 'destroy'),// array($handler, 'gc')// );// register_shutdown_function('session_write_close');// session_start();// $_SESSION['name'] = 'value';// $ret = $_SESSION['name'];// echo $ret.PHP_EOL;