# 在多個協程間共用同一個協程客戶端 同步阻塞程序不同，協程是并發處理請求的，因此同一時間可能會有很多個請求在并行處理，一旦共用客戶端連接，就會導致不同協程之間發生數據錯亂。 #### 錯誤的代碼 ```php $server = new Swoole\Http\Server('127.0.0.1', 9501); $server->on('Receive', function ($serv, $fd, $rid, $data) { $redis = RedisFactory::getRedis(); $result = $redis->hgetall('key'); $resp->end(var_export($result, true)); }); $server->start(); class RedisFactory { private static $_redis = null; public static function getRedis() { if (null === self::$_redis) { $redis = new \Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379); self::$_redis = $redis; } return self::$_redis; } } ``` #### 正確的代碼 基于`SplQueue`實現協程客戶端的連接池，可以復用協程客戶端，實現長連接。 ```php $pool = new RedisPool(); $server = new Swoole\Http\Server('127.0.0.1', 9501); $server->on('Request', function($req, $resp) use ($pool) { //從連接池中獲取一個Redis協程客戶端 $redis = $pool->get(); //連接失敗 if ($redis === false) { $resp->end("ERROR"); return; } $result = $redis->hgetall('key'); $resp->end(var_export($result, true)); //釋放客戶端，其他協程可復用此對象 $pool->put($redis); }); $server->start(); class RedisPool { protected $pool; function __construct() { $this->pool = new SplQueue; } function put($redis) { $this->pool->push($redis); } function get() { //有空閑連接 if (count($this->pool) > 0) { return $this->pool->pop(); } //無空閑連接，創建新連接 $redis = new Swoole\Coroutine\Redis(); $res = $redis->connect('127.0.0.1', 6379); if ($res == false) { return false; } else { return $redis; } } } ```