php分布式部署

普通的Web开发，常用的模式就是用户登录之后，登录状态信息保存在Session中，用户一些常用的热数据保存在文件缓存中，用户上传的附件信息保存在Web服务器的某个目录上。这种方式对于一般的Web应用，使用很方便，完全能够胜任。但是对于高并发的企业级网站，就应付不了了。需要采用Web集群实现负载均衡。

　　使用Web集群方式部署之后，首要调整的就是用户状态信息与附件信息。用户状态不能再保存到Session中，缓存也不能用本地Web服务器的文件缓存，以及附件，也不能保存在Web服务器上了。因为要保证集群里面的各个Web服务器，状态完全一致。因此，需要将用户状态、缓存等保存到专用的缓存服务器，比如Memcache。附件需要保存到云存储中，比如七牛云存储、阿里云存储、腾讯云存储等。

　　本文以ThinkPHP开发框架为例，说明如何设置，能够将Session、缓存等保存到Memcache缓存服务器上。

 

　　下载缓存的Memcache处理类，放到ThinkphpExtendDriverCache目录中；下载Session的Memcache处理类，放到ThinkphpExtendDriverSession目录中，如下图所示：

　　修改配置文件，调整Session与缓存，都记录到Memcache服务器上。打开ThinkPHPConfconvention.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 <liu21st@gmail.com>  
10. // +----------------------------------------------------------------------  
11.   
12. defined("THINK_PATH") or exit();  
13. /** 
14.  * Memcache缓存驱动 
15.  * @category   Extend 
16.  * @package  Extend 
17.  * @subpackage  Driver.Cache 
18.  * @author    liu21st <liu21st@gmail.com> 
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 <richievoe@163.com>  
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. }  
62. ?>