php swoole实现简单redis连接池

<?php declare(strict_types=1);

Co\run(function(){
    go(function(){
        redisPool::i();
        for ($c=1000;$c--;){
            $pool = RedisPool::i();
            $redis = $pool->get();
            defer(function() use($pool,$redis){
                $pool->put($redis);
            });
            $value = $redis->get('foo');
            if($value === false){
                throw new RuntimeException('get undefined');
            }

            assert($value,'bar');
        }
    });
});



class RedisPool
{
    protected $channel;
    protected static $instance;

    public static function i() : self
    {
        return !empty(static::$instance) ? static::$instance : (static::$instance = new static());
    }

    public function __construct(int $size=100)
    {
        $this->channel = new Swoole\Coroutine\Channel($size);
        while ($size --)
        {
            $redis = new Swoole\Coroutine\Redis();
            $res = $redis->connect('127.0.0.1',6379);
            if($res === true){
                $this->put($redis);
            }else{
                throw new RuntimeException('cannot connect redis');
            }
        }
    }

    public function put(Swoole\Coroutine\Redis $redis) : void
    {
        $this->channel->push($redis);
    }

    public function get(float $timeout = -1) : ?Swoole\Coroutine\Redis
    {
        return $this->channel->pop($timeout) ? : null;
    }

    public function close()
    {
        return $this->channel->close();
    }
}

注意点：

/etc/php.ini 配置 swoole.use_shortname = On 开启swoole go 函数的短函数的使用