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