Swoole2.0协程客户端连接池的实现

Swoole2.0官方默认的实例是短连接的，在请求处理完毕后就会切断redis或mysql的连接。实际项目可以使用连接池实现复用。

实现原理也很简单，使用SplQueue，在请求到来时判断资源队列中是否有可用的连接，如果有直接拿来复用。如果没有就创建一个新的连接。在连接使用完毕后再讲它重新放回到队列，此连接就可以被其他协程复用。

1$count = 0;
2$pool = new SplQueue();
3$server = new Swoole\Http\Server('127.0.0.1', 9501, SWOOLE_BASE);
4
5$server->on('Request', function($request, $response) use(&$count, $pool) {
6    if (count($pool) == 0) {
7        $redis = new Swoole\Coroutine\Redis();
8        $res = $redis->connect('127.0.0.1', 6379);
9        if ($res == false) {
10            $response->end("redis connect fail!");
11            return;
12        }
13        $pool->push($redis);
14        $count++;
15    }
16    $redis = $pool->pop();
17    $ret = $redis->set('key', 'value');
18    $response->end("swoole response is ok, count = $count, result=" . var_export($ret, true));
19    $pool->push($redis);
20});
21
22$server->start();

此连接池代码也可用于其他协程客户端包括MySQL、HttpClient、TCPClient等。

协程没办法像异步回调程序一样可以对请求进行排队，然后通过事件驱动触发，没办法等到资源池可用。因此不太方便限制连接的数量。生产环境建议对连接池最大值做限制，操作最大连接数后，要拒绝客户端发起新的请求。

1if (count($pool) == 0) {
2    if ($count > 100) {
3        $response->status(500);
4        $response->end("<h1>连接池已满，无法提供服务，请稍后重试</h1>");
5    }
6}

转载至：https://my.oschina.net/matyhtf/blog/818339