cari

Rumah >pembangunan bahagian belakang >tutorial php >ThinkPHP项目实现分布式部署实例详解

ThinkPHP项目实现分布式部署实例详解

小云云
小云云asal
2018-01-25 14:18:097441semak imbas

　　普通的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，增加配置项：

    /* Memcache缓存设置 */
    'MEMCACHE_HOST'         => '192.168.202.20',
    'MEMCACHE_PORT'         => 11211,

　　修改数据缓存为Memcache：

    'DATA_CACHE_TYPE'       => 'Memcache',

　　修改Session为Memcache：

    'SESSION_TYPE'          => 'Memcache',

　　如下图所示：


　　因为云存储各类比较多，附件存储到云存储上，就不再赘述，参数各云存储提供的sdk即可。经过以上修改，就可以将Web服务器进行分布式部署了。

　　附件1：CacheMemcache.class.php

<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006-2012 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------

defined(&#39;THINK_PATH&#39;) or exit();
/**
 * Memcache缓存驱动
 * @category   Extend
 * @package  Extend
 * @subpackage  Driver.Cache
 * @author    liu21st <liu21st@gmail.com>
 */
class CacheMemcache extends Cache {

    /**
     * 架构函数
     * @param array $options 缓存参数
     * @access public
     */
    function __construct($options=array()) {
        if ( !extension_loaded(&#39;memcache&#39;) ) {
            throw_exception(L(&#39;_NOT_SUPPERT_&#39;).&#39;:memcache&#39;);
        }

        $options = array_merge(array (
            &#39;host&#39;        =>  C(&#39;MEMCACHE_HOST&#39;) ? C(&#39;MEMCACHE_HOST&#39;) : &#39;127.0.0.1&#39;,
            &#39;port&#39;        =>  C(&#39;MEMCACHE_PORT&#39;) ? C(&#39;MEMCACHE_PORT&#39;) : 11211,
            &#39;timeout&#39;     =>  C(&#39;DATA_CACHE_TIMEOUT&#39;) ? C(&#39;DATA_CACHE_TIMEOUT&#39;) : false,
            &#39;persistent&#39;  =>  false,
        ),$options);

        $this->options      =   $options;
        $this->options[&#39;expire&#39;] =  isset($options[&#39;expire&#39;])?  $options[&#39;expire&#39;]  :   C(&#39;DATA_CACHE_TIME&#39;);
        $this->options[&#39;prefix&#39;] =  isset($options[&#39;prefix&#39;])?  $options[&#39;prefix&#39;]  :   C(&#39;DATA_CACHE_PREFIX&#39;);        
        $this->options[&#39;length&#39;] =  isset($options[&#39;length&#39;])?  $options[&#39;length&#39;]  :   0;        
        $func               =   $options[&#39;persistent&#39;] ? &#39;pconnect&#39; : &#39;connect&#39;;
        $this->handler      =   new Memcache;
        $options[&#39;timeout&#39;] === false ?
            $this->handler->$func($options[&#39;host&#39;], $options[&#39;port&#39;]) :
            $this->handler->$func($options[&#39;host&#39;], $options[&#39;port&#39;], $options[&#39;timeout&#39;]);
    }

    /**
     * 读取缓存
     * @access public
     * @param string $name 缓存变量名
     * @return mixed
     */
    public function get($name) {
        N(&#39;cache_read&#39;,1);
        return $this->handler->get($this->options[&#39;prefix&#39;].$name);
    }

    /**
     * 写入缓存
     * @access public
     * @param string $name 缓存变量名
     * @param mixed $value  存储数据
     * @param integer $expire  有效时间（秒）
     * @return boolen
     */
    public function set($name, $value, $expire = null) {
        N(&#39;cache_write&#39;,1);
        if(is_null($expire)) {
            $expire  =  $this->options[&#39;expire&#39;];
        }
        $name   =   $this->options[&#39;prefix&#39;].$name;
        if($this->handler->set($name, $value, 0, $expire)) {
            if($this->options[&#39;length&#39;]>0) {
                // 记录缓存队列
                $this->queue($name);
            }
            return true;
        }
        return false;
    }

    /**
     * 删除缓存
     * @access public
     * @param string $name 缓存变量名
     * @return boolen
     */
    public function rm($name, $ttl = false) {
        $name   =   $this->options[&#39;prefix&#39;].$name;
        return $ttl === false ?
            $this->handler->delete($name) :
            $this->handler->delete($name, $ttl);
    }

    /**
     * 清除缓存
     * @access public
     * @return boolen
     */
    public function clear() {
        return $this->handler->flush();
    }
}

　　附件2：SessionMemcache.class.php

<?php 
// +----------------------------------------------------------------------
// | 
// +----------------------------------------------------------------------
// | Copyright (c) 2013- 
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: richievoe <richievoe@163.com>
// +----------------------------------------------------------------------
    /**
     * 自定义Memcache来保存session
     */
Class SessionMemcache{
    //memcache对象
    private $mem;
    //SESSION有效时间
    private $expire;
    //外部调用的函数
    public function execute(){
        session_set_save_handler(
            array(&$this,&#39;open&#39;), 
            array(&$this,&#39;close&#39;), 
            array(&$this,&#39;read&#39;), 
            array(&$this,&#39;write&#39;), 
            array(&$this,&#39;destroy&#39;), 
            array(&$this,&#39;gc&#39;)
            );
    }
    //连接memcached和初始化一些数据
    public function open($path,$name){
        $this->expire = C(&#39;SESSION_EXPIRE&#39;) ? C(&#39;SESSION_EXPIRE&#39;) :ini_get(&#39;session.gc_maxlifetime&#39;);
        $this->mem = new Memcache;
        return $this->mem->connect(C(&#39;MEMCACHE_HOST&#39;), C(&#39;MEMCACHE_PORT&#39;));
    }
    //关闭memcache服务器
    public function close(){
        return $this->mem->close();
    }
    //读取数据
    public function read($id){
        $id = C(&#39;SESSION_PREFIX&#39;).$id;
        $data = $this->mem->get($id);
        return $data ? $data :&#39;&#39;;
    }
    //存入数据
    public function write($id,$data){
        $id = C(&#39;SESSION_PREFIX&#39;).$id;
        //$data = addslashes($data);
        return $this->mem->set($id,$data,0,$this->expire);
    }
    //销毁数据
    public function destroy($id){
        $id = C(&#39;SESSION_PREFIX&#39;).$id;
        return $this->mem->delete($id);
    }
    //垃圾销毁
    public function gc(){
        return true;
    }
}
?>

经过以上配置，就可以将用户状态信息与缓存信息保存到Memcache中。可以使用负载均衡服务器，来实现大规模集群方式架设网站。

相关推荐：

详谈php分布式部署

MongoDB单机, 主从, 分布式部署

PHP扩展Memcache分布式部署方案_PHP

Atas ialah kandungan terperinci ThinkPHP项目实现分布式部署实例详解. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

php 分布式 thinkphp Session class 并发 mongodb memcache 负载均衡
Kenyataan：
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Artikel sebelumnya：详谈php分布式部署Artikel seterusnya：浏览器缓存机制详细介绍

Artikel berkaitan

Lihat lagi