默认情况下,PHP会话(session)是通过文件来保存的。这样做有以下几个缺点:
会话文件一般都很小,但文件数却很多,在文件系统中保存许多这样的小文件非常浪费空间,且效率不高。 分布式的站点难以利用会话文件来共享会话。 会话文件方式不利于统计在线用户的会话信息。 为解决以上问题,我们可以考虑用数据库来保存会话信息。 对 于 PHP 开发来说,保存会话用 MySQL 是一个非常不错的选择。MySQL 提供一种建立在内存中的表类型 Heap,如果每条会话数据量很小的 话,可以考虑用这种类型的表来进一步优化性能。但是 Heap 类型的表有许多限制,例如它不支持 text 类型的字段,因此如果在无法预测会话数据记 录长度的情况下,选择 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 函数来反序列化。 这个类的使用很简单,在原来使用 session_start 的地方,替换成 $session = new session($db) 就可以了。$db 表示 sessions 表所在的数据库。 另外可以用 get 方法来获取某个用户的所有会话信息,通过 lists 方法来得到所有用户会话列表。这样就可以方便的管理用户会话了。 require_once ( "class_mysql.php" ); class session { public $db ; function session(& $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(); } function unserialize( $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; isset( $vars [ $i ]); $i ++) { $result [ $vars [ $i ++]] = unserialize( $vars [ $i ]); } return $result ; } function open( $path , $name ) { return true; } function close() { return true; } function read( $session_id ) { $session_id = $this -> db -> escape_string( $session_id ); if ( $row = $this -> db -> query( "select * from `sessions` where `session_id` = '$session_id' limit 1" )) { return $row [ 'data_value' ]; } else { $this -> db -> query( "insert into `sessions` set `session_id` = '$session_id'" ); return "" ; } } function write( $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 ); $sql = "update `sessions` set " ; if (isset( $data [ 'user_id' ])) { $sql .= "`user_id` = '{$data['user_id']}', " ; } $sql .= "`data_value` = '$data_value', " . "`last_visit` = null " . "where `session_id` = '$session_id'" ; $this -> db -> query( $sql ); return true; } 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" ); return true; } // get sessions by user_id function get( $user_id ) { $user_id = $this -> db -> escape_string( $user_id ); return $this -> db -> query( "select * from `sessions` where `user_id` = '$user_id'" ); } // get sessions list function lists( $page , $rows ) { if ( $page == 0) { return $this -> db -> query( "select * from `sessions` order by `user_id`" ); } else { $start = ( $page - 1) * $rows ; return $this -> db -> query( "select * from `sessions` order by `user_id` limit $start, $rows" ); } } } ?> |