Redis协程连接池

参考Demo: Pool连接池

demo中有封装好的redis连接池以及redis类，复制demo中的RedisPool.php和RedisObject.php并放入App/Utility/Pool中即可使用

添加数据库配置

在dev.php,produce.php中添加配置信息：

  1. /*################ REDIS CONFIG ##################*/
  2. 'REDIS' => [
  3.     'host'          => '127.0.0.1',
  4.     'port'          => '6379',
  5.     'auth'          => '',
  6.     'POOL_MAX_NUM'  => '20',
  7.     'POOL_MIN_NUM'  => '5',
  8.     'POOL_TIME_OUT' => '0.1',
  9. ],

在EasySwooleEvent.php的initialize方法中注册连接池对象(注意命名空间,新版本可以无需注册,自动注册)

  1. <?php
  2.         $redisConf2 = PoolManager::getInstance()->register(RedisPool::class, Config::getInstance()->getConf('REDIS.POOL_MAX_NUM'));
  3.         //注册之后会返回conf配置,可继续配置,如果返回null代表注册失败

可通过register返回的PoolConf对象去配置其他参数

注意

连接池不是跨进程的，进程间的连接池连接数是相互独立的，默认最大值是10个；如果开了4个worker，最大连接数可以达到40个。

基础使用

通过redis连接池获取redis操作对象

  1. <?php
  3. function index()
  4. {
  5.     $redis = PoolManager::getInstance()->getPool(RedisPool::class)->getObj();
  7.     $redis->set('key', '仙士可');
  8.     $data = $redis->get('key');
  9.     PoolManager::getInstance()->getPool(RedisPool::class)->recycleObj($redis);
  10.     $this->response()->write($data);
  11. }

用完redis连接池对象之后记得用recycleObj回收

直接getobj时,可能会出现没有连接(返回null)的情况,需要增加判断

用完redis连接池对象之后记得用recycleObj回收(新版本可使用invoker.defer方法自动回收)

  1. <?php
  2. PoolManager::getInstance()->getPool(RedisPool::class)->recycleObj($redis);

自动回收

  • invoke
    可通过invoke静态方法直接从连接池取出一个连接,直接使用,回调函数结束后自动回收:
    1. <?php
    2. try {
    3.   $result = RedisPool::invoke(function(RedisObject $redis) {
    4.           $name = $redis->get('name');
    5.           return $name;
    6.       });
    7.   $this->writeJson(Status::CODE_OK, $result);
    8. } catch (\Throwable $throwable) {
    9.   $this->writeJson(Status::CODE_BAD_REQUEST, null, $throwable->getMessage());
    10. }
  • defer
    使用defer方法直接获取一个连接池连接,直接使用,协程结束后自动回收:
    1. $redis = RedisPool::defer();
    2. $name = $redis->get('name');

    异常拦截,当invoke调用,内部发生(连接不够,连接对象错误)等异常情况时,会抛出PoolEmpty和PoolException,可在控制器基类拦截或直接忽略,EasySwoole内部有做异常拦截处理,将直接拦截并返回错误到前端.只要使用以上两个方法,就无需关注连接回收问题,将自动回收

预创建链接

新增preload方法,可在程序启动后预创建连接,避免在启动时突然大量请求,造成连接来不及创建从而失败的问题.
示例:
在EasySwooleEvent文件,mainServerCreate事件中增加onWorkerStart回调事件中预热启动:

  1. <?php
  2. //注册onWorkerStart回调事件
  3. public static function mainServerCreate(EventRegister $register)
  4. {
  5.     $register->add($register::onWorkerStart, function (\swoole_server $server, int $workerId) {
  6.     if ($server->taskworker == false) {
  7.         PoolManager::getInstance()->getPool(RedisPool::class)->preLoad(1);
  8.         //PoolManager::getInstance()->getPool(RedisPool::class)->preLoad(预创建数量,必须小于连接池最大数量);
  9.     }
  11.     // var_dump('worker:' . $workerId . 'start');
  12.     });
  13. }