1234567891011121314151617181920212223 |
- <?php
- $count = 0;
- $pool = new SplQueue();
- $server = new Swoole\Http\Server('127.0.0.1', 9501, SWOOLE_BASE);
- $server->on('Request', function($request, $response) use(&$count, $pool) {
- if (count($pool) == 0) {
- $redis = new Swoole\Coroutine\Redis();
- $res = $redis->connect('127.0.0.1', 6379);
- if ($res == false) {
- $response->end("redis connect fail!");
- return;
- }
- $pool->enqueue($redis);
- }
- $redis = $pool->dequeue();
- $count ++;
- $ret = $redis->set('key', 'value');
- $response->end("swoole response is ok, count = $count, result=" . var_export($ret, true));
- $pool->enqueue($redis);
- });
- $server->start();
|