Memcache的Session數(shù)據(jù)的多服務(wù)器共享方式

本篇內(nèi)容介紹了“Memcache的Session數(shù)據(jù)的多服務(wù)器共享方式”的有關(guān)知識，在實(shí)際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

一相關(guān)介紹
1.memcache + memcache的多服務(wù)器數(shù)據(jù)共享的介紹，請參見http://www.guigui8.com/index.php/archives/206.html
2.session機(jī)制：
session機(jī)制是一種服務(wù)器端的機(jī)制，服務(wù)器使用一種類似于散列表的結(jié)構(gòu)（也可能就是使用散列表）來保存信息。
當(dāng)程序需要為某個客戶端的請求創(chuàng)建一個session的時候，服務(wù)器首先檢查這個客戶端的請求里是否已包含了一個session標(biāo)識- 稱為sessionid，如果已包含一個sessionid則說明以前已經(jīng)為此客戶端創(chuàng)建過session，服務(wù)器就按照sessionid把這個session檢索出來使用（如果檢索不到，可能會新建一個），如果客戶端請求不包含sessionid，則為此客戶端創(chuàng)建一個session并且生成一個與此session相關(guān)聯(lián)的sessionid，sessionid的值應(yīng)該是一個既不會重復(fù)，又不容易被找到規(guī)律以仿造的字符串，這個sessionid將被在本次響應(yīng)中返回給客戶端保存。

保存這個sessionid的方式可以采用cookie，這樣在交互過程中瀏覽器可以自動的按照規(guī)則把這個標(biāo)識發(fā)揮給服務(wù)器。

一般這個cookie的名字都是類似于SEEESIONID，而。比如weblogic對于web應(yīng)用程序生成的cookie，PHPSESSID=ByOK3vjFD75aPnrF3K2HmdnV6QZcEbzWoWiBYEnLerj，它的名字就是PHPSESSID。

二動機(jī)
在實(shí)際web生產(chǎn)環(huán)境中，一個應(yīng)用系統(tǒng)，往往將不同的業(yè)務(wù)應(yīng)用分布到不同服務(wù)器上進(jìn)行處理。
當(dāng)跟蹤當(dāng)前在線用戶信息時，如果是同一個主域名時，可以用全域cookie處理相關(guān)數(shù)據(jù)的共享問題；如果是在不同主域下，則可以通過觀察者模式的中心話概念解決相應(yīng)問題，通過這種概念延伸出的解決方案有很多，而今天我所要講的，是前一種，通過memcache的多服務(wù)器數(shù)據(jù)共享技術(shù)來模擬session，以進(jìn)行對當(dāng)前在線用戶數(shù)據(jù)的多服務(wù)器共享。
關(guān)于多服務(wù)器統(tǒng)一session信息，要求如下：
1.能夠在memcached規(guī)定的幾臺服務(wù)器上，保存session信息（通過前面介紹的memcache的多服務(wù)器數(shù)據(jù)共享）；
2.能夠象zend定義的session_start()前，通過session_id($sessid)那樣，自定義session_id的值。
3.能方便的在系統(tǒng)運(yùn)行時，切換memcached存儲的session信息和 用文件存儲的session信息的操作。

三代碼
實(shí)現(xiàn)方式很簡單，通過memcache來模擬session機(jī)制，只是利用memcache將存儲媒介換成共享服務(wù)器的內(nèi)存，以達(dá)到多臺分布式部署的服務(wù)器共享session信息的目的。而調(diào)用的接口，與zend提供的session操作函數(shù)相區(qū)別，所以可以方便的在memcache和文件的session信息操作建切換。
以下代碼，已經(jīng)過多次實(shí)際測試，能達(dá)到以上功能需求。先貼下面了：

復(fù)制代碼 代碼如下:

/**
 *=---------------------------------------------------------------------------=
 *                         MemcacheSession.class.php
 *=---------------------------------------------------------------------------=
 *
 * 實(shí)現(xiàn)基于Memcache存儲的 Session 功能
 *  (模擬session機(jī)制，只是利用memcache將存儲媒介換成共享服務(wù)器的內(nèi)存)
 *
 * 缺點(diǎn)：暫時沒有引入不同主域的session共享機(jī)制的實(shí)現(xiàn)策略。即只支持同主域下的實(shí)現(xiàn)。
 *
 * Copyright(c) 2008 by guigui. All rights reserved.
 * @author guigui <evan_gui@163.com>
 * @version $Id: MemcacheSession.class.php, v 1.0 2008/12/22 $
 * @package systen
 * @link http://www.guigui8.com
 */

 
/**
 * class MemcacheSession
 *
 * 1. 設(shè)置客戶端的Cookie來保存SessionID
 * 2. 把用戶的數(shù)據(jù)保存在服務(wù)器端，通過Cookie中的Session Id來確定一個數(shù)據(jù)是否是用戶的
 */
class MemcacheSession
{
   // {{{ 類成員屬性定義
   public  $memObject          = null;      //memcache操作對象句柄
   private $_sessId            = '';
   private $_sessKeyPrefix     = 'sess_';
   private $_sessExpireTime    = 86400;  
   private $_cookieDomain      = '.guigui8.com';   //全域cookie域名
   private $_cookieName        = '_PROJECT_MEMCACHE_SESS';
   private $_cookieExpireTime  = '';   

   private $_memServers        = array('192.168.0.3' => 11211, '192.168.0.4' => 11211);
   private $_sessContainer     = array();     //當(dāng)前用戶的session信息
   private static $_instance   = null;      //本類單例對象
   // }}}

 
   /**
    * 單例對象獲取的靜態(tài)方法。
 * (可以順便提供memcache信息存儲的服務(wù)器參數(shù))
    *
    * @param string $host   - memcache數(shù)據(jù)存儲的服務(wù)器ip
    * @param integer $port  - memcache數(shù)據(jù)存儲的服務(wù)器端口號
    * @param bool $isInit   - 是否實(shí)例化對象的時候啟動Session
    */
   public static function getInstance($host='', $port=11211, $isInit = true) {
     if (null === self::$_instance) {
      self::$_instance = new self($host, $port, $isInit);
     }
     return self::$_instance;
   }

   /**
    * 構(gòu)造函數(shù)
    *
    * @param bool $isInit - 是否實(shí)例化對象的時候啟動Session
    */
   private function __construct($host='', $port=11211, $isInit = false){
       !empty($host) && $this->_memServers = array(trim($host) => $port);
       $isInit && $this->start();
   }

   /**
  *=-----------------------------------------------------------------------=
  *=-----------------------------------------------------------------------=
 *      Public Methods
  *=-----------------------------------------------------------------------=
  *=-----------------------------------------------------------------------=
  */

   /**
    * 啟動Session操作
    *
    * @param int $expireTime - Session失效時間,缺省是0,當(dāng)瀏覽器關(guān)閉的時候失效, 該值單位是秒
    */
   public 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->_cookieDomain);
           $this->_initMemcacheObj();

           $this->_sessContainer = array();
           $this->_saveSession();
       } else {
           $this->_sessId = $_sessId;
           $this->_sessContainer = $this->_getSession($_sessId);
       }       
   }

   /**
    * setSessId
    *
    * 自定義的session id，通常沒有必要經(jīng)過cookie操作處理的（所以省略了cookie記錄session_id）
    *
    * @param string $sess_id
    * @return boolean
    */
   public function setSessId($sess_id){
       $_sessId = trim($sess_id);
       if (!$_sessId){
           return false;
       } else {
           $this->_sessId = $_sessId;
           $this->_sessContainer = $this->_getSession($_sessId);
       }       
   }

   /**
    * 判斷某個Session變量是否注冊
    *
    * @param string $varName -
    * @return bool 存在返回true, 不存在返回false
    */
   public function isRegistered($varName){
       if (!isset($this->_sessContainer[$varName])){
           return false;
       }
       return true;
   }   

   /**
    * 注冊一個Session變量
    *
    * @param string $varName - 需要注冊成Session的變量名
    * @param mixed $varValue - 注冊成Session變量的值
    * @return bool - 該變量名已經(jīng)存在返回false, 注冊成功返回true
    */
   public function set($varName, $varValue){
       $this->_sessContainer[$varName] = $varValue;
       $this->_saveSession();
       return true;
   }

   /**
    * 獲取一個已注冊的Session變量值
    *
    * @param string $varName - Session變量的名稱
    * @return mixed - 不存在的變量返回false, 存在變量返回變量值
    */
   public function get($varName){
       if (!isset($this->_sessContainer[$varName])){
           return false;
       }
       return $this->_sessContainer[$varName];
   }   

   /**
    * 銷毀一個已注冊的Session變量
    *
    * @param string $varName - 需要銷毀的Session變量名
    * @return bool 銷毀成功返回true
    */
   public function delete($varName){
       unset($this->_sessContainer[$varName]);
       $this->_saveSession();
       return true;
   }

   /**
    * 銷毀所有已經(jīng)注冊的Session變量
    *
    * @return 銷毀成功返回true
    */
   public function destroy(){
       $this->_sessContainer = array();
       $this->_saveSession();
       return true;   
   }

 
   /**
    * 獲取所有Session變量
    *
    * @return array - 返回所有已注冊的Session變量值
    */
   public function getAll(){
       return $this->_sessContainer;
   }

   /**
    * 獲取當(dāng)前的Session ID
    *
    * @return string 獲取的SessionID
    */
   public function getSid(){
       return $this->_sessId;
   }

   /**
    * 獲取Memcache的服務(wù)器信息
    *
    * @return array Memcache配置數(shù)組信息
    */
   public function getMemServers(){
       return $this->_memServers;
   }

   /**
    * 設(shè)置Memcache的服務(wù)器信息
    *
    * @param string $host - Memcache服務(wù)器的IP
    * @param int $port - Memcache服務(wù)器的端口
    */
   public function setMemServers($arr){
       $this->_memServers = $arr;
   }   

   /**
    * 添加Memcache服務(wù)器
    *
    * @param string $host - Memcache服務(wù)器的IP
    * @param int $port - Memcache服務(wù)器的端口
    */
   public function addMemServer($host, $port){
       $this->_memServers[trim($host)] = trim($port);
       $this->memObject->addServer($host, $port);
   }  

   /**
    * 移除Memcache服務(wù)器(注意，這個只是移除配置，并不能實(shí)際從memcached的連接池移除)
    *
    * @param string $host - Memcache服務(wù)器的IP
    * @param int $port - Memcache服務(wù)器的端口
    */
   public function removeMemServer($host){
  unset($this->_memServers[trim($host)]);
   }  

   /**
  *=-----------------------------------------------------------------------=
  *=-----------------------------------------------------------------------=
 *      Private Methods
  *=-----------------------------------------------------------------------=
  *=-----------------------------------------------------------------------=
  */

   /**
    * 生成一個Session ID
    *
    * @return string 返回一個32位的Session ID
    */
   private function _getId(){
       return md5(uniqid(microtime()));
   }

   /**
    * 獲取一個保存在Memcache的Session Key
    *
    * @param string $_sessId - 是否指定Session ID
    * @return string 獲取到的Session Key
    */
   private function _getSessKey($_sessId = ''){
       $sessKey = ($_sessId == '') ? $this->_sessKeyPrefix.$this->_sessId : $this->_sessKeyPrefix.$_sessId;
       return $sessKey;
   }   
   /**
    * 檢查保存Session數(shù)據(jù)的路徑是否存在
    *
    * @return bool 成功返回true
    */
   private function _initMemcacheObj(){
       if (!class_exists('Memcache') || !function_exists('memcache_connect')){
           $this->_showMessage('Failed: Memcache extension not install, please from http://pecl.php.net download and install');
       }       
       if ($this->memObject && is_object($this->memObject)){
           return true;
       }
       $this->memObject = new Memcache;
       if (!empty($this->_memServers)) {
          foreach ($this->_memServers as $_host => $_port) {
            $this->memObject->addServer($_host, $_port);
        }
       }

       return true;
   }

   /**
    * 獲取Session文件中的數(shù)據(jù)
    *
    * @param string $_sessId - 需要獲取Session數(shù)據(jù)的SessionId
    * @return unknown
    */
   private function _getSession($_sessId = ''){
       $this->_initMemcacheObj();
       $sessKey = $this->_getSessKey($_sessId);
       $sessData = $this->memObject->get($sessKey);
       if (!is_array($sessData) || empty($sessData)){
         //this must be $_COOKIE['__SessHandler'] error!
         return array();
       }
       return $sessData;
   }

   /**
    * 把當(dāng)前的Session數(shù)據(jù)保存到Memcache
    *
    * @param string $_sessId - Session ID
    * @return 成功返回true
    */
   private function _saveSession($_sessId = ''){
       $this->_initMemcacheObj();
       $sessKey = $this->_getSessKey($_sessId);

       if (empty($this->_sessContainer)){
           $ret = @$this->memObject->set($sessKey, $this->_sessContainer, false, $this->_sessExpireTime);
       }else{
           $ret = @$this->memObject->replace($sessKey, $this->_sessContainer, false, $this->_sessExpireTime);
       }

       if (!$ret){
           $this->_showMessage('Failed: Save sessiont data failed, please check memcache server');
       }
       return true;
   }

   /**
    * 顯示提示信息
    *
    * @param string $strMessage - 需要顯示的信息內(nèi)容
    * @param bool $isFailed - 是否是失敗信息, 缺省是true
    */
   private function _showMessage($strMessage, $isFailed = true){
     return;
       if ($isFailed){
           echo ($strMessage);
       }
       echo $strMessage;
   }   

四應(yīng)用
1.本地session存儲，與原始session操作方式一樣，沒有任何改變。如：

復(fù)制代碼 代碼如下:

session_start();
$_SESSION['file_session_info']= '本地文件保存的session信息'; //本地文件保存的session

2.memcache共享服務(wù)器的session存儲

復(fù)制代碼 代碼如下:

$mem= MemcacheSession::getInstance('192.168.0.4', 11211);
$mem->addMemServer('192.168.0.4',11211);
$mem->addMemServer('192.168.0.5',11211);
//如果cookie功能不可用，則根據(jù)其他參數(shù)傳遞的唯一信息，設(shè)置映射為session_id
if(1) {
$sn= '838ece1033bf7c7468e873e79ba2a3ec';
$mem->setSessId($sn);
}
$mem->set('name','guigui');  //多臺memcache服務(wù)器共享的session
$mem->set('addr','wuhan');  //多臺memcache服務(wù)器共享的session
//$mem->destroy();

3.分別獲取本地和memcache存儲的session信息

復(fù)制代碼 代碼如下:

$addr= $mem->get('addr');
$_MEM_SESSION= $mem->getAll();
echo"<hr>localhost file session:";
var_dump($_SESSION);
echo"<hr>memcache session:";
var_dump($_MEM_SESSION);
//$res= $mem->delete('name');

“Memcache的Session數(shù)據(jù)的多服務(wù)器共享方式”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！