发布/订阅
通过前两篇文章，我们了解到生产了消息后，一旦某个消费者消费了消息，那么其他消息者就无法消费该消息了，但有的时候，我们需要把消息发送到每一个消费者。例如我们有两个消费者，一个用于给用户发送短信，一个用于给用户发送邮件，但消息内容都是一样的。
分发一个消息给多个消费者（consumers）。这种模式被称为“发布／订阅”。
交换机（Exchanges）
RabbitMQ消息模型的核心理念是：发布者（producer）不会直接发送任何消息给队列。事实上，发布者（producer）甚至不知道消息是否已经被投递到队列。
发布者（producer）只需要把消息发送给一个交换机（exchange）。交换机一边从发布者方接收消息，一边把消息推送到队列。交换机必须知道如何处理它接收到的消息，是应该推送到指定的队列还是是多个队列，或者是直接忽略消息。这些规则是通过交换机类型（exchange type）来定义的。
有几个可供选择的交换机类型：直连交换机（direct）, 主题交换机（topic）, （头交换机）headers和 扇型交换机（fanout）。我们在这里主要说明最后一个 —— 扇型交换机（fanout）。先创建一个fanout类型的交换机，命名为logs：
$channel->exchange_declare('msgs', 'fanout', false, false, false);
扇型交换机（fanout）会把消息发送给它所知道的所有队列。
交换器列表
rabbitmqctl能够列出服务器上所有的交换器：
rabbitmqctl list_exchanges
匿名的交换器
前面的文章中我们对交换机一无所知，但仍然能够发送消息到队列中。因为我们使用了命名为空字符串(“”)默认的交换机。
例如之前是这样发布一则消息：
$channel->basic_publish($msg, '', 'hello');
这里我们使用默认或者匿名交换机：消息将会根据指定的routing_key分发到指定的队列，routing key是basic_publish函数的第三个参数。
发送消息到一个已命名的交换机：
$channel->exchange_declare('msgs', 'fanout', false, false, false); //msgs就是交换机的名称
$channel->basic_publish($msg, 'msgs');
临时队列
在 php-amqplib 客户端，当我们提供队列名称为空字符串时，我们创建了一个具有生成名称的非持久队列：
list($queue_name, ,) = $channel->queue_declare("");
方法返回时，$queue_name变量包含一个随机生成的RabbitMQ队列名称。例如，类似amq.gen-jzty20brgko-hjmujj0wlg。
绑定（Bindings）
创建了队列与交换机后，还需要完成交换机与队列的绑定，这样交换机才能知道把消息发送到哪个队列。
$channel->queue_bind($queue_name, 'msgs');
绑定后，交换机将会把消息添加到指定的队列中。
绑定（binding）列表
通过以下命令可以列出所有现存的绑定：
rabbitmqctl list_bindings
新建生产者：send_msg.php
新建send_msg.php用于发送消息至指定的交换机，代码如下：
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
$connection = new AMQPStreamConnection('x.x.x.x', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->exchange_declare('msgs', 'fanout', false, false, false);
$data = implode(' ', array_slice($argv, 1));
if(empty($data)) $data = "nobody";
$msg = new AMQPMessage($data);
$channel->basic_publish($msg, 'msgs');
echo "Sent message to ", $data, "\n";
$channel->close();
$connection->close();
?>
新建消费者：rec_msg1.php
新建rec_msg1.php用于将消息以email的方式发送给指定用户。
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
$connection = new AMQPStreamConnection('118.24.10.71', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->exchange_declare('msgs', 'fanout', false, false, false);
list($queue_name, ,) = $channel->queue_declare("", false, false, true, false);
$channel->queue_bind($queue_name, 'msgs');
echo 'Waiting for messages. To exit press CTRL+C', "\n";
$callback = function($msg){
echo 'Send email to ', $msg->body, "\n";
};
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
while(count($channel->callbacks)) {
$channel->wait();
}
$channel->close();
$connection->close();
?>
新建消费者：rec_msg2.php
新建rec_msg2.php用于将消息以短信方式发送给指定用户。
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
$connection = new AMQPStreamConnection('118.24.10.71', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->exchange_declare('msgs', 'fanout', false, false, false);
list($queue_name, ,) = $channel->queue_declare("", false, false, true, false);
$channel->queue_bind($queue_name, 'msgs');
echo 'Waiting for messages. To exit press CTRL+C', "\n";
$callback = function($msg){
echo 'Send sms to ', $msg->body, "\n";
};
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
while(count($channel->callbacks)) {
$channel->wait();
}
$channel->close();
$connection->close();
?>
简单说明一下，目前新建了3个文件，send_msg.php文件为消息生产者，用于将要发送给用户的消息推送到rabbitmq服务器，rec_msg1.php和rec_msg2.php为消费者，其中rec_msg1.php用于将消息以email的方式发送给用户，rec_msg2.php则用于将消息以短信的方式发送给用户。
运行以上三个文件后，效果如下图：
通过运行结果可以看出，生产者（send_msg.php）将消息推送到rabbimq后，rabbitmq将消息分发到了每一个生产者。
