Redis 缓存

目前支持文件缓存、redis 缓存，实现代码如下:

  2. namespace FastD\Pool;
  4. use Symfony\Component\Cache\Adapter\AbstractAdapter;
  5. use Symfony\Component\Cache\Adapter\RedisAdapter;
  7. /**
  8.  * Class CachePool.
  9.  */
  10. class CachePool implements PoolInterface
  11. {
  12.     /**
  13.      * @var AbstractAdapter[]
  14.      */
  15.     protected $caches = [];
  17.     /**
  18.      * @var array
  19.      */
  20.     protected $config;
  22.     /**
  23.      * Cache constructor.
  24.      *
  25.      * @param array $config
  26.      */
  27.     public function __construct(array $config)
  28.     {
  29.         $this->config = $config;
  30.     }
  32.     /**
  33.      * @param $key
  34.      *
  35.      * @return AbstractAdapter
  36.      */
  37.     public function getCache($key)
  38.     {
  39.         if (!isset($this->caches[$key])) {
  40.             if (!isset($this->config[$key])) {
  41.                 throw new \LogicException(sprintf('No set %s cache', $key));
  42.             }
  43.             $config = $this->config[$key];
  44.             switch ($config['adapter']) {
  45.                 case RedisAdapter::class:
  46.                     $this->caches[$key] = new RedisAdapter(
  47.                         RedisAdapter::createConnection($config['params']['dsn']),
  48.                         isset($config['params']['namespace']) ? $config['params']['namespace'] : '',
  49.                         isset($config['params']['lifetime']) ? $config['params']['lifetime'] : ''
  50.                     );
  52.                     break;
  53.                 default:
  54.                     $this->caches[$key] = new $config['adapter'](
  55.                         isset($config['params']['namespace']) ? $config['params']['namespace'] : '',
  56.                         isset($config['params']['lifetime']) ? $config['params']['lifetime'] : '',
  57.                         isset($config['params']['directory']) ? $config['params']['directory'] : app()->getPath().'/runtime/cache'
  58.                     );
  59.             }
  60.         }
  62.         return $this->caches[$key];
  63.     }
  65.     /**
  66.      * {@inheritdoc}
  67.      */
  68.     public function initPool()
  69.     {
  70.         foreach ($this->config as $name => $config) {
  71.             $this->getCache($name);
  72.         }
  73.     }
  74. }

使用 Redis 配置

缓存此处使用 dsn 形式进行配置，因此写法需要按照规范进行填写，如: redis://user:pass@host:port/db

  1. <?php
  3. return [
  4.     'default' => [
  5.         'adapter' => \Symfony\Component\Cache\Adapter\RedisAdapter::class,
  6.         'params' => [
  7.             'dsn' => 'redis://localhost:3306/db',
  8.         ],
  9.     ],
  10. ];

通过配置完以上配置，框架会自动切换到 redis 驱动中进行数据缓存。无论是文件缓存或者其他不一样驱动的缓存，写法上保持一致。