Yii框架分布式缓存的实现方案

「爱情、让人受尽委屈。」 2022-08-07 01:45 150阅读 0赞

声明：本文阅读对象最好是对Yii和分布式缓存有一定了解的人群，否则理解和掌握上有一些困难，建议阅读之前做好以上两点基础准备。

YiiFramework简称Yii,读作易，代表简单(easy)、高效(efficient)、可扩展(extensible)，Yii将面向对象思想以及代码的重用性发挥到了极致，尤其是在缓存的支持上，Yii是最有效率的PHP框架之一。

Yii的缓存支持封装在框架核心的caching文件夹下面，如下图是Yii支持的缓存存储介质。

![Center][]

如果要做跨Session和请求的分布式缓存，可以选用CFileCache,如果要做跨WebServer的分布式缓存，就必须用CMemCache或CRedisCache缓存。

1.跨Session和请求分布式缓存处理方案(只有一台Web服务器、利用缓存依赖实现缓存实时更新)

Yii缓存支持需要在项目的主配置文件添加相应的配置支持。

'components'=>array(
    
              //设置缓存
             'cache'=>array(
                 'class'=>'CFileCache',
              ),
           ),

Yii中不管缓存介质是磁盘、数据库还是内存，赋值和取值都是统一的，这样的话，当我们有更换缓存介质的时候就可以改一下主配置文件，程序代码一点都不用动，这也是Yii将代码重用性发挥到极致的一个很好体现。

A.缓存的赋值：

Yii::app()->cache->set(key,value,过期时间,依赖条件);

下面举一个具体调用案例：

$products=['id'=>1,'name'=>'茅台酒'];
    
            Yii::app()->cache->set('product',
                           $products,
                           30,
                           newCGlobalStateCacheDependency('version')
            );

上面是一个常用的案例，我们将'product'作为key,$products数组当做value，过期时间为30秒（若永不过期此处填0），同时依赖全局缓存变量'version'这个值。

设置缓存依赖后，当'version'的值发生变化后，缓存过期，30秒后缓存过期，这两个条件有一个成立，缓存都过期。

B.缓存值的获取

Yii::app()->cache->get(key);

下面举一个具体调用案例：

跨Session和请求分布式缓存的实现方案Demo:

读取线程代码：

$products=Yii::app()->cache->get('product');
        //没有读取到缓存
        if($products===false)
        {
           $pro=Yii::app()->db;
           $products=$pro->createCommand("select*from{
          {product}}")->query();
    
           //设置缓存永不过期，同时依赖于全局变量'version'
           Yii::app()->cache->set('product',
                                  $products,
                                  0,
                                  newCGlobalStateCacheDependency('version')
            );
           echo "从数据库获取<br/>";
         }
         echo json_encode($products);

写线程代码：

$pro=Yii::app()->db;
    
        $command=$pro->createCommand("INSERTINTO{
          {product}}(`name`,`color`,`version`)VALUES('依赖','黑色',1)");
    
        $command->execute();
    
        //设置缓存依赖，让缓存过期
    
        $version=Yii::app()->getGlobalState('version');
    
        Yii::app()->setGlobalState('version',++$version);

上面的业务逻辑如下图：

![Center 1][]

读线程每次获取缓存的时候都会验证一下缓存依赖是否值发生变化，如果缓存依赖值变化了就获取不到缓存，获取不到缓存就会去数据库查询结果，查询到结果后，重新设置缓存；如果缓存依赖值没有发生变化，直接获取缓存，不再连接数据库并将值返回给浏览器，这样读线程完成了任务。

写线程直接操作数据库，将数据更新到数据库，然后他只需要更新Denp缓存依赖就可以返回浏览器了，当然，写线程也可以直接清除对应的缓存，这样写线程完成任务。

当你想更新缓存介质的时候，如Memcached做分布式缓存介质，前提是web服务器安装php的memcached扩展，在web程序内只需要在主配置文件中做如下修改：

'components'=>array(
           //设置缓存
           'cache'=>array(
              'class'=>'CMemCache',
              'servers'=>array(
                 array('host'=>'192.168.1.16','port'=>11211,'weight'=>60),
                 array('host'=>'192.168.1.16','port'=>11212,'weight'=>40),
               ),
            ),
        ),

2.跨Web服务器分布式缓存处理方案

跨Web服务器的分布式缓存就得借助于Memcached或Redis了，如下图：

![Center 2][]

浏览器将读/写请求交给反向代理Nginx或者F5硬件，再由Nginx将请求分发给各自的Web服务器，各自Web服务器共享缓存服务器。

上图是利用Cache Server来实现的分布式缓存实时更新，处理流程：

1号读线程开始请求缓存，请求不到，读取数据库，设置缓存，将查询结果返回给浏览器；2号读线程，请求缓存，请求到缓存，将结果返回给浏览器；写线程直接操作数据库，删除缓存，返回浏览器；1号读线程读不到缓存，读取数据库，设置缓存，将查询结果返回给浏览器。

读线程代码:

/**读线程
    *@return mixed
    */
    public function actionWide()
    {
        $products=$this->getCache();
        if(!$products)
        {
           $products=$this->getProducts();
           $this->setCache($products);
           echo "没有获取到缓存，从数据库读取数据。<br/>";
        }
        echo json_encode($products);
    }
    
    /**从缓存中读取数据
    *@return mixed
    */
    private function getCache()
    {
         return Yii::app()->cache->get('product');
    }
    
    /**从数据库读取数据
    *@return mixed
    */
    private function getProducts()
    {
         $pro=Yii::app()->db;
         $products=$pro->createCommand("select*from{
          {product}}")->query();
         $products=$products->readAll();
         return $products;
    }
    
    /**
    *更新缓存
    */
    private function setCache($products)
    {
        Yii::app()->cache->set('product',$products);
    }

写线程代码：

/**
    *模拟写操作
    */
    public function actionWrite()
    {
        $pro=Yii::app()->db;
        $command=$pro->createCommand("INSERTINTO{
          {product}}(`name`,`color`,`version`)VALUES('依赖','黑色',1)");
        $command->execute();
        $this->delCache('product');
        echo "写成功";
    }
    
    /**根据键值删除缓存
    *@param$key键值
    */
    private function delCache($key)
    {
        Yii::app()->cache->delete($key);
    }

如果你想用Redis或Memcached做缓存，最好用Linux做缓存服务器，连接Web服务器就不做限制了，但是有一点，如果你想用Redis做缓存，或者Web服务器安装php对Redis的扩展，或者去Yii官网下载Yii对Redis的支持扩展，否则Yii不是不能利用Redis做缓存的，也可以在这里下载，这是我下好的。

[RedisCache][]

下载解压放在extensions目录，在主配置文件里做如下修改:

'components'=>array(
        //设置缓存
        'cache'=>array(
            'class'=>'ext.redis.CRedisCache',
            'servers'=>array(
                array('host'=>'192.168.1.16','port'=>6379,),
             ),
         'keyPrefix'=>'',
        ),
    ),

最后补充一下，为什么加这个keyPrefix配置，因为，如果你想用telnet通过key获取memcached或者Redis中的缓存value，是获取不到的，因为Yii框架给key会加上默认前缀，如果你在这里配置了，Yii框架就不会再对key进行处理了，这样你就可以通过telnet获取到缓存数据了。

好了，就到这里了。

[Center]: /images/20220805/019b17ff4d4c46c2b3dea080ad487b2c.png
[Center 1]: /images/20220805/70f919cb363347e08f2c0fd2f0a80a78.png
[Center 2]: /images/20220805/c7349a997b83464baa066021b247d494.png
[RedisCache]: http://pan.baidu.com/s/1bnaYwmr