使用 MySQL 开始 PHP 会话

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

会话文件一般都很小，但文件数却很多，在文件系统中保存许多这样的小文件非常浪费空间，且效率不高。
分布式的站点难以利用会话文件来共享会话。
会话文件方式不利于统计在线用户的会话信息。
为解决以上问题，我们可以考虑用数据库来保存会话信息。

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

下面是sessions表的结构：

DROPTABLEIFEXISTS`sessions`;
CREATETABLE`sessions`(
`session_id`varchar(32)NOTNULLdefault,
`user_id`int(10)unsignedNOTNULLdefault0,
`data_value`textNOTNULL,
`last_visit`timestamp(14)NOTNULL,
PRIMARYKEY(`session_id`),
KEY`user_id`(`user_id`)
)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请参见《超级简单但超级实用的PHP的mysql类》。

〈?php
/**
*@author马秉尧
*/

require_once(“class_mysql.php“);

classsession{
var$db;
functionsession(&$db){
$this-〉db=&$db;
session_module_name(user);
session_set_save_handler(
array(&$this,open),
array(&$this,close),
array(&$this,read),
array(&$this,write),
array(&$this,destroy),
array(&$this,gc)
);
session_start();
}
functionunserialize($data_value){
$vars=preg_split(
/([a-zA-Z_\x7f-\xff][a-zA-Z0-9_\x7f-\xff]*)\/,
$data_value,-1,PREG_SPLIT_NO_EMPTY
PREG_SPLIT_DELIM_CAPTURE
);
for($i=0;$vars[$i];$i++){
$result[$vars[$i++]]=unserialize($vars[$i]);
}
return$result;
}
functionopen($path,$name){
returntrue;
}
functionclose(){
returntrue;
}
functionread($session_id){
$session_id=$this-〉db-〉escape_string($session_id);
if($row=$this-〉db-〉query(“select*from`sessions`where`session_id`=$session_idlimit1“)){
return$row[data_value];
}
else{
$this-〉db-〉query(“insertinto`sessions`set`session_id`=$session_id“);
return““;
}
}
functionwrite($session_id,$data_value){
$data=$this-〉unserialize($data_value);
$session_id=$this-〉db-〉escape_string($session_id);
$data_value=$this-〉db-〉escape_string($data_value);
$this-〉db-〉query(“update`sessions`set“
.“`user_id`={$data[user_id]},“
.“`data_value`=$data_value,“
.“`last_visit`=null“
.“where`session_id`=$session_id“);
returntrue;
}
functiondestroy($session_id){
$session_id=$this-〉db-〉escape_string($session_id);
$this-〉db-〉query(“deletefrom`sessions`where`session_id`=$session_id“);
returntrue;
}
functiongc($lifetime){
$this-〉db-〉query(“deletefrom`sessions`whereunix_timestamp(now())-unix_timestamp(`last_visit`)〉$lifetime“);
returntrue;
}
//getsessionsbyuser_id
functionget($user_id){
$user_id=$this-〉db-〉escape_string($user_id);
return$this-〉db-〉query(“select*from`sessions`where`user_id`=$user_id“);
}
//getsessionslist
functionlists($page,$rows){
if($page==0){
return$this-〉db-〉query(“select*from`sessions`orderby`user_id`“);
}
else{
$start=($page-1)*$rows;
return$this-〉db-〉query(“select*from`sessions`orderby`user_id`limit$start,$rows“);
}
}
}
?〉

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

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