Memcache ストレージに基づいて Session クラスを実装する

cache|session

我没事的时候写的自主实现Session功能的类，基于文件方式存储Session数据，测试基本通过，还比较好玩，实际应用没有意义，只不过是学习Session是如何实现的。

使用基于文件的Session存取瓶颈可能都是在磁盘IO操作上，所以对付小数据量的Session没有问题，但是如果碰到大数据量的Sesstion，那么可能无法胜任，现在利用Memcache来保存Session数据，直接通过内存的方式，效率自然能够提高不少，并且如果结合PHP的Memcache扩展，能够支持分布式的Memcache服务器，那么这个性能就能够提到更高，负载更多更复杂的应用。

说明：以下代码基于Memcache来保存Session数据，客户端必须安装有PHP的Memcache扩展，否则无法运行，同时本代码没有经过严格测试，只是作为学习代码。

//===========================================
// 程序：Memcache-Based Session Class
// 功能：基于Memcache存储的 Session 功能类
// 作者: heiyeluren
// 博客: http://blog.csdn.net/heiyeshuwu
// 时间: 2006-12-23
//===========================================

/**
* 类名: FileSession Class
* 功能: 自主实现基于Memcache存储的 Session 功能
* 描述: 这个类就是实现Session的功能, 基本上是通过设置客户端的Cookie来保存SessionID,
* 然后把用户的数据保存在服务器端,最后通过Cookie中的Session Id来确定一个数据是否是用户的,
* 然后进行相应的数据操作, 目前的缺点是没有垃圾收集功能
*
* 本方式适合Memcache内存方式存储Session数据的方式，同时如果构建分布式的Memcache服务器，
* 能够保存相当多缓存数据，并且适合用户量比较多并发比较大的情况
* 注意: 本类必须要求PHP安装了Memcache扩展, 获取Memcache扩展请访问: http://pecl.php.net
*/
class MemcacheSession
{
var $sessId = '';
var $sessKeyPrefix = 'sess_';
var $sessExpireTime = 86400;
var $cookieName = '__SessHandler';
var $cookieExpireTime = '';
var $memConfig = array('host'=>'192.168.0.200', 'port'=>11211);
    var $memObject            = null;   
   
   
    /**
     * 构造函数
     *
     * @param bool $isInit - 是否实例化对象的时候启动Session
     */
    function MemcacheSession($isInit = false){
        if ($isInit){
            $this->start();
        }
    }

//-------------------------------------
// 外部方法
//-------------- -----------

/**
* セッションの開始操作
*
* @param int $expireTime - セッションの有効期限、デフォルトは 0、ブラウザを閉じると期限切れになります、値の単位は秒です
*/
function start($expireTime = 0){
$sessId = $_COOKIE[$this->cookieName];
if (! $sessId){
$this->sessId = $this->_getId();
$this->cookieExpireTime = ($expireTime > 0) ? time() + $expireTime : 0;
setcookie($this->cookieName, $this->sessId, $this->cookieExpireTime, "/", '');
$this->_initMemcacheObj() ;
$_SESSION = array();
$this->_saveSession();
} else {
$this->sessId = $sessId;
$_ SESSION = $this->_getSession($sessId);
}
}

/**
* セッション変数が登録されているかどうかを判断します
*
* @param string $varName -
* @return bool は、存在する場合は true を返し、存在しない場合は false を返します
*/
function is_registered($varName){
if (!isset($_SESSION[$varName])){
return false;
}
return true;
}

/*** セッション変数を登録すると、登録が成功し、true が返されます
*/
function register($varName, $varValue){
if (isset($_SESSION[$varName])){
return false;
}
$_SESSION[$varName] = $varValue;
$this->_saveSession();
return true;
}

/**
* 登録されたセッション変数を破棄します
*
* @param string $varName - 破棄する必要があるセッション変数の名前
* @return bool 破棄が成功した場合は true を返します
*/
function unregister($varName){
unset($_SESSION[$varName]);
$this-> ;_saveSession();
return true;
}

/**
* 登録されているセッション変数をすべて破棄します
*
* @return 破棄が成功した場合は true を返します
*/
function destroy(){
$_SESSION = array();
$this->_saveSession();
true を返します。   
}

/**
* 获取一个已注册的セッション变量值
*
* @param string $varName - セッション变量の名前
     * @return mixed - 不存在的变量返回false, 存在变量返回变量值
     */
    function get($varName){
        if (!isset($_SESSION[$varName])){
            return false;
        }
        return $_SESSION[$varName];
    }   
   
    /**
     * 获取所有Session变量
     *
     * @return array - 返回所有已注册的Session变量值
     */
    function getAll(){
        return $_SESSION;
    }
   
    /**
     * 获取当前的Session ID
     *
     * @return string 获取的SessionID
     */
    function getSid(){
        return $this->sessId;
    }

/**​​​​*/
function getMemConfig(){
return $this->memConfig;
}

/**
* Memcache の構成情報を設定します
*
* @param string $host - Memcache サーバーの IP
* @param int $port - Memcache サーバーのポート
*/
function setMemConfig($host, $port){
$this ->memConfig = array('host'=>$host, 'port'=>$port);
}


//----------------- --------
// 内部インターフェース
//--------------------------------------

/**
* /
function _getId(){
return md5(uniqid(microtime()));
}

/**
* memcacheで保存されたセッションキーを取得
*
* @param string $ sessid-セッションIDを指定するかどうか
*/
function _getSessKey($sessId = ''){
$sessId = = ='')? $this->sessKeyPrefix.$this->sessId : $this->sessKeyPrefix.$sessId;
return $sessKey;
}
/**
*/
_initMemcacheObj(){
もし(! class_exists('Memcache') || !function_exists('memcache_connect')){
$this->showMessage('失敗: Memcache 拡張機能がインストールされません。http://pecl.php.net からダウンロードしてインストールしてください');
}
if ($this->memObject && is_object($this->memObject)){
return true;
}
$mem = new Memcache;
if (!@$mem->connect($this ->memConfig['host'], $this->memConfig['port'])){
$this->_showMessage('失敗: memcache ホストの接続 '. $this->memConfig['host' ] .':'. $this->memConfig['port'] .' 失敗しました');
}
$this->memObject = $mem;
return true;
}

/**
* セッションファイル内のデータを取得します
*
* @param string $sessId - セッションデータを取得する必要がある SessionId
* @return known
*/
function _getSession($sessId = ''){
$this->_initMemcacheObj();
$sessKey = $this->_getSessKey($sessId);
$sessData = $this->memObject-&g t ;get($sessKey);
if (!is_array($sessData) || empty($sessData)){
$this->_showMessage('失敗: セッション ID '. $sessKey .' セッション データが存在しません');
}
return $sessData;
}

/**
*掴み現在のセッションデータは Memcache に保存されます
*
     * @param string $sessId - セッション ID
* @return 成功返還 true
*/
function _saveSession($sessId = ''){
$this->_initMemcacheObj();
$this->_getS essキー($sessId);
if (empty($_SESSION)){
$ret = @$this->memObject->set($sessKey, $_SESSION, false, $this->sessExpireTime);
}else {
$ ret = @$ this-＆gt; memobject-＆gt;置換（$ sesskey、$ _session、false、$ this-＆gt; sessexpiretime）; ('失敗: セッション データの保存に失敗しました。memcache サーバーを確認してください');
}
return true;
}

/**
* プロンプトメッセージを表示します
*
* @param string $strMessage – 表示されるメッセージの内容
* @param bool $isFailed – 失敗メッセージかどうか、デフォルトは true です
*/
function _showMessage($strMessage, $isFailed = true){
if ( $isFailed){
exit($strMessage);
}
echo $strMessage;
}
}
?>