多服務(wù)器共享session(mysql)

2019-11-17 04:10:49

字體：大中小

供稿：網(wǎng)友

php代碼
<?php
/* vim: set expandtab tabstop=4 shiftwidth=4 foldmethod=marker: */
//===========================================
// 程序：   MySQL-Based session Class
// 功能：   基于mysql存儲(chǔ)的 Session 功能類
// 作者:    yejr
// 網(wǎng)站:    http://imysql.cn
// 時(shí)間:    2007-01-05
//===========================================

/**
* 類名:    MySQL Session Class
* 功能:    自主實(shí)現(xiàn)基于MySQL HEAP表存儲(chǔ)的 Session 功能
* 描述:    這個(gè)類就是實(shí)現(xiàn)Session的功能，基本上是通過(guò)設(shè)置客戶端的Cookie來(lái)保存SessionID，
*          然后把用戶的數(shù)據(jù)保存在服務(wù)器端，最后通過(guò)Cookie中的Session Id來(lái)確定一個(gè)數(shù)據(jù)是否是用戶的，
*          然后進(jìn)行相應(yīng)的數(shù)據(jù)操作
*
* 注意: 本類調(diào)用了PEAR::DB類,如果有自己的DB類,則可以稍微修改一下代碼
*
* 備注：數(shù)據(jù)表初始化SQL語(yǔ)句:
* 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;
*/

//設(shè)定 SESSION 有效時(shí)間，單位是秒
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;

    // {{{ 初始化構(gòu)造函數(shù)
    /**
     * 構(gòu)造函數(shù)
     *
     * @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,否則取回的數(shù)組只能用數(shù)字做下標(biāo)
        if (!PEAR::isError($row = self::$mDb->getRow($wSql, null, DB_FETCHMODE_ASSOC)))
        {
            //session已經(jīng)存在了
            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;

        //計(jì)算出過(guò)期時(shí)間
        $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);

        //設(shè)置垃圾回收最大生存時(shí)間
        ini_set('session.gc_maxlifetime',   SESS_LIFTTIME);

        //使用 COOKIE 保存 SESSION ID 的方式
        ini_set('session.use_cookies',      1);
        ini_set('session.cookie_path',      '/');

        //多主機(jī)共享保存 SESSION ID 的 COOKIE
        ini_set('session.cookie_domain',    $domain);

        //將 session.save_handler 設(shè)置為 user，而不是默認(rèn)的 files
        session_module_name('user');

        //定義 SESSION 各項(xiàng)操作所對(duì)應(yīng)的方法名：
        session_set_save_handler(
                array('Usess', 'sessOpen'),   //對(duì)應(yīng)于靜態(tài)方法 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實(shí)例詳解

下一篇：如何在Windows下手動(dòng)將Tomcat 安裝成為系統(tǒng)服務(wù)