码迷，mamicode.com
首页 > Web开发 > 详细

php实现session入库

时间：2017-08-16 17:27:33      阅读：243      评论：0      收藏：0      [点我收藏+]

标签：important   viso   for   就会   image   throws   array   res   unknown   

为什么要把session存入数据库？有什么用？

可以：统计在线人数，现实多站点session共享（通行证），控制同个账号登入人数等。

要实现session的入库，有关键的几个基本知识：

session.gc_divisor = 100  session.gc_probability = 1 。session.gc_probability 与 session.gc_divisor 合起来用来管理 gc（garbage collection 垃圾回收）进程启动的概率。（ session.gc_probability/session.gc_divisor = 概率）

session.gc_maxlifetime = 1024 。session.gc_maxlifetime 指定过了多少秒之后数据就会被视为“垃圾”并被清除。

session.save_handler = files 。session.save_handler 定义了来存储和获取与会话关联的数据的处理器的名字。默认为 files。参见 session_set_save_handler()。

首先设计数据库表：

 [sql] 

  CREATE TABLE IF NOT EXISTS `session` (  

  `phpsession` char(32) COLLATE utf8_bin NOT NULL,  

  `uptime` int(10) unsigned NOT NULL,  

  `data` text COLLATE utf8_bin NOT NULL,  PRIMARY KEY (`phpsession`)  

   ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin; 

 

需要2个class, 一个是数据库的，一个是session的操作类

 

[php] view plain copy
 
 print?
  1. <?php  
  2. /** 
  3.  * session入库操作类 
  4.  * @author 删代码工程师  geek-cy.com 
  5.  */  
  6. include ‘DbSession.php‘; //引入session数据库操作类  
  7. class MySession extends DbSession{  
  8.     private $dbc = null; //保存数据库资源句柄  
  9.     private $lifetime = null; // session的生成时间  
  10.     private $time = null; //当前时间  
  11.   
  12.     const uptime = 30; //更新session的时间  
  13.   
  14.     static $DEBUG = false; //是否开启错误提示  
  15.   
  16.     public function __construct(  ){  
  17.         $this->init();     
  18.         $this->SessionSetSaveHandler();  
  19.     }  
  20.   
  21.     /** 
  22.      * 初始化session处理 
  23.      * @throws Exception 
  24.      */  
  25.     private function init(){  
  26.         try{  
  27.             //设置数据库链接资源句柄  
  28.             $db = DbSession::InitDbSession(); //获取用于数据库操作的对象  
  29.             if( !($db instanceof DbSession) ){  
  30.                 throw new Exception(‘需要MySession类的对象‘);  
  31.             }else{  
  32.                 $this->dbc = $db;  
  33.             }  
  34.             //设置session有效时间  
  35.             if( !$this->lifetime = ini_get(‘session.gc_maxlifetime‘) ){  
  36.                 throw new Exception(‘session.gc_maxlifetime获取失败‘);  
  37.             }         
  38.         }catch (Exception $e){  
  39.             $this->ShowErrow( $e->getMessage() );  
  40.         }  
  41.         $this->time = time();  
  42. //      ini_set(‘session.save_handler‘, user);  
  43.   
  44.     }  
  45.   
  46.     /** 
  47.      * 设置自定义session的回调方法 
  48.      */  
  49.     private function SessionSetSaveHandler(){  
  50.         session_set_save_handler(  
  51.             array($this, "open"),  
  52.             array($this, "close"),  
  53.             array($this, "read"),  
  54.             array($this, "write"),  
  55.             array($this, "destroy"),  
  56.             array($this, "gc")  
  57.         );  
  58.         session_start();//开启session  
  59.     }  
  60.   
  61.     /** 
  62.      * 打开session 
  63.      * @param string $savePath 
  64.      * @param string $sessName 
  65.      * @return boolean 
  66.      */  
  67.     public function open($savePath, $sessName){  
  68.         if(is_null( $this->dbc )){ //判断数据库连接是否正常  
  69.             return false;  
  70.         }else{  
  71.             return true;  
  72.         }  
  73.     }  
  74.   
  75.     /** 
  76.      * 关闭session 
  77.      */  
  78.     public function close(){  
  79.         $this->gc($this->lifetime); //触发垃圾回收机制  
  80.         return $this->dbc->MysqlClose(); //关闭数据库连接  
  81.     }  
  82.   
  83.     /** 
  84.      * 读取session 
  85.      * @param string $sessionid 
  86.      * @return boolean|unknown 
  87.      */  
  88.     public  function read( $sessionid ){  
  89.         $selectData = array(0=>$this->phpsession,1=>$this->uptime,2=>$this->data); // 需要读取的字段，数组形式  
  90.   
  91.         $sessionData = $this->dbc->ReadSession($sessionid, $selectData);  
  92.         //是否返回有效值  
  93.         if( $sessionData == false){  
  94.             return false;  
  95.         }  
  96.   
  97.         //是否过期判断  
  98.         if( $sessionData[$this->uptime] + $this->lifetime < $this->time ){  
  99.             $this->destroy( $sessionData[$this->phpsession] );  
  100.             return false;  
  101.         }  
  102.   
  103.         return $sessionData[$this->data];      
  104.     }  
  105.   
  106.     /** 
  107.      * 写入session 
  108.      * @param string $sessionid 
  109.      * @param string $data 
  110.      * @return boolean 
  111.      */  
  112.     public function write( $sessionid, $data ){  
  113.         $selectData = array(0=>$this->phpsession,1=>$this->uptime,2=>$this->data);// 需要读取的字段，数组形式  
  114.         $sessionData = $this->dbc->ReadSession($sessionid, $selectData);  
  115.         if( $sessionData == false){ //没有session数据  
  116.             if( !empty( $data ) ){ //判断是否用需要插入的session值  
  117.                 //数组形式组装要插入的字段和对应值  
  118.                 $insertData = array(  
  119.                         $this->phpsession    => $sessionid,  
  120.                         $this->uptime        => $this->time,  
  121.                         $this->data          => $data  
  122.                 );  
  123.                 $this->dbc->InsertSession( $insertData );  
  124.             }  
  125.         }else{//已经有了session数据  
  126.             //判断session数据是否有改变，或者需要更新有效时间。   
  127.             if($sessionData[$this->data] != $data || $this->time > ($sessionData[$this->uptime]+self::uptime)){  
  128.                 //以数组形式组装要更新的数据  
  129.                 $updateData = array(  
  130.                         $this->uptime    => $this->time,  
  131.                         $this->data      => $data  
  132.                 );  
  133.                 $this->dbc->UpdateSession($sessionData[$this->phpsession], $updateData );  
  134.             }  
  135.         }  
  136.         return true;  
  137.     }  
  138.   
  139.     /** 
  140.      * 销毁session 
  141.      * @param string $sessionid 
  142.      */  
  143.     public  function destroy( $sessionid ){  
  144.   
  145.         return $this->dbc->DeleteSession( $sessionid );  
  146.     }  
  147.   
  148.     /** 
  149.      * session的回收机制 
  150.      * @param string $lifetime 
  151.      */  
  152.     public function gc( $lifetime ){  
  153.         $this->dbc->GcSession( $lifetime );  
  154.     }  
  155.   
  156. }  
  157.   
  158. ?>  

 

[php] view plain copy
 
 print?
  1. <?php  
  2. /** 
  3.  * session入库的数据库操作类 
  4.  * @author 删代码工程师  geek-cy.com 
  5.  * 
  6.  */  
  7.   
  8. class DbSession{  
  9.     public static $db = null;  
  10.   
  11.     private $con = null; //保存数据库链接资源句柄  
  12.     private $HOSTNAME = ‘localhost‘;   
  13.     private $DB = ‘phptest‘;  
  14.     private $USER = ‘root‘;  
  15.     private $PASSWORD = ‘‘;  
  16.     const CHARSET = ‘UTF8‘; //编码设置  
  17.   
  18.     static $DEBUG = true; //是否开启错误提示  
  19.   
  20.     //session表与表字段  
  21.     private $TableName = ‘session‘;   
  22.     protected $phpsession = ‘phpsession‘;   
  23.     protected $uptime = ‘uptime‘;  
  24.     protected $data = ‘data‘;   
  25.   
  26.     private function __construct(){  
  27.         $this->contect();  
  28.     }  
  29.   
  30.     private function __clone(){  
  31.   
  32.     }  
  33.   
  34.     /** 
  35.      * 初始化链接数据库 
  36.      * @return Ambigous <NULL, string> 
  37.      */  
  38.     public static function InitDbSession(){  
  39.         if( is_null(self::$db) || !(self::$db instanceof self) ){  
  40.             self::$db = new DbSession;  
  41.   
  42.         }  
  43.         return self::$db; //返回类对象  
  44.     }  
  45.   
  46.     /** 
  47.      * 链接数据库 
  48.      *  
  49.      */  
  50.     private  function contect(){  
  51.         $this->con = mysql_connect($this->HOSTNAME, $this->USER, $this->PASSWORD); //保存数据库连接资源句柄  
  52.         try{  
  53.             if( is_null($this->con) ){  
  54.                 throw new Exception(‘链接数据库失败‘);  
  55.             }  
  56.             if(!mysql_select_db($this->DB, $this->con)){  
  57.                 throw new Exception(‘选择数据库失败‘);  
  58.             }  
  59.             mysql_query("SET NAMES self::CHARSET");  
  60.   
  61.         }catch (Exception $e){  
  62.             $this->ShowErrow( $e->getMessage() );  
  63.         }  
  64.     }  
  65.     /** 
  66.      * 输出错误 
  67.      * @param string $msg 
  68.      */  
  69.     protected function ShowErrow( $msg ){  
  70.         if(static::$DEBUG){ //判断是否打印错误  
  71.             echo $msg;  
  72.         }  
  73.     }  
  74.   
  75.     /** 
  76.      * 读取数据库中保存的session 
  77.      * @param string $sessionid 
  78.      * @param array $selectData 
  79.      * @return boolean|Ambigous <boolean, multitype:> 
  80.      */  
  81.     public function ReadSession( $sessionid, array $selectData ){  
  82.         $selectData = $this->doSelectData($selectData);  
  83.         if(!$selectData){  
  84.             return false;  
  85.         }  
  86.         if( $this->CheckSessionId($sessionid) ){  
  87.             $sql = ‘SELECT ‘.$selectData.‘ FROM `‘.$this->TableName.‘` WHERE ‘.$this->phpsession.‘ = \‘‘.$sessionid.‘\‘ LIMIT 1‘;  
  88.             $result = mysql_query($sql, $this->con);  
  89.             return $this->fetch($result);  
  90.         }     
  91.     }  
  92.   
  93.     /** 
  94.      * 写入新session到数据库中 
  95.      * @param array $insertData 
  96.      * @return boolean 
  97.      */  
  98.     public function InsertSession( array $insertData ){  
  99.         if( $insertData = $this->doInsertData($insertData) ){  
  100.             $sql = ‘INSERT INTO ‘.$this->TableName.‘(‘.$insertData[0].‘) VALUES(‘.$insertData[1].‘)‘;  
  101.             mysql_query($sql, $this->con);  
  102.             return true;  
  103.         }else{  
  104.             return false;  
  105.         }         
  106.     }  
  107.   
  108.     /** 
  109.      * 更新数据库中保存的session 
  110.      * @param string $sessionid 
  111.      * @param array $updateData 
  112.      * @return boolean 
  113.      */  
  114.     public function UpdateSession( $sessionid, array $updateData){  
  115.         if( !$this->CheckSessionId($sessionid) ){  
  116.             return false;  
  117.         }  
  118.   
  119.         if( $updateData = $this->doUpadateData($updateData) ){  
  120.             $sql = ‘UPDATE ‘.$this->TableName.‘ SET ‘.$updateData.‘ WHERE ‘.$this->phpsession.‘ = \‘‘.$sessionid.‘\‘‘;  
  121.             mysql_query($sql, $this->con);  
  122.             return true;  
  123.         }else{  
  124.             return false;  
  125.         }  
  126.     }  
  127.     /** 
  128.      * 删除数据库中的session 
  129.      * @param string $sessionid 
  130.      * @return boolean 
  131.      */  
  132.     public function DeleteSession( $sessionid ){  
  133.         if( !$this->CheckSessionId($sessionid) ){  
  134.             return false;  
  135.         }  
  136.         $sql = ‘DELETE FROM ‘.$this->TableName.‘ WHERE \‘‘.$sessionid.‘\‘ = ‘.$this->phpsession;  
  137.         mysql_query($sql,$this->con);  
  138.         return true;  
  139.     }  
  140.   
  141.     /** 
  142.      * 回收清除数据库中已经获取无用的session 
  143.      * @param string $lifetime 
  144.      * @return boolean 
  145.      */  
  146.     public function GcSession( $lifetime ){  
  147.         if( !ctype_digit($lifetime )){  
  148.             return false;  
  149.         }  
  150.         $checktime = time()-$lifetime;  
  151.         $sql = ‘DELETE FROM ‘.$this->TableName.‘ WHERE ‘.$this->uptime.‘ < ‘.$checktime ;  
  152.         mysql_query($sql,$this->con);  
  153.         return true;  
  154.     }  
  155.   
  156.     /** 
  157.      * 关闭数据库连接 
  158.      */  
  159.     public function MysqlClose(){  
  160.         mysql_close( $this->con );  
  161.     }  
  162.   
  163.     public function __destruct(){  
  164.         self::$db = null;  
  165.         if($this->con instanceof self){  
  166.             mysql_close( $this->con );  
  167.         }  
  168.     }  
  169.   
  170.     /** 
  171.      * 对session id 做合法性检查 
  172.      * @param string $sessionid 
  173.      * @return boolean 
  174.      */  
  175.     private function CheckSessionId( $sessionid ){  
  176.         return ctype_alnum($sessionid);  
  177.     }  
  178.   
  179.     /** 
  180.      * 返回select取得的结果集 
  181.      * @param  $result 
  182.      * @return boolean|multitype: 
  183.      */  
  184.     private function fetch(  $result ){  
  185.         if( $result && mysql_num_rows($result) == 1){  
  186.             $resultArray = array();  
  187.             $resultArray = mysql_fetch_array($result, MYSQL_ASSOC);  
  188.             if( !$resultArray || count($resultArray)== 0 ){  
  189.                 return false;  
  190.             }else{  
  191.                 return $resultArray;  
  192.             }  
  193.   
  194.         }else{  
  195.             return false;  
  196.         }  
  197.     }  
  198.   
  199.     /** 
  200.      * 处理select要查询的字段 
  201.      * @param array $data 
  202.      * @return boolean|string 
  203.      */  
  204.     private function doSelectData( array $data ){  
  205.         $keyString = ‘‘;  
  206.         foreach ($data as $value){  
  207.             $keyString .= ‘`‘.$value.‘`,‘;  
  208.         }  
  209.         $keyString   =  substr($keyString,0,-1);  
  210.         if($keyString == ‘‘){  
  211.             return false;  
  212.         }  
  213.         return $keyString;  
  214.   
  215.     }  
  216.   
  217.     /** 
  218.      * 处理要insert进数据库的字段和对应的值 
  219.      * @param array $data 
  220.      * @return boolean|string 
  221.      */  
  222.     private function doInsertData( array $data ){  
  223.         $keyString = ‘‘;  
  224.         $valueString = ‘‘;  
  225.         if(array_key_exists($this->phpsession, $data)){  
  226.             if( !$this->CheckSessionId($data[$this->phpsession]) ){  
  227.                 return false;  
  228.             }  
  229.         }  
  230.   
  231.         foreach ($data as $key => $value){  
  232.             $keyString .= ‘`‘.$key.‘`,‘;  
  233.             if(ctype_digit($value)){  
  234.                 $valueString .= ‘‘.$value.‘,‘;  
  235.             }else{  
  236.                 $valueString .= ‘\‘‘.$value.‘\‘,‘;  
  237.             }  
  238.   
  239.         }  
  240.         if( $keyString != ‘‘ && $valueString != ‘‘){  
  241.             $keyString   =  substr($keyString,0,-1);  
  242.             $valueString =  substr($valueString,0,-1);  
  243.             $dataArray[0] = $keyString; //字段  
  244.             $dataArray[1] = $valueString;//值  
  245.             return $dataArray;  
  246.         }else{  
  247.             return false;  
  248.         }  
  249.   
  250.     }  
  251.   
  252.     /** 
  253.      * 处理update的字段和对应的值 
  254.      * @param array $data 
  255.      * @return boolean|string 
  256.      */  
  257.     private function doUpadateData( array $data ){  
  258.         $upDataString = ‘‘;  
  259.   
  260.         foreach($data as $key => $value){  
  261.             if(ctype_digit($value)){  
  262.                 $value = ‘‘.$value.‘‘;  
  263.             }else{  
  264.                 $value = ‘\‘‘.$value.‘\‘‘;  
  265.             }  
  266.             $upDataString .= ‘`‘.$key.‘` = ‘.$value.‘,‘;  
  267.         }  
  268.         $upDataString = substr($upDataString,0,-1);  
  269.         if( $upDataString == ‘‘){  
  270.             return false;  
  271.         }  
  272.         return $upDataString;  
  273.     }  
  274.   
  275. }  


下面是使用方法：

 

 

 

[php] view plain copy
 
 print?
    1. <?php   
    2. include ‘MySession.php‘;  
    3.   
    4. $session = new MySession( );  
    5. $_SESSION[‘test1‘] = ‘test1‘;  
    6. $_SESSION[‘test2‘] = 2;  
    7. $_SESSION[‘test3‘] = array(1,2,3,4);  
    8.   
    9. // session_destroy();  
    10. ?>  

 

 
 

php实现session入库

标签：important   viso   for   就会   image   throws   array   res   unknown   

原文地址：http://www.cnblogs.com/zhangtianle/p/7373563.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！