使用 MySQL 开始 PHP 会话

默认情况下，PHP会话（session）是通过文件来保存的。这样做有以下几个缺点：

1. 会话文件一般都很小，但文件数却很多，在文件系统中保存许多这样的小文件非常浪费空间，且效率不高。
2. 分布式的站点难以利用会话文件来共享会话。
3. 会话文件方式不利于统计在线用户的会话信息。

为解决以上问题，我们可以考虑用数据库来保存会话信息。

对于 PHP 开发来说，保存会话用 MySQL 是一个非常不错的选择。MySQL 提供一种建立在内存中的表类型 Heap，如果每条会话数据量很小的话，可以考虑用这种类型的表来进一步优化性能。但是 Heap 类型的表有许多限制，例如它不支持 text 类型的字段，因此如果在无法预测会话数据记录长度的情况下，选择 MyISAM 是比较合适的，这种类型的表没有事物处理开销，对于基于磁盘的表可以得到最优性能。

下面是 sessions 表的结构：

sessions.sql

1. DROP TABLE IF EXISTS `sessions`;
2. CREATE TABLE `sessions` (
3.   `session_id` varchar(32) NOT NULL default '',
4.   `user_id` int(10) unsigned NOT NULL default '0',
5.   `data_value` text NOT NULL,
6.   `last_visit` timestamp(14) NOT NULL,
7.   PRIMARY KEY (`session_id`),
8.   KEY `user_id` (`user_id`)
9. ) TYPE=MyISAM;

PHP 支持用户会话模块，可以通过 session_set_save_handler 来设置自定义的会话处理函数。因为默认的处理模块是 files，因此要在用 session_set_save_handler 设置会话处理函数之前，先用 session_module_name(’user’) 来告诉 PHP 使用用户会话模块， 而session_set_save_handler 必须要在 session_start 之前执行。

用户会话数据在会话处理函数中都是序列化之后的，要取出其中的某个会话变量，可以对其进行反序列化，默认是 php 序列化方式，可以用 session::unserialize 函数来反序列化。

下面的代码定义了一个用 MySQL 来处理 PHP 会话的类，其中所使用的 class_mysql.php 请参见 。

class_session.php

2. /**
3. * @author 马秉尧
4. * @copyright (C) 2005 CoolCode.CN
5. */
6.  
7. require_once("class_mysql.php");
8.  
9. class session {
10.     var $db;
11.     function session(&$db) {
12.         $this->db = &$db;
13.         session_module_name('user');
14.         session_set_save_handler(
15.             array(&$this, 'open'),
16.             array(&$this, 'close'),
17.             array(&$this, 'read'),
18.             array(&$this, 'write'),
19.             array(&$this, 'destroy'),
20.             array(&$this, 'gc')
21.         );
22.         session_start();
23.     }
24.     function unserialize($data_value) {
25.         $vars = preg_split(
26.             '/([a-zA-Z_\x7f-\xff][a-zA-Z0-9_\x7f-\xff]*)\|/',
27.             $data_value, -1, PREG_SPLIT_NO_EMPTY |
28.             PREG_SPLIT_DELIM_CAPTURE
29.         );
30.         for ($i = 0; isset($vars[$i]); $i++) {
31.             $result[$vars[$i++]] = unserialize($vars[$i]);
32.         }
33.         return $result;
34.     }
35.     function open($path, $name) {
36.         return true;
37.     }
38.     function close() {
39.         return true;
40.     }
41.     function read($session_id) {
42.         $session_id = $this->db->escape_string($session_id);
43.         if ($row = $this->db->query("select * from `sessions` where `session_id` = '$session_id' limit 1")) {
44.             return $row['data_value'];
45.         }
46.         else {
47.             $this->db->query("insert into `sessions` set `session_id` = '$session_id'");
48.             return "";
49.         }
50.     }
51.     function write($session_id, $data_value) {
52.         $data = $this->unserialize($data_value);
53.         $session_id = $this->db->escape_string($session_id);
54.         $data_value = $this->db->escape_string($data_value);
55.         $sql = "update `sessions` set ";
56.         if (isset($data['user_id'])) {
57.             $sql .= "`user_id` = '{$data['user_id']}', ";
58.         }
59.         $sql .= "`data_value` = '$data_value', "
60.               . "`last_visit` = null "
61.               . "where `session_id` = '$session_id'";
62.         $this->db->query($sql);
63.         return true;
64.     }
65.     function destroy($session_id) {
66.         $session_id = $this->db->escape_string($session_id);
67.         $this->db->query("delete from `sessions` where `session_id` = '$session_id'");
68.         return true;
69.     }
70.     function gc($lifetime) {
71.         $this->db->query("delete from `sessions` where unix_timestamp(now()) - unix_timestamp(`last_visit`) > $lifetime");
72.         return true;
73.     }
74.     // get sessions by user_id
75.     function get($user_id) {
76.         $user_id = $this->db->escape_string($user_id);
77.         return $this->db->query("select * from `sessions` where `user_id` = '$user_id'");
78.     }
79.     // get sessions list
80.     function lists($page, $rows) {
81.         if ($page == 0) {
82.             return $this->db->query("select * from `sessions` order by `user_id`");
83.         }
84.         else {
85.             $start = ($page - 1) * $rows;
86.             return $this->db->query("select * from `sessions` order by `user_id` limit $start, $rows");
87.         }
88.     }
89. }
90. ?>

这个类的使用很简单，在原来使用 session_start 的地方，替换成 $session = new session($db) 就可以了。$db 表示 sessions 表所在的数据库。

另外可以用 get 方法来获取某个用户的所有会话信息，通过 lists 方法来得到所有用户会话列表。这样就可以方便的管理用户会话了。