RabbitMQ是一个代理器：它接管和转发。
你可以把它当作一个邮局：当你把邮件放在信箱里时，你可以肯定邮差师长西席终极会把邮件送到你的收件人那里。
在这个比喻中，RabbitMQ便是这里的邮箱，邮局和邮差。

RabbitMQ和邮局之间的紧张差异是，它不处理纸张，而是接管、存储和转发二进制数据‒。

RabbitMQ，和一样平常的通报，利用专业术语。

rabbitmqphp多进程RabbitMQPHP应用详解 React

生产者的事情便是发送。
发送的程序是生产者：

行列步队类比一个邮箱，存在于RabbitMQ， 然而信息流利过RabbitMQ和您的运用程序，他们只能存储在一个行列步队。
行列步队只受主机内存和磁盘限定的约束，它实质上是一个很大的缓冲区。
会有许多生产者可以发送到一个行列步队的，许多消费者可以考试测验从一个行列步队吸收数据。
这便是我们如何表示行列步队的办法：

消费者和生产者有着相似的意义. 消费者无非便是等待然后处理的程序:

请把稳，生产者、消费者和代理不必同一主机上；事实上，在大多数运用程序中它们没有这样做。

\"大众Hello World\公众

（利用PHP amqplib客户端）

在本教程的这一部分中，我们将用PHP编写两个程序；一个生产者发送一条，一个用户吸收并将它们打印出来。
我们会PHP amqplib API的忽略一些细节，集中在这个非常大略的事情刚刚开始。
这是一个“Hello World”的通报。

不才图中，“p”是我们的生产商，“C”是我们的消费者。
在中间的框是一个行列步队的缓冲区，RabbitMQ保持代表的消费。

PHP amqplib客户端库

RabbitMQ有很多协议。
本教程先容AMQP 0-9-1，这是一个开放的、通用的协议。
有许多不同的措辞RabbitMQ一批客户。
我们将在本教程中利用PHP amqplib，composer办理依赖管理。

添加composer.json:

{ \"大众require\"大众: { \公众php-amqplib/php-amqplib\"大众: \"大众>=2.6.1\"大众 }}composer install# 或者 直接运行包引入composer require php-amqplib/php-amqplib

现在我们可以开始我们的hello world

生产者（发送方）

我们命令我们的发布者（发送者）send.php和吸收receive.php。
发送者将连接到RabbitMQ，发送一条，然退却撤退出。

require_once __DIR__ . '/vendor/autoload.php';use PhpAmqpLib\Connection\AMQPStreamConnection;use PhpAmqpLib\Message\AMQPMessage;

现在我们能创建一个连接做事器的Connection:

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');$channel = $connection->channel();

该连接抽象套接字(socket)连接，并为我们卖力协议版本协商和认证等。
这里，我们连接到一个rabbitmq代理器在本地机器上-利用localhost。
如果我们想在不同的机器上连接到一个代理，我们只需在这里指定它的名称或IP地址。

接下来，我们创建一个通道，这是处理事情的大部分API的地方。

发送前，我们必须声明一个行列步队为我们发送做准备；然后我们可以向行列步队发布：

$channel->queue_declare('hello', false, false, false, false);$msg = new AMQPMessage('Hello World!');$channel->basic_publish($msg, '', 'hello');echo \"大众 [x] Sent 'Hello World!'\n\"大众;

声明行列步队是幂等的（原句：Declaring a queue is idempotent，这里的idempotent不知道是什么意思） - 只有在它不存在时才会创建行列步队。
内容是一个字节数组，因此您可以在那里编码用你喜好的办法。

末了，我们关闭通道和连接；

$channel->close();$connection->close();

上面我们完成了send.php.

接下来我们完成消费方的代码

消费者（吸收方，任务处理方）

消费者从RabbitMQ吸收推来的，我们会保持运行监听并打印出来。

引入lib

require_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\公众;

把稳，我们也在这里声明行列步队。
由于我们可能在发布之前启动消费者，我们希望在我们考试测验从它那里消费之前确定行列步队的存在。

我们将见告做事器从行列步队中发送。
我们将定义一个PHP可调用，它将吸收做事器发送的。
请记住，是从做事器异步发送到客户机的。

$callback = function($msg) { echo \公众 [x] Received \"大众, $msg->body, \公众\n\"大众;};$channel->basic_consume('hello', '', false, true, false, false, $callback);while(count($channel->callbacks)) { $channel->wait();}

当调用basic_consume，我们的代码会壅塞。
当我们收到时，我们的回调函数将通过吸收到返回的通报。

以上是我们receive.php的代码

运行测试

运行消费者

php receive.php

运行发送方

php send.php

列出行列步队

rabbitmqctl list_queues

转发于 https://my.oschina.net/u/2364788/blog/2876595