使用 MySQL 开始 PHP 会话

来自：http://www.coolcode.cn/?p=43
默认情况下，PHP会话（session）是通过文件来保存的。这样做有以下几个缺点：
: ^+ h; h$ ]1 K) c5 w
会话文件一般都很小，但文件数却很多，在文件系统中保存许多这样的小文件非常浪费空间，且效率不高。
7 k4 k7 H  S' E! j' K" j* b
分布式的站点难以利用会话文件来共享会话。
会话文件方式不利于统计在线用户的会话信息。

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

对于 PHP 开发来说，保存会话用 MySQL 是一个非常不错的选择。MySQL 提供一种建立在内存中的表类型 Heap，如果每条会话数据量很小的话，可以考虑用这种类型的表来进一步优化性能。但是 Heap 类型的表有许多限制，例如它不支持 text 类型的字段，因此如果在无法预测会话数据记录长度的情况下，选择 MyISAM 是比较合适的，这种类型的表没有事物处理开销，对于基于磁盘的表可以得到最优性能。
: |- j% u3 m; F& d: ?; i
, u2 a! L' Z( x9 ?- Y) T下面是 sessions 表的结构：
8 C8 V& ^$ s( x  w# a+ r9 ^5 m

DROP TABLE IF EXISTS `sessions`;  
% l, A- G" z% q' Q4 g! m$ VCREATE TABLE `sessions` (  
  `session_id` varchar(32) NOT NULL default '',  
  `user_id` int(10) unsigned NOT NULL default '0',  
" z( Q: |2 T  L4 p5 n; J  `data_value` text NOT NULL,  
* J# M: ?+ F$ I, V  P% P+ }( ^  o# I% M  `last_visit` timestamp(14) NOT NULL,  
  PRIMARY KEY (`session_id`),  
  KEY `user_id` (`user_id`)  
+ I3 c3 Z1 G! F) TYPE=MyISAM;

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

用户会话数据在会话处理函数中都是序列化之后的，要取出其中的某个会话变量，可以对其进行反序列化，默认是 php 序列化方式，可以用 unserialize 函数来反序列化。
, ?7 s! E+ Y" ?7 u( P
5 v; l2 p$ a/ _2 B( Q  m下面的代码定义了一个用 MySQL 来处理 PHP 会话的类，其中所使用的 class_mysql.php 请参见 《超级简单但超级实用的 PHP 的 mysql 类》 。

<?php  
' l: J( {5 v* j, u" L9 Z/**  
* @author Ma Bingyao  
* @copyright (C) 2005 CoolCode.CN  
/ |. [! r9 k- m9 B) _' B*/  
7 y6 ^% y  Q) t  m   
! T4 E- V' w+ Y2 r, prequire_once("class_mysql.php");  
+ L! c7 e& F( r' `6 u! J: r   
class session {  
    var $db;  
    function session(&$db) {  
        $this->db = &$db;  
        session_module_name('user');  
        session_set_save_handler(  
+ {" D+ |* F  `' Q            array(&$this, 'open'),  
7 s5 i1 D( O2 G- J1 @6 d* o            array(&$this, 'close'),  
            array(&$this, 'read'),  
& I  u+ R" z6 B7 a: r: W            array(&$this, 'write'),  
            array(&$this, 'destroy'),  
            array(&$this, 'gc')  
) P/ |! w4 D& B/ a' R8 c        );  
" l+ ~/ ?) C1 D0 q        session_start();  
  i7 O' O7 k8 o. L. g; e    }  
8 u5 [! I: t& s) _$ F- ?; t2 D    function open($path, $name) {  
        return true;  
    }  
+ D$ G, x( j) C. k" Y8 v- D) A" t8 b    function close() {  
        return true;  
    }  
2 M. m' d. y  |    function read($session_id) {  
4 P1 l0 M1 V" Z  s/ T        $session_id = $this->db->escape_string($session_id);  
        if ($row = $this->db->query("select * from `sessions` where `session_id` = '$session_id' limit 1")) {  
" m$ V7 o( [1 v+ K1 {' ]! f            return $row->data_value;  
$ c( z( V  w3 p8 ]( t0 V        }  
        else {  
            $this->db->query("insert into `sessions` set `session_id` = '$session_id'");  
8 g' {2 X5 I# N9 Z# z6 c& h            return "";  
; \4 y, X$ u! {% X        }  
2 f* J  L7 X! q7 K' l8 x/ N$ s8 B+ t+ P    }  
4 p: d/ r  X  |" Y! ^) `    function write($session_id, $data_value) {  
; k+ z. f0 ~1 s- j  O: p        $session_id = $this->db->escape_string($session_id);  
* f. d8 g5 A) z% h7 w) j& @$ X* @6 `        $data_value = $this->db->escape_string($data_value);  
        $data = unserialize($data_value);  
        $this->db->query("update `sessions` set "   
                                . "`user_id` = '{$data['user_id']}', "  
                                . "`data_value` = '$data_value', "  
. z- b9 A% c9 ~1 F  l8 Q                                . "`last_visit` = null "  
+ [; c- t0 l5 E! L; L. k                                . "where `session_id` = '$session_id'");  
+ w7 B" c  A! B. L1 ?        return true;  
# A& @3 k! f, O  G; N  E7 _* }% y    }  
    function destroy($session_id) {  
        $session_id = $this->db->escape_string($session_id);  
        $this->db->query("delete from `sessions` where `session_id` = '$session_id'");  
        return true;  
    }  
    function gc($lifetime) {  
        $this->db->query("delete from `sessions` where unix_timestamp(now()) - unix_timestamp(`last_visit`) > $lifetime");  
5 \8 ~, i5 Q4 m' b0 U, a        return true;  
    }  
# b" F1 p2 w# K    function replace($session_id, $data_value) {  
& }3 g0 `! i7 G. |# E+ \: G        $session_id = $this->db->escape_string($session_id);  
8 I, a" Y* M3 ?/ f1 a2 g1 l        $data_value = $this->db->escape_string($data_value);  
" M+ F9 h8 f4 v+ d        $data = unserialize($data_value);  
9 c& b( p  x/ e% l, Y' {        $this->db->query("replace `sessions` set "   
( M5 b9 S. r/ c$ {                                . "`session_id` = '$session_id', "  
0 [5 f7 z- V. t8 T3 @                                . "`user_id` = '{$data['user_id']}', "  
                                . "`data_value` = '$data_value', "  
  S* Q& @4 v: U$ N+ d                                . "`last_visit` = null");  
5 K) Q! U  {' t# g    }  
    // get sessions by user_id  
    function get($user_id) {  
% }$ z4 Q$ N8 ~5 A        $user_id = $this->db->escape_string($user_id);  
+ P  V2 X8 C6 U* M- _        return $this->db->query("select * from `sessions` where `user_id` = '$user_id'");  
    }  
8 N9 O! b. g; M    // get sessions list  
' E. |4 W( v" q    function list($page, $rows) {  
        if ($page == 0) {  
$ h7 t2 `# H- i6 h- k            return $this->db->query("select * from `sessions` order by `user_id`");  
2 o& m, @( O/ j( m        }  
        else {  
* e; k3 T) n' v' k. m, X            $start = ($page - 1) * $rows;  
5 ?& r: G1 A5 b, D" M, z( I0 M            return $this->db->query("select * from `sessions` order by `user_id` limit $start, $rows");  
3 p9 K! _5 m% Z        }  
1 k4 ^, C9 [8 k( h; \4 C8 e( X    }  
}  
?>

: X$ w* F$ @0 s: G: f) l' ~) u这个类的使用很简单，在原来使用 session_start 的地方，替换成 $session = new session($db) 就可以了。$db 表示 sessions 表所在的数据库。

" j- U9 \' Y9 W# J& b另外可以用 get 方法来获取某个用户的所有会话信息，通过 list 方法来得到所有用户会话列表。这样就可以方便的管理用户会话了。