# 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开头的方法进行堵塞！