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

闲话不多说了，相关文章请查看 PHP实现多服务器session共享之NFS共享 和 PHP实现多服务器session共享之memcache共享。
基于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 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` 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();
?>

以上代码在 php5.20 中测试通过。