ホームページ >バックエンド開発 >PHPチュートリアル >PHPSessionをデータベース/redisに格納する方法の詳細説明

PHPSessionをデータベース/redisに格納する方法の詳細説明

墨辰丷オリジナル: 2018-05-23 09:36:261700ブラウズ

この記事では、PHP で Redis に Session storage/deposit を実装する方法を主に紹介します。編集者が非常に優れていると考えたので、参考として共有します。エディターをフォローして見てみましょう

アクセス数が多いサイトにデフォルトのセッションを使用するのは適していません。データベースに保存するか、Redis KEY-VALUE データストレージソリューションを使用できます

まず、新しいセッションテーブルを作成します。

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のメモリエンジンはメモリテーブルを使用し、すべてのデータはメモリに保存され、動作速度が速いです

<?php
//引入数据库文件
include "db.php";
class MySessionHandler implements SessionHandlerInterface
{
  private $savePath;
  private $sessData;
  public $expiretime;  //设置过期时间
  public $db;  //数据库
  public function __construct($hanlder =&#39;&#39;){
     
    $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 =&#39;$id&#39;";
    $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 =&#39;$id&#39;";
    $result = $this->db->getOne($sql);
    //var_dump($result);
    if($data==&#39;&#39;||isset($data)){
      $data = $this->sessData;
    }
      if($result){
      //如果存在则更新
  $sql ="update sessions set updatetime = &#39;$newExp&#39;,data =&#39;$data&#39; where sid = &#39;$id&#39;";
        //echo $sql;
          $update_data =$this->db->execute($sql);
          if($update_data){
            return true;
          }
         
      }else{
      //不存在则生成生成
  $sql = "insert into sessions(sid,updatetime,data) values(&#39;$id&#39;,&#39;$now&#39;,&#39;$data&#39;)";
    $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 - &#39;updatetime&#39;>${sessMaxLifeTime}";
    $data = $this->db->execute($this->tosql);
    if($data){
      return true;
    }else{
      return false;
      }
    return true;
  }
}

インスタンス化

こちらのPHPマニュアルには2つの方法があります

1実装された SessionHandlerInterface Excuse オブジェクト (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(&#39;session.use_trans_sid&#39;,0);
    ini_set(&#39;session.use_cookies&#39;,1);
    ini_set(&#39;session.cookie_path&#39;,&#39;/&#39;);
      ini_set(&#39;session.save_handler&#39;,&#39;user&#39;);
      session_module_name(&#39;user&#39;);
      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[&#39;QQ&#39;]="QQ";
echo $_SESSION[&#39;QQ&#39;];

データベースコード 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(&#39;mysql:host=localhost;dbname=session&#39;, &#39;root&#39;,&#39;&#39;);
  }
 
    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);

SESSION を保存するには REDIS を使用します

りー

PHPSessionをデータベース/redisに格納する方法の詳細説明

関連記事