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函数的解释!
- <?php
- /*
- session信息存储到数据库的类 表结构:
- CREATE TABLE IF NOT EXISTS `sessioninfo` (
- `sid` varchar(255) NOT NULL,
- `value` longtext NOT NULL,
- `expiration` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
- PRIMARY KEY (`sid`)
- ) ENGINE = InnoDB DEFAULT CHARSET = utf8;
- */
- class MySessionHandler implements SessionHandlerInterface
- {
- /**
- * @access private
- * @var object 数据库连接
- */
- private $_dbLink;
- /**
- * @access private
- * @var string 保存session的表名
- */
- Private $_sessionTable;
- /**
- * @access private
- * @var string session名
- */
- private $_sessionName;
- /**
- * @const 过期时间
- */
- const SESSION_EXPIRE = 10;
- public function __construct($dbLink, $sessionTable)
- {
- if (!is_object($dbLink)) {
- return false;
- }
- $this->_dbLink = $dbLink;
- $this->_sessionTable = $sessionTable;
- }
- /**
- * 打开
- * @access public
- * @param string $session_save_path 保存session的路径
- * @param string $session_name session名
- * @return integer
- */
- public function open($session_save_path, $session_name)
- {
- $this->_sessionName = $session_name;
- return 0;
- }
- /**
- * 关闭
- * @access public
- * @return integer
- */
- public function close()
- {
- return 0;
- }
- /**
- * 关闭session
- * @access public
- * @param string $session_id session ID
- * @return string
- */
- public function read($session_id)
- {
- $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = {$session_id} AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";
- $result = $this->_dbLink->query($query);
- if (!isset($value) || empty($value)) {
- $value = "";
- return $value;
- }
- $this->_dbLink->query("UPDATE {$this->_sessionTable} SET expiration = CURRENT_TIMESTAMP() WHERE sid = {$session_id}");
- $value = $result->fetch_array();
- $result->free();
- return $value['value'];
- }
- /**
- * 写入session
- * @access public
- * @param string $session_id session ID
- * @param string $session_data session data
- * @return integer
- */
- public function write($session_id, $session_data)
- {
- $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = '{$session_id}' AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";
- $result = $this->_dbLink->query($query);
- $result = $result->fetch_array();
- if (!empty($result)) {
- $result = $this->_dbLink->query("UPDATE {$this->_sessionTable} SET value = {$session_data} WHERE sid = {$session_id}");
- } else {
- $result = $this->_dbLink->query("INSERT INTO {$this->_sessionTable} (sid, value) VALUES ('{$session_id}', '{$session_data}')");
- }
- if ($result) {
- return 0;
- } else {
- return 1;
- }
- }
- /**
- * 销魂session
- * @access public
- * @param string $session_id session ID
- * @return integer
- */
- public function destroy($session_id)
- {
- $result = $this->_dbLink->query("DELETE FROM {$this->_sessionTable} WHERE sid = '{$session_id}'");
- if ($result) {
- return 0;
- } else {
- return 1;
- }
- }
- /**
- * 垃圾回收
- * @access public
- * @param string $maxlifetime session 最长生存时间
- * @return integer
- */
- public function gc($maxlifetime)
- {
- $result = $this->_dbLink->query("DELETE FROM {$this->_sessionTable} WHERE UNIX_TIMESTAMP(expiration) < UNIX_TIMESTAMP(NOW()) - " . self::SESSION_EXPIRE);
- if ($result) {
- return 0;
- } else {
- return 1;
- }
- }
- }
- /**************************************************************************************/
- $dbLink = new mysqli("localhost", "root", "", "test");
- $sessionTable = "sessioninfo";
- $handler = new MySessionHandler($dbLink, $sessionTable);
- session_set_save_handler($handler);
- session_start();
- $_SESSION['name'] = "test";
- echo $_SESSION["name"];
- //session_destroy();