多服務器共享session(mysql)

2019-11-17 04:10:49

字體：大中小

來源：轉載

供稿：網友

php代碼
<?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 <= 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();
?>

上一篇：利用Java控制EXCEL實例詳解

下一篇：如何在Windows下手動將Tomcat 安裝成為系統服務