Redis协程连接池

参考Demo: Pool连接池

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

添加数据库配置

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

/*################ REDIS CONFIG ##################*/
'REDIS' => [
    'host'          => '127.0.0.1',
    'port'          => '6379',
    'auth'          => '',
    'POOL_MAX_NUM'  => '20',
    'POOL_MIN_NUM'  => '5',
    'POOL_TIME_OUT' => '0.1',
],

在EasySwooleEvent初始化事件initialize注册该连接池

// 注册redis连接池

PoolManager::getInstance()->register(RedisPool::class, Config::getInstance()->getConf('REDIS.POOL_MAX_NUM'));

注意

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

使用

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

$redis = PoolManager::getInstance()->getPool(RedisPool::class)->getObj(Config::getInstance()->getConf('REDIS.POOL_TIME_OUT'));
$redis->set('name', 'blank');
$name = $redis->get('name');
var_dump($name);
/*
 * string(5) "blank"
 */

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

PoolManager::getInstance()->getPool(RedisPool::class)->recycleObj($redis);

可通过invoke静态方法直接从连接池取出一个连接,直接使用,回调函数结束后自动回收:

<?php
try {
    $result = RedisPool::invoke(function(RedisObject $redis) {
            $name = $redis->get('name');
            return $name;
        });
    $this->writeJson(Status::CODE_OK, $result);
} catch (\Throwable $throwable) {
    $this->writeJson(Status::CODE_BAD_REQUEST, null, $throwable->getMessage());
}

预创建链接

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

//注册onWorkerStart回调事件
public static function mainServerCreate(EventRegister $register)
{
    $register->add($register::onWorkerStart, function (\swoole_server $server, int $workerId) {
    if ($server->taskworker == false) {
        PoolManager::getInstance()->getPool(RedisPool::class)->preLoad(1);
        //PoolManager::getInstance()->getPool(RedisPool::class)->preLoad(预创建数量,必须小于连接池最大数量);
    }

    // var_dump('worker:' . $workerId . 'start');
    });
}

results matching ""

    No results matching ""