Redis-Pool

Redis-Pool 基于 pool通用连接池,redis协程客户端封装的组件

安装

  1. composer require easyswoole/redis-pool

连接池注册

使用连接之前注册redis连接池:

  1. //redis连接池注册(config默认为127.0.0.1,端口6379)
  2. \EasySwoole\RedisPool\Redis::getInstance()->register('redis',new \EasySwoole\Redis\Config\RedisConfig());
  4. //redis集群连接池注册
  5. \EasySwoole\RedisPool\Redis::getInstance()->register('redisCluster',new \EasySwoole\Redis\Config\RedisClusterConfig([
  6.         ['172.16.253.156', 9001],
  7.         ['172.16.253.156', 9002],
  8.         ['172.16.253.156', 9003],
  9.         ['172.16.253.156', 9004],
  10.     ]
  11. ));

连接池配置

当注册好时,将返回连接池的poolConf用于配置连接池:

  1. $redisPoolConfig = \EasySwoole\RedisPool\Redis::getInstance()->register('redis',new \EasySwoole\Redis\Config\RedisConfig());
  2. //配置连接池连接数
  3. $redisPoolConfig->setMinObjectNum(5);
  4. $redisPoolConfig->setMaxObjectNum(20);
  6. $redisClusterPoolConfig = \EasySwoole\RedisPool\Redis::getInstance()->register('redisCluster',new \EasySwoole\Redis\Config\RedisClusterConfig([
  7.         ['172.16.253.156', 9001],
  8.         ['172.16.253.156', 9002],
  9.         ['172.16.253.156', 9003],
  10.         ['172.16.253.156', 9004],
  11.     ]
  12. ));
  13. //配置连接池连接数
  14. $redisPoolConfig->setMinObjectNum(5);
  15. $redisPoolConfig->setMaxObjectNum(20);

使用连接池:

  1. //redis连接池注册(config默认为127.0.0.1,端口6379)
  2. \EasySwoole\RedisPool\Redis::getInstance()->register('redis',new \EasySwoole\Redis\Config\RedisConfig());
  4. //redis集群连接池注册
  5. \EasySwoole\RedisPool\Redis::getInstance()->register('redisCluster',new \EasySwoole\Redis\Config\RedisClusterConfig([
  6.         ['172.16.253.156', 9001],
  7.         ['172.16.253.156', 9002],
  8.         ['172.16.253.156', 9003],
  9.         ['172.16.253.156', 9004],
  10.     ]
  11. ));
  12. go(function () {
  13.     //defer方式获取连接
  14.     $redis = \EasySwoole\RedisPool\Redis::defer('redis');
  15.     $redisCluster = \EasySwoole\RedisPool\Redis::defer('redisCluster');
  16.     $redis->set('a', 1);
  17.     $redisCluster->set('a', 1);
  19.     //invoke方式获取连接
  20.     \EasySwoole\RedisPool\Redis::invoke('redis', function (\EasySwoole\Redis\Redis $redis) {
  21.         var_dump($redis->set('a', 1));
  22.     });
  23.     \EasySwoole\RedisPool\Redis::invoke('redisCluster', function (\EasySwoole\Redis\Redis $redis) {
  24.         var_dump($redis->set('a', 1));
  25.     });
  27.     //获取连接池对象
  28.     $redisPool = \EasySwoole\RedisPool\Redis::getInstance()->get('redis');
  29.     $redisClusterPool = \EasySwoole\RedisPool\Redis::getInstance()->get('redisCluster');
  31.     $redis = $redisPool->getObj();
  32.     $redisPool->recycleObj($redis);
  34. //清除pool中的定时器
  35.     \EasySwoole\Component\Timer::getInstance()->clearAll();
  36. });