# AMQP 通過php-amqplib/php-amqplib庫和eventloop實現異步回調。 底層是基于stream庫并不是swoole_client，write的操作依舊是堵塞的，不過這個影響已經極小，read的操作通過eventloop實現了異步讀，所以可以實現異步的訂閱。 比較具體的用法可以參考[php-amqplib](https://github.com/php-amqplib/php-amqplib/)中的demo。但是有些細節需要注意，有所不同。 初始化的地點依舊是在AppServer的initAsynPools下 例子： ```php /** * 這里可以進行額外的異步連接池，比如另一組redis/mysql連接 * @param $workerId * @return array */ public function initAsynPools($workerId) { parent::initAsynPools($workerId); if($workerId==0) { $amqp = new AMQP('localhost',5672,'guest','guest'); $channel = $amqp->channel(); $channel->queue_declare('msgs', false, true, false, false); $channel->exchange_declare('router', 'direct', false, true, false); $channel->queue_bind('msgs', 'router'); $channel->basic_consume('msgs', 'consumer', false, false, false, false, function (AMQPMessage $message) { echo "\n--------\n"; echo $message->body; $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']); }); } } ``` 這里只在第一個進程中啟動了AMQP客戶端。 異步AMQP客戶端是由Server\Asyn\AMQP\AMQP構建的，不要使用錯了。 和php-amqplib庫中demo不同的是，千萬不要使用wait方法進行堵塞！ 重要的事情說三遍，千萬不要使用任何wait方法或者wait開頭的方法進行堵塞，千萬不要使用任何wait方法或者wait開頭的方法進行堵塞，千萬不要使用任何wait方法或者wait開頭的方法進行堵塞！