php session存数据库

 http://hudeyong926.iteye.com/blog/1231026

http://www.feiyan.info/11.html

php.ini改称 session.save_handler="user"多服务器共享SESSION 的主要障碍及解决办法
通过了解 SESSION 的工作原理,我们可以发现,在默认情况下,各个服务器会各自分别对同一个客户端产生SESSION ID,如对于同一个用户浏览器,A 服务器产生的 SESSION ID是30de1e9de3192ba6ce2992d27a1b6a0a,而 B 服务器生成的则是c72665af28a8b14c0fe11afe3b59b51b。另外,PHP 的 SESSION 数据都是分别保存在本服务器的文件系统中。确定了问题所在之后,就可以着手进行解决了。想要共享 SESSION 数据,那就必须实现两个目标
一个是各个服务器对同一个客户端产生的 SESSION ID 必须相同,并且可通过同一个 COOKIE 进行传递,也就是说各个服务器必须可以读取同一个名为 PHPSESSID 的 COOKIE;
另一个是 SESSION 数据的存储方式/位置必须保证各个服务器都能够访问到。 简单地说就是多服务器共享客户端的 SESSION ID,同时还必须共享服务器端的 SESSION数据。

 

SESSION数据库的优点,如果服务器采用群集的方式的话就不能保持session的一致性,所以我们就绪要采用数据库的方式来保存session, 这样,不管有几台服务器同时使用,只要把他们的session保存在一台数据库服务器上就可以保存session的完整了.还有诸如:控制一个帐号只能一个人登录,统计在线人数,踢出某个在线用户.总之用户的状态就掌握在我们手里了.并且不用修改代码.多站点共享session,实现Application变量(多用户共享的全局变量)

只不过这样的功能会给数据库带来严重的I/O负担,但凡有点流量再碰上点*的用户这样的数据库性能肯定要被严重拖累

SessionHandlerInterface接口是PHP内置的接口,直接实现就行了
具体可以看php手册关于session_set_save_handler函数的解释!

Java代码  php session存数据库
  1. <?php  
  2. /* 
  3. session信息存储到数据库的类  表结构: 
  4. CREATE TABLE IF NOT EXISTS `sessioninfo` ( 
  5.   `sid` varchar(255) NOT NULL, 
  6.   `value` longtext NOT NULL, 
  7.   `expiration` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, 
  8.   PRIMARY KEY (`sid`) 
  9. ) ENGINE = InnoDB DEFAULT CHARSET = utf8; 
  10. */  
  11. class MySessionHandler implements SessionHandlerInterface  
  12. {  
  13.   
  14.     /** 
  15.      * @access private 
  16.      * @var object 数据库连接 
  17.      */  
  18.     private $_dbLink;  
  19.     /** 
  20.      * @access private 
  21.      * @var string 保存session的表名 
  22.      */  
  23.     Private $_sessionTable;  
  24.     /** 
  25.      * @access private 
  26.      * @var string session名 
  27.      */  
  28.     private $_sessionName;  
  29.     /** 
  30.      * @const 过期时间 
  31.      */  
  32.     const SESSION_EXPIRE = 10;  
  33.   
  34.     public function __construct($dbLink, $sessionTable)  
  35.     {  
  36.         if (!is_object($dbLink)) {  
  37.             return false;  
  38.         }  
  39.         $this->_dbLink = $dbLink;  
  40.         $this->_sessionTable = $sessionTable;  
  41.     }  
  42.   
  43.     /** 
  44.      * 打开 
  45.      * @access public 
  46.      * @param string $session_save_path 保存session的路径 
  47.      * @param string $session_name session名 
  48.      * @return integer 
  49.      */  
  50.     public function open($session_save_path, $session_name)  
  51.     {  
  52.         $this->_sessionName = $session_name;  
  53.         return 0;  
  54.     }  
  55.   
  56.     /** 
  57.      * 关闭 
  58.      * @access public 
  59.      * @return integer 
  60.      */  
  61.     public function close()  
  62.     {  
  63.         return 0;  
  64.     }  
  65.   
  66.     /** 
  67.      * 关闭session 
  68.      * @access public 
  69.      * @param string $session_id session ID 
  70.      * @return string 
  71.      */  
  72.     public function read($session_id)  
  73.     {  
  74.         $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = {$session_id} AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";  
  75.         $result = $this->_dbLink->query($query);  
  76.         if (!isset($value) || empty($value)) {  
  77.             $value = "";  
  78.             return $value;  
  79.         }  
  80.         $this->_dbLink->query("UPDATE {$this->_sessionTable} SET expiration = CURRENT_TIMESTAMP() WHERE sid = {$session_id}");  
  81.         $value = $result->fetch_array();  
  82.         $result->free();  
  83.         return $value['value'];  
  84.     }  
  85.   
  86.     /** 
  87.      * 写入session 
  88.      * @access public 
  89.      * @param string $session_id session ID 
  90.      * @param string $session_data session data 
  91.      * @return integer 
  92.      */  
  93.     public function write($session_id, $session_data)  
  94.     {  
  95.         $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = '{$session_id}' AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";  
  96.         $result = $this->_dbLink->query($query);  
  97.         $result = $result->fetch_array();  
  98.         if (!empty($result)) {  
  99.             $result = $this->_dbLink->query("UPDATE {$this->_sessionTable} SET value = {$session_data} WHERE sid = {$session_id}");  
  100.         } else {  
  101.             $result = $this->_dbLink->query("INSERT INTO {$this->_sessionTable} (sid, value) VALUES ('{$session_id}', '{$session_data}')");  
  102.         }  
  103.         if ($result) {  
  104.             return 0;  
  105.         } else {  
  106.             return 1;  
  107.         }  
  108.     }  
  109.   
  110.     /** 
  111.      * 销魂session 
  112.      * @access public 
  113.      * @param string $session_id session ID 
  114.      * @return integer 
  115.      */  
  116.     public function destroy($session_id)  
  117.     {  
  118.         $result = $this->_dbLink->query("DELETE FROM {$this->_sessionTable} WHERE sid = '{$session_id}'");  
  119.         if ($result) {  
  120.             return 0;  
  121.         } else {  
  122.             return 1;  
  123.         }  
  124.     }  
  125.   
  126.     /** 
  127.      * 垃圾回收 
  128.      * @access public 
  129.      * @param string $maxlifetime session 最长生存时间 
  130.      * @return integer 
  131.      */  
  132.     public function gc($maxlifetime)  
  133.     {  
  134.         $result = $this->_dbLink->query("DELETE FROM {$this->_sessionTable} WHERE UNIX_TIMESTAMP(expiration) < UNIX_TIMESTAMP(NOW()) - " . self::SESSION_EXPIRE);  
  135.         if ($result) {  
  136.             return 0;  
  137.         } else {  
  138.             return 1;  
  139.         }  
  140.     }  
  141.   
  142. }  
  143.   
  144. /**************************************************************************************/  
  145. $dbLink = new mysqli("localhost""root""""test");  
  146. $sessionTable = "sessioninfo";  
  147.   
  148. $handler = new MySessionHandler($dbLink, $sessionTable);  
  149. session_set_save_handler($handler);  
  150. session_start();  
  151. $_SESSION['name'] = "test";  
  152. echo $_SESSION["name"];  
  153. //session_destroy();  
上一篇:通过实现网站访问计数器带你理解 轻量级锁CAS原理,还学不会算我输!!!(下)


下一篇:受用一生的高效 PyCharm 使用技巧(六)