上一篇博客中使用文件实现了缓存组件，这一篇我们就使用Redis来实现一下，剩下的如何使用memcache、mysql等去实现缓存我就不一一去做了。

首先我们需要安装一下 redis 和 phpredis 库，phpredis 项目在github上的地址：https://github.com/phpredis/phpredis 。相应的文档也在上面。

先在 src/cache 文件夹下创建 RedisCache.php 文件。在写组件的时候发现我们缺少一个地方去创建一个 Redis 的实例，并且是在创建 cahce 实例之后，返回给Yii::createObject 方法之前。所以我们修改了 src/Sf.php 文件，其 createObject 方法的内容如下：

    public static function createObject($name){$config = require(SF_PATH . "/config/$name.php");// create instance$instance = new $config['class']();unset($config['class']);// add attributesforeach ($config as $key => $value) {$instance->$key = $value;}$instance->init();return $instance;}

对比之前的代码，不难发现其实只添加了一行 $instance->init(); ，这样我们就可以在 init 方法中去创建相应的 Redis 实例，并保存下来。但这样又会引入一个问题，所有使用 Yii::createObject 创建的实例都必须含有 init 方法（当然你也可以判断有没有这个方法）。那我们就来实现一个基础类 Component ，并规定所有使用 Yii::createObject 创建的实例都集成它，然后再在 Component 中加入 init 方法即可。

为什么选择这种做法，而不是使用判断 init 方法存不存在的方式去解决这个问题，主要是考虑到之后可能还需要对这些类做一些公共的事情，就提前抽出了 Component 类。

Component 类现在很简单，其内容如下：

<?php
namespace sf\base;/*** Component is the base class for most sf classes.* @author Harry Sun <sunguangjun@126.com>*/
class Component
{/*** Initializes the component.* This method is invoked at the end of the constructor after the object is initialized with the* given configuration.*/public function init(){}
}

之后再定义一下 Redis 缓存的配置如下：

<?php
return ['class' => 'sf\cache\RedisCache','redis' => ['host' => 'localhost','port' => 6379,'database' => 0,// 'password' =>'jun',// 'options' => [Redis::OPT_SERIALIZER, Redis::SERIALIZER_PHP],]
];

其中 password 和 options 是选填，其它是必填。

剩下的就是相关实现，就不一一细说了，代码如下：

<?php
namespace sf\cache;use Redis;
use Exception;
use sf\base\Component;/*** CacheInterface* @author Harry Sun <sunguangjun@126.com>*/
class RedisCache extends Component implements CacheInterface
{/*** @var Redis|array the Redis object or the config of redis*/public $redis;public function init(){if (is_array($this->redis)) {extract($this->redis);$redis = new Redis();$redis->connect($host, $port);if (!empty($password)) {$redis->auth($password);}$redis->select($database);if (!empty($options)) {call_user_func_array([$redis, 'setOption'], $options);}$this->redis = $redis;}if (!$this->redis instanceof Redis) {throw new Exception('Cache::redis must be either a Redis connection instance.');}}/*** Builds a normalized cache key from a given key.*/public function buildKey($key){if (!is_string($key)) {$key = json_encode($key);}return md5($key);}/*** Retrieves a value from cache with a specified key.*/public function get($key){$key = $this->buildKey($key);return $this->redis->get($key);}/*** Checks whether a specified key exists in the cache.*/public function exists($key){$key = $this->buildKey($key);return $this->redis->exists($key);}/*** Retrieves multiple values from cache with the specified keys.*/public function mget($keys){for ($index = 0; $index < count($keys); $index++) {$keys[$index] = $this->buildKey($keys[$index]);}return $this->redis->mGet($keys);}/*** Stores a value identified by a key into cache.*/public function set($key, $value, $duration = 0){$key = $this->buildKey($key);if ($duration !== 0) {$expire = (int) $duration * 1000;return $this->redis->set($key, $value, $expire);} else {return $this->redis->set($key, $value);}}/*** Stores multiple items in cache. Each item contains a value identified by a key.*/public function mset($items, $duration = 0){$failedKeys = [];foreach ($items as $key => $value) {if ($this->set($key, $value, $duration) === false) {$failedKeys[] = $key;}}return $failedKeys;}/*** Stores a value identified by a key into cache if the cache does not contain this key.*/public function add($key, $value, $duration = 0){if (!$this->exists($key)) {return $this->set($key, $value, $duration);} else {return false;}}/*** Stores multiple items in cache. Each item contains a value identified by a key.*/public function madd($items, $duration = 0){$failedKeys = [];foreach ($items as $key => $value) {if ($this->add($key, $value, $duration) === false) {$failedKeys[] = $key;}}return $failedKeys;}/*** Deletes a value with the specified key from cache*/public function delete($key){$key = $this->buildKey($key);return $this->redis->delete($key);}/*** Deletes all values from cache.*/public function flush(){return $this->redis->flushDb();}
}

访问 http://localhost/simple-framework/public/index.php?r=site/cache 路径，得到结果如下：

我就是测试一下缓存组件

这样我们完成了使用 Redis 的缓存组件。

好了，今天就先到这里。项目内容和博客内容也都会放到Github上，欢迎大家提建议。

code：https://github.com/CraryPrimitiveMan/simple-framework/tree/1.0

blog project：https://github.com/CraryPrimitiveMan/create-your-own-php-framework