简略队列通常为一个生产者、一个消费者、一个队列的构造。
装置依赖
# composer.json{ "require": { "php-amqplib/php-amqplib": ">=3.0" }}> composer.phar install模式构造
生产者
生产者连贯到RabbitMQ，发送一条音讯，而后退出。
# send.php<?phprequire_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('Hello World!');// 通过默认的交换机发送音讯到队列 (音讯内容, 默认交换机, 路由键)$channel->basic_publish($msg, '', 'hello');echo " [x] Sent 'Hello World!'\n";$channel->close();$connection->close();消费者
消费者监听来自 RabbitMQ 的音讯，通常须要始终放弃运行状态以监听音讯。
# receive.php<?phprequire_once __DIR__ . '/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);echo " [*] Waiting for messages. To exit press CTRL+C\n";// 定义音讯解决回调函数$callback = function ($msg) { echo ' [x] Received ', $msg->body, "\n";};$channel->basic_consume('hello', '', false, true, false, false, $callback);while ($channel->is_open()) { $channel->wait();}$channel->close();$connection->close();运行
关上一个终端，运行消费者：
php receive.php关上另一个终端，运行生产者：
php send.php应用 rabbitmqctl 工具查看队列
# Linuxsudo rabbitmqctl list_queues# Windowsrabbitmqctl.bat list_queues