PHP实现多服务器session共享之mysql共享

当前位置：网学 > 编程文档 > PHP > 正文

作者：用户投稿来源：网络发布时间： 12/12/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 <= count($row)) 　　　　　　{ 　　　　　　　　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` < $last;", DB_NAME, self::$mTblSess, self::$mTblSessMap['last']); 　　　　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();