title: Redis connection pool meta:

  • name: description content: easyswoole Redis connection pool component, implemented by universal connection pool and redis coroutine client package
  • name: keywords content: swoole|swoole extension|swoole framework|EasySwoole redis|redis connection pool|swoole redis|redis connection pool

Redis-Pool

Redis-Pool is based on [pool universal connection pool] (./Pool/introduction.md), [redis coroutine client] (./Redis/introduction.md) packaged components

Installation

  1. composer require easyswoole/redis-pool

Connection pool registration

Register the Redis connection pool before using the connection:

  1. //Redis connection pool registration (config defaults to 127.0.0.1, port 6379)
  2. \EasySwoole\RedisPool\Redis::getInstance()->register('redis',new \EasySwoole\Redis\Config\RedisConfig());
  4. //Redis cluster connection pool registration
  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. ));

Connection pool configuration

When registered, the poolConf that will return the connection pool is used to configure the connection pool:

  1. $redisPoolConfig = \EasySwoole\RedisPool\Redis::getInstance()->register('redis',new \EasySwoole\Redis\Config\RedisConfig());
  2. //Configure connection pool connections
  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. //Configure connection pool connections
  14. $redisPoolConfig->setMinObjectNum(5);
  15. $redisPoolConfig->setMaxObjectNum(20);

Use a connection pool:

  1. //Redis connection pool registration (config defaults to 127.0.0.1, port 6379)
  2. \EasySwoole\RedisPool\Redis::getInstance()->register('redis',new \EasySwoole\Redis\Config\RedisConfig());
  4. //Redis cluster connection pool registration
  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 mode to get the connection
  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 mode to get the connection
  20.     \EasySwoole\RedisPool\Redis::invoker('redis', function (\EasySwoole\Redis\Redis $redis) {
  21.         var_dump($redis->set('a', 1));
  22.     });
  23.     \EasySwoole\RedisPool\Redis::invoker('redisCluster', function (\EasySwoole\Redis\Redis $redis) {
  24.         var_dump($redis->set('a', 1));
  25.     });
  27.     //Get the connection pool object
  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.     //Clear the timer in the pool
  35.     \EasySwoole\Component\Timer::getInstance()->clearAll();
  36. });