[toc] # RabbitMQ 簡單使用 - php **擴展包:** ``` composer require php-amqplib/php-amqplib ``` ## 生產者（發送到隊列） ```php <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->queue_declare('hello', false, false, false, false); $msg = new AMQPMessage('你好!'); $channel->basic_publish($msg, '', 'hello'); $channel->close(); $connection->close(); ``` ## 消費者 （消費隊列） ```php <?php require_once 'vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->queue_declare('hello', false, false, false, false); $callback = function(\PhpAmqpLib\\Message\\AMQPMessage $msg) { echo " [x] Received ", $msg->getBody(), "\n"; // 確認一個消息 (任務完成，從隊列中移除) $msg->getChannel()->basic_ack($msg->getDeliveryTag()); // 重新放入隊列 // $msg->getChannel()->basic_nack($msg->getDeliveryTag(), false, true); // 拋棄此消息 // $msg->getChannel()->basic_nack($msg->getDeliveryTag(), false, false); }; $channel->basic_consume('hello', '', false, false, false, false, $callback); while(count($channel->callbacks)) { $channel->wait(); } ``` **2021/5/25更新說明：`delivery_info`已棄用，推薦使用下面的方法替代ack確認消息。更加明確表達含義** ```php $msg->getChannel()->basic_ack($msg->getDeliveryTag()); if ($msg->getBody() === 'quit') { // 結束隊列使用者 $msg->getChannel()->basic_cancel($msg->getConsumerTag()); } ``` **參考資料:** - [RabbitMQ+PHP 教程一（Hello World）](https://segmentfault.com/a/1190000011825148)