虚位以待(AD)
虚位以待(AD)
首页 > 网络编程 > PHP编程 > PHP实现Session入库/存入redis的方法

PHP实现Session入库/存入redis的方法
类别:PHP编程   作者:码皇   来源:互联网   点击:

本篇文章主要介绍了PHP实现Session入库 存入redis的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

对于大访问量的站点使用默认的Session 并不合适,我们可以将其存入数据库、或者使用Redis KEY-VALUE数据存储方案

首先新建一个session表

    CREATE TABLE `sessions` ( `sid` char(40) NOT NULL, `updatetime` int(20) NOT NULL, `data` varchar(200) NOT NULL, UNIQUE KEY `sid` (`sid`) USING HASH) ENGINE=MEMORY DEFAULT CHARSET=utf8;

Mysql 的memory引擎采用内存表,所有数据存储在内存,操作速度快

    <?php//引入数据库文件include "db.php";
    class MySessionHandler implements SessionHandlerInterface{
    private $savePath;
    private $sessData;
    public $expiretime;
    //设置过期时间 public $db;
    //数据库 public function __construct($hanlder =''){
    $this->db = Database::getInstance();
    //获取数据库实力 ///var_dump($this->db);
    }
    public function open($savePath, $sessionName) {
    return true;
    }
    public function close() {
    return true;
    }
    public function read($id) {
    $sql ="select * from sessions where sid ='$id'";
    $result = $this->db->execute($sql);
    if(!empty($result)){
    return $this->sessData = $result;
    }
    }
    //函数的参数 $id -> 当前会话ID //数据DATA -> 序列化之后的字符串 public function write($id, $data) {
    // echo $id;
    // echo $data;
    $now = time();
    $newExp = $now+$this->expiretime;
    //总时间=当前时间 + 期限时间 $sql = "select * from sessions where sid ='$id'";
    $result = $this->db->getOne($sql);
    //var_dump($result);
    if($data==''||isset($data)){
    $data = $this->sessData;
    }
    if($result){
    //如果存在则更新 $sql ="update sessions set updatetime = '$newExp',data ='$data' where sid = '$id'";
    //echo $sql;
    $update_data =$this->db->execute($sql);
    if($update_data){
    return true;
    }
    }
    else{
    //不存在则生成生成 $sql = "insert into sessions(sid,updatetime,data) values('$id','$now','$data')";
    $insert_data = $this->db->execute($sql);
    if($insert_data){
    return true;
    }
    }
    return false;
    }
    public function destroy($id) {
    //销毁 $sql = "delete from sessions where sid="."$id";
    $destory = $this->db->execute($sql);
    if($destory){
    return true;
    }
    else{
    return false;
    }
    }
    public function gc($sessMaxLifeTime) {
    $t = time();
    $sql ="delete from sessions where $t - 'updatetime'>${
    sessMaxLifeTime}
    ";
    $data = $this->db->execute($this->tosql);
    if($data){
    return true;
    }
    else{
    return false;
    }
    return true;
    }
    }

实例化

此处 PHP 手册可以有两种方法

    1,实现了SessionHandlerInterface借口的对象,自PHP5.4可以使用

    2 ,直接使用  session_set_save_handler

    //判断PHP版本 if(version_compare(PHP_VERSION,5.4)==1){
    session_set_save_handler($handler, true);
    session_start();
    }
    else{
    ini_set('session.use_trans_sid',0);
    ini_set('session.use_cookies',1);
    ini_set('session.cookie_path','/');
    ini_set('session.save_handler','user');
    session_module_name('user');
    session_set_save_handler(array($session,"open"),array($session,"close"),array($session,"read"),array($session,"write"),array($session,"destory"),array($session,"gc"));
    session_start();
    }
    $_SESSION['QQ']="QQ";
    echo $_SESSION['QQ'];

数据库代码 db.php

    <?php class Database{
    static $instance;
    static $db;
    static function getInstance(){
    if(self::$instance){
    return self::$instance;
    }
    else{
    return new Database();
    }
    }
    public function __construct(){
    self::$db = new PDO('mysql:host=localhost;
    dbname=session', 'root','');
    }
    public function getOne($sql){
    $rs =self::$db->query($sql);
    @$rs->setFetchMode(PDO::FETCH_ASSOC);
    //返回关联数组 $result = $rs -> fetch();
    return $result;
    }
    public function execute($sql){
    $rs = self::$db->exec($sql);
    return $rs;
    }
    }
    //$data = Database::getInstance();
    //var_dump($data);

使用REDIS 存储SESSION

    <?phpclass SessionManager{
    private $redis;
    private $sessionSavePath;
    private $sessionName;
    private $sessionExpireTime = 30;
    public function __construct(){
    $this->redis = new Redis();
    $this->redis->connect('127.0.0.1',6379);
    //连接redis $retval = session_set_save_handler( array($this,"open"), array($this,"close"), array($this,"read"), array($this,"write"), array($this,"destory"), array($this,"gc") );
    session_start();
    }
    public function open($path,$name){
    return true;
    }
    public function close(){
    return true;
    }
    public function read($id){
    $value = $this->redis->get($id);
    if($value){
    return $value;
    }
    else{
    return "";
    }
    }
    public function write($id,$data){
    if($this->redis->set($id,$data)){
    $this->redis->expire($id,$this->sessionExpireTime);
    //设置过期时间 return true;
    }
    return false;
    }
    public function destory($id){
    if($this->redis->delete($id)){
    return true;
    }
    return false;
    }
    public function gc($maxlifetime){
    return true;
    }
    //析构函数 public function __destruct(){
    session_write_close();
    }
    }
    $re = new SessionManager();
    $_SESSION['name'] = "qq";
    echo $_SESSION['name'];

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关热词搜索: php session存入redis session存入redis p