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