多服务器共享session(mysql)

php代码
/* vim: set expandtab tabstop=4 shiftwidth=4 foldmethod=marker: */　
//===========================================　
// 程序：　 MySQL-Based session Class　
// 功能：　 基于mysql存储的 Session 功能类　
// 作者:　 yejr　
// 网站:　 http://imysql.cn　
// 时间:　 2007-01-05　
//===========================================　
　
/**　
* 类名:　 MySQL Session Class　
* 功能:　 自主实现基于MySQL HEAP表存储的 Session 功能　
* 描述:　 这个类就是实现Session的功能，基本上是通过设置客户端的Cookie来保存SessionID，　
*　　　　 然后把用户的数据保存在服务器端，最后通过Cookie中的Session Id来确定一个数据是否是用户的，　
*　　　　 然后进行相应的数据操作　
*　
* 注意: 本类调用了PEAR::DB类,如果有自己的DB类,则可以稍微修改一下代码　
*　
* 备注：数据表初始化SQL语句:　
* CREATE TABLE `sessions` (　
* `sid` varchar(32) NOT NULL default '',　
* `session` longtext,　
* `flush_dt` int unsigned NOT NULL default '0',　
* PRIMARY KEY (`sid`),　
* KEY `last` (`flush_dt`)　
* ) ENGINE=HEAP;　
*/　
　
//设定 SESSION 有效时间，单位是 秒　
define('SESS_LIFTTIME', 3600);　
define('DB_DSN', 'mysql://root:@localhost/test');　
define('DB_NAME','test');　
　
require_once('DB.php');　
　
$gDb　 = new DB;　
$gDb　 = DB::connect(DB_DSN, TRUE);　
　
if (PEAR::isError($gDb))　
{　
　 die($gDb->getMessage());　
}　
　
if (!defined('MySQLSession'))　
{　
　 define('MySQLSession',　 TRUE);　
　
class Usess　
{　
　 static $mSessSavePath;　
　 static $mSessName;　
　 static $mSessMaxTime;　
　 static $mTblSess　 = 'sessions';　
　 static $mTblSessMap;　
　 static $mDb;　
　
　 // {{{ 初始化构造函数　
　 /**　
　　 * 构造函数　
　　 *　
　　 * @param string $login_user　 登录用户　
　　 * @param int $login_type　　　 用户类型　
　　 * @param string $login_sess　 登录Session值　
　　 * @return Esession　
　　 */　
　 public function __construct()　
　 {　
　　　 self::$mSessMaxTime = SESS_LIFTTIME;　
　
　　　 self::$mTblSessMap = array(　
　　　　　　　 'sid'　 => 'sid',　
　　　　　　　 'data' => 'session',　
　　　　　　　 'last' => 'flush_dt',　
　　　　　　　 );　
　 }　
　 // }}}　
　
　 /** {{{ sessOpen($pSavePath, $name)　
　　 *　
　　 * @param　 String $pSavePath　
　　 * @param　 String $pSessName　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function sessOpen($pSavePath = '', $pSessName = '')　
　 {　
　　　 global $gDb;　
　
　　　 self::$mDb = $gDb;　
　　　 self::$mSessSavePath　 = $pSavePath;　
　　　 self::$mSessName　　　 = $pSessName;　
　
　　　 self::sessGc();　
　
　　　 return TRUE;　
　 }　
　 // }}}　
　
　 /** {{{ sessClose()　
　　 *　
　　 * @param　 NULL　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function sessClose()　
　 {　
　　　 return TRUE;　
　 }　
　 // }}}　
　
　 /** {{{ sessRead($wSid)　
　　 *　
　　 * @param　 String $wSid　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function sessRead($wSid = '')　
　 {　
　　　 global $db;　
　
　　　 $wSql　 = sprintf("SELECT * FROM `%s`.`%s` WHERE `%s` = '%s';",　
　　　　　　　　　　　 DB_NAME,　
　　　　　　　　　　　 self::$mTblSess,　
　　　　　　　　　　　 self::$mTblSessMap['sid'],　
　　　　　　　　　　　 $wSid　
　　　　　　　 );　
　
　　　 //这里一定要用 DB_FETCHMODE_ASSOC,否则取回的数组只能用数字做下标　
　　　 if (!PEAR::isError($row = self::$mDb->getRow($wSql, null, DB_FETCHMODE_ASSOC)))　
　　　 {　
　　　　　 //session已经存在了　
　　　　　 if (is_array($row) && 1 　　　　　 {　
　　　　　　　 return $row[self::$mTblSessMap['data']];　
　　　　　 }　
　　　　　 else　
　　　　　 {　
　　　　　　　 $wSql　 = sprintf("INSERT INTO `%s`.`%s` VALUES ('%s', '', UNIX_TIMESTAMP(NOW()));",　
　　　　　　　　　　　　　　　 DB_NAME,　
　　　　　　　　　　　　　　　 self::$mTblSess,　
　　　　　　　　　　　　　　　 $wSid　
　　　　　　　　　　　 );　
　
　　　　　　　 if (!PEAR::isError(self::$mDb->query($wSql)))　
　　　　　　　 {　
　　　　　　　　　 return TRUE;　
　　　　　　　 }　
　　　　　 }　
　　　 }　
　
　　　 return FALSE;　
　 }　
　 // }}}　
　
　 /** {{{ sessWrite($wSid, $wData)　
　　 *　
　　 * @param　 String $wSid　
　　 * @param　 String $wData　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function sessWrite($wSid = '', $wData = '')　
　 {　
　　　 $wData = mysql_escape_string($wData);　
　
　　　 $wSql　 = sprintf("UPDATE `%s`.`%s` SET `%s` = '%s', `%s` = UNIX_TIMESTAMP(NOW()) WHERE `%s` = '%s';",　
　　　　　　　　　　　 DB_NAME,　
　　　　　　　　　　　 self::$mTblSess,　
　　　　　　　　　　　 self::$mTblSessMap['data'],　
　　　　　　　　　　　 $wData,　
　　　　　　　　　　　 self::$mTblSessMap['last'],　
　　　　　　　　　　　 self::$mTblSessMap['sid'],　
　　　　　　　　　　　 $wSid　
　　　　　　　 );　
　
　　　 if (!PEAR::isError(self::$mDb->query($wSql)))　
　　　 {　
　　　　　 return TRUE;　
　　　 }　
　
　　　 return FALSE;　
　 }　
　 // }}}　
　
　 /** {{{ sessDestroy($wSid)　
　　 *　
　　 * @param　 String $wSid　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function sessDestroy($wSid = '')　
　 {　
　　　 $wSql　 = sprintf("DELETE FROM `%s`.`%s` WHERE `%s` = '%s';",　
　　　　　　　　　　　 DB_NAME,　
　　　　　　　　　　　 self::$mTblSess,　
　　　　　　　　　　　 $wSid　
　　　　　　　 );　
　
　　　 if (!PEAR::isError(self::$mDb->query($wSql)))　
　　　 {　
　　　　　 return TRUE;　
　　　 }　
　
　　　 return FALSE;　
　 }　
　 // }}}　
　
　 /** {{{ sessGc()　
　　 *　
　　 * @param　 NULL　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function sessGc()　
　 {　
　　　 global $db;　
　
　　　 //计算出过期时间　
　　　 $last　 = time() - self::$mSessMaxTime;　
　
　　　 $wSql　 = sprintf("DELETE FROM `%s`.`%s` WHERE `%s` 　
　　　 if (!PEAR::isError(self::$mDb->query($wSql)))　
　　　 {　
　　　　　 return TRUE;　
　　　 }　
　
　　　 return FALSE;　
　 }　
　 // }}}　
　
　 /** {{{ initSess()　
　　 *　
　　 * @param　 NULL　
　　 *　
　　 * @return Bool　 TRUE/FALSE　
　　 */　
　 public function initSess()　
　 {　
　　　 $domain = '';　
　
　　　 //不使用 GET/POST 变量方式　
　　　 ini_set('session.use_trans_sid',　 0);　
　
　　　 //设置垃圾回收最大生存时间　
　　　 ini_set('session.gc_maxlifetime',　 SESS_LIFTTIME);　
　
　　　 //使用 COOKIE 保存 SESSION ID 的方式　
　　　 ini_set('session.use_cookies',　　 1);　
　　　 ini_set('session.cookie_path',　　 '/');　
　
　　　 //多主机共享保存 SESSION ID 的 COOKIE　
　　　 ini_set('session.cookie_domain',　 $domain);　
　
　　　 //将 session.save_handler 设置为 user，而不是默认的 files　
　　　 session_module_name('user');　
　
　　　 //定义 SESSION 各项操作所对应的方法名：　
　　　 session_set_save_handler(　
　　　　　　　 array('Usess', 'sessOpen'),　 //对应于静态方法 My_Sess::open()，下同。　
　　　　　　　 array('Usess', 'sessClose'),　
　　　　　　　 array('Usess', 'sessRead'),　
　　　　　　　 array('Usess', 'sessWrite'),　
　　　　　　　 array('Usess', 'sessDestroy'),　
　　　　　　　 array('Usess', 'sessGc')　
　　　　　　　 );　
　　　 session_start();　
　
　　　 return TRUE;　
　 }　
　 // }}}　
　
}//end class　
　
}//end define　
　
$sess　 = new Usess;　
$sess->initSess();　
?>