1. 程式人生 > >ThinkPHP分散式環境搭建

ThinkPHP分散式環境搭建

普通的Web開發,常用的模式就是使用者登入之後,登入狀態資訊儲存在Session中,使用者一些常用的熱資料儲存在檔案快取中,使用者上傳的附件資訊儲存在Web伺服器的某個目錄上。這種方式對於一般的Web應用,使用很方便,完全能夠勝任。但是對於高併發的企業級網站,就應付不了了。需要採用Web叢集實現負載均衡。

  使用Web叢集方式部署之後,首要調整的就是使用者狀態資訊與附件資訊。使用者狀態不能再儲存到Session中,快取也不能用本地Web伺服器的檔案快取,以及附件,也不能儲存在Web伺服器上了。因為要保證叢集裡面的各個Web伺服器,狀態完全一致。因此,需要將使用者狀態、快取等儲存到專用的快取伺服器,比如Memcache。附件需要儲存到雲端儲存中,比如七牛雲端儲存、阿里雲端儲存、騰訊雲端儲存等。

  本文以ThinkPHP開發框架為例,說明如何設定,能夠將Session、快取等儲存到Memcache快取伺服器上。

 

  下載快取的Memcache處理類,放到Thinkphp\Extend\Driver\Cache目錄中;下載Session的Memcache處理類,放到Thinkphp\Extend\Driver\Session目錄中,如下圖所示:

 

 

  修改配置檔案,調整Session與快取,都記錄到Memcache伺服器上。開啟ThinkPHP\Conf\convention.PHP,增加配置項:

 

[php] view plain copy

  1. /* Memcache快取設定 */  
  2. 'MEMCACHE_HOST'         => '192.168.202.20',  
  3. 'MEMCACHE_PORT'         => 11211,  

 

  修改資料快取為Memcache:

 

[php] view plain copy

  1. 'DATA_CACHE_TYPE'       => 'Memcache',  

  修改Session為Memcache:

 

 

[php] view plain copy

  1. 'SESSION_TYPE'          => 'Memcache',  

 

  如下圖所示:

 

  因為雲端儲存各類比較多,附件儲存到雲端儲存上,就不再贅述,引數各雲端儲存提供的sdk即可。經過以上修改,就可以將Web伺服器進行分散式部署了。

 

  附件1:CacheMemcache.class.php

[php] view plain copy

  1. <?php  
  2. // +----------------------------------------------------------------------  
  3. // | ThinkPHP [ WE CAN DO IT JUST THINK IT ]  
  4. // +----------------------------------------------------------------------  
  5. // | Copyright (c) 2006-2012 http://thinkphp.cn All rights reserved.  
  6. // +----------------------------------------------------------------------  
  7. // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )  
  8. // +----------------------------------------------------------------------  
  9. // | Author: liu21st <[email protected]>  
  10. // +----------------------------------------------------------------------  
  11.   
  12. defined('THINK_PATH') or exit();  
  13. /** 
  14.  * Memcache快取驅動 
  15.  * @category   Extend 
  16.  * @package  Extend 
  17.  * @subpackage  Driver.Cache 
  18.  * @author    liu21st <[email protected]
  19.  */  
  20. class CacheMemcache extends Cache {  
  21.   
  22.     /** 
  23.      * 架構函式 
  24.      * @param array $options 快取引數 
  25.      * @access public 
  26.      */  
  27.     function __construct($options=array()) {  
  28.         if ( !extension_loaded('memcache') ) {  
  29.             throw_exception(L('_NOT_SUPPERT_').':memcache');  
  30.         }  
  31.   
  32.         $options = array_merge(array (  
  33.             'host'        =>  C('MEMCACHE_HOST') ? C('MEMCACHE_HOST') : '127.0.0.1',  
  34.             'port'        =>  C('MEMCACHE_PORT') ? C('MEMCACHE_PORT') : 11211,  
  35.             'timeout'     =>  C('DATA_CACHE_TIMEOUT') ? C('DATA_CACHE_TIMEOUT') : false,  
  36.             'persistent'  =>  false,  
  37.         ),$options);  
  38.   
  39.         $this->options      =   $options;  
  40.         $this->options['expire'] =  isset($options['expire'])?  $options['expire']  :   C('DATA_CACHE_TIME');  
  41.         $this->options['prefix'] =  isset($options['prefix'])?  $options['prefix']  :   C('DATA_CACHE_PREFIX');          
  42.         $this->options['length'] =  isset($options['length'])?  $options['length']  :   0;          
  43.         $func               =   $options['persistent'] ? 'pconnect' : 'connect';  
  44.         $this->handler      =   new Memcache;  
  45.         $options['timeout'] === false ?  
  46.             $this->handler->$func($options['host'], $options['port']) :  
  47.             $this->handler->$func($options['host'], $options['port'], $options['timeout']);  
  48.     }  
  49.   
  50.     /** 
  51.      * 讀取快取 
  52.      * @access public 
  53.      * @param string $name 快取變數名 
  54.      * @return mixed 
  55.      */  
  56.     public function get($name) {  
  57.         N('cache_read',1);  
  58.         return $this->handler->get($this->options['prefix'].$name);  
  59.     }  
  60.   
  61.     /** 
  62.      * 寫入快取 
  63.      * @access public 
  64.      * @param string $name 快取變數名 
  65.      * @param mixed $value  儲存資料 
  66.      * @param integer $expire  有效時間(秒) 
  67.      * @return boolen 
  68.      */  
  69.     public function set($name, $value, $expire = null) {  
  70.         N('cache_write',1);  
  71.         if(is_null($expire)) {  
  72.             $expire  =  $this->options['expire'];  
  73.         }  
  74.         $name   =   $this->options['prefix'].$name;  
  75.         if($this->handler->set($name, $value, 0, $expire)) {  
  76.             if($this->options['length']>0) {  
  77.                 // 記錄快取佇列  
  78.                 $this->queue($name);  
  79.             }  
  80.             return true;  
  81.         }  
  82.         return false;  
  83.     }  
  84.   
  85.     /** 
  86.      * 刪除快取 
  87.      * @access public 
  88.      * @param string $name 快取變數名 
  89.      * @return boolen 
  90.      */  
  91.     public function rm($name, $ttl = false) {  
  92.         $name   =   $this->options['prefix'].$name;  
  93.         return $ttl === false ?  
  94.             $this->handler->delete($name) :  
  95.             $this->handler->delete($name, $ttl);  
  96.     }  
  97.   
  98.     /** 
  99.      * 清除快取 
  100.      * @access public 
  101.      * @return boolen 
  102.      */  
  103.     public function clear() {  
  104.         return $this->handler->flush();  
  105.     }  
  106. }  

 

  附件2:SessionMemcache.class.php

 

[php] view plain copy

  1. <?php   
  2. // +----------------------------------------------------------------------  
  3. // |   
  4. // +----------------------------------------------------------------------  
  5. // | Copyright (c) 2013-   
  6. // +----------------------------------------------------------------------  
  7. // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )  
  8. // +----------------------------------------------------------------------  
  9. // | Author: richievoe <[email protected]>  
  10. // +----------------------------------------------------------------------  
  11.     /** 
  12.      * 自定義Memcache來儲存session 
  13.      */  
  14. Class SessionMemcache{  
  15.     //memcache物件  
  16.     private $mem;  
  17.     //SESSION有效時間  
  18.     private $expire;  
  19.     //外部呼叫的函式  
  20.     public function execute(){  
  21.         session_set_save_handler(  
  22.             array(&$this,'open'),   
  23.             array(&$this,'close'),   
  24.             array(&$this,'read'),   
  25.             array(&$this,'write'),   
  26.             array(&$this,'destroy'),   
  27.             array(&$this,'gc')  
  28.             );  
  29.     }  
  30.     //連線memcached和初始化一些資料  
  31.     public function open($path,$name){  
  32.         $this->expire = C('SESSION_EXPIRE') ? C('SESSION_EXPIRE') :ini_get('session.gc_maxlifetime');  
  33.         $this->mem = new Memcache;  
  34.         return $this->mem->connect(C('MEMCACHE_HOST'), C('MEMCACHE_PORT'));  
  35.     }  
  36.     //關閉memcache伺服器  
  37.     public function close(){  
  38.         return $this->mem->close();  
  39.     }  
  40.     //讀取資料  
  41.     public function read($id){  
  42.         $id = C('SESSION_PREFIX').$id;  
  43.         $data = $this->mem->get($id);  
  44.         return $data ? $data :'';  
  45.     }  
  46.     //存入資料  
  47.     public function write($id,$data){  
  48.         $id = C('SESSION_PREFIX').$id;  
  49.         //$data = addslashes($data);  
  50.         return $this->mem->set($id,$data,0,$this->expire);  
  51.     }  
  52.     //銷燬資料  
  53.     public function destroy($id){  
  54.         $id = C('SESSION_PREFIX').$id;  
  55.         return $this->mem->delete($id);  
  56.     }  
  57.     //垃圾銷燬  
  58.     public function gc(){  
  59.         return true;  
  60.     }  
  61. }