会话文件一般都很小,但文件数却很多,在文件系统中保存许多这样的小文件非常浪费空间,且效率不高。
分布式的站点难以利用会话文件来共享会话。
会话文件方式不利于统计在线用户的会话信息。
为解决以上问题,我们可以考虑用数据库来保存会话信息。
对于PHP开发来说,保存会话用MySQL是一个非常不错的选择。MySQL提供一种建立在内存中的表类型Heap,如果每条会话数据量很小的话,可以考虑用这种类型的表来进一步优化性能。但是Heap类型的表有许多限制,例如它不支持text类型的字段,因此如果在无法预测会话数据记录长度的情况下,选择MyISAM是比较合适的,这种类型的表没有事物处理开销,对于基于磁盘的表可以得到最优性能。
下面是sessions表的结构:
DROPTABLEIFEXISTS`sessions`;
CREATETABLE`sessions`(
`session_id`varchar(32)NOTNULLdefault'',
`user_id`int(10)unsignedNOTNULLdefault'0',
`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马秉尧
*@copyright(C)2005CoolCode.CN
*/
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_id'limit1“)){
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方法来得到所有用户会话列表。这样就可以方便的管理用户会话了。