Connection Pool

4.x is outdated, please check the latest version 22.x

Latest version: pecl install openswoole-22.1.2

General coroutine based connection pool implmentated with Channel.

Connection pool is used to reduce the TCP reconnect overhead, can be used to increase the application performance.

You can use the build-in ConnectionPool to manage a pool of connection to storage servers or remote services.




use Swoole\Coroutine;
use Swoole\Database\RedisConfig;
use Swoole\Database\RedisPool;
use Swoole\Runtime;

const N = 10;
Coroutine\run(function () {
    $pool = new RedisPool((new RedisConfig)
    for ($n = N; $n--;) {
        Coroutine::create(function () use ($pool) {
            $redis = $pool->get();
            $result = $redis->set('foo', 'bar');
            if (!$result) {
                throw new RuntimeException('Set failed');
            $result = $redis->get('foo');
            if ($result !== 'bar') {
                throw new RuntimeException('Get failed');
Last updated on August 31, 2022