在实际的rabbitMQ使用中，大部分场景都比较复杂，没有像上一篇学习笔记里介绍的单个consumer那么简单。通常会将一个消息deliver到多个consumer。这就是rabbitMQ实现的pub/sub模式，也就是发布/订阅模式。
为了阐述这个模式，我们实现一个简单的日志系统来演示pub/sub。系统的功能十分简单，一个生产者向rabbitMQ写入log，两个消费者监听rabbitMQ获得log信息，其中一个消费者将log打印到控制台上，另一个将log打印到磁盘上。在展示代码之前我们需要理解一些基本概念。
exchanges
rabbitMQ中所谓的交换机。在前一篇笔记中我们是通过在队列(queue)中发送和接收消息，来实现producer和consumer的解耦，我们简单快速的回顾一下前面介绍的rabbitMQ消息模型：
1、生产者是一个发送消息的应用
2、队列作为消息的缓冲和存储
3、消费者从队列中接收消息并处理
然而这个模型过于“simple”和粗粒度了，rabbitMQ的消息模型的核心思想是生产者和消费者的完全解耦。具体而言，就是生产者不会将消息发送到一个具体的队列，甚至大多是情况下生产者都不知道消息是否被发送到了队列中。那么rabbitMQ又是如何将消息发送到队列中的呢？
Producer发送的Message实际上是发到了Exchange中。它的功能也很简单：从Producer接收Message，然后投递到queue中。
Exchange需要知道如何处理Message，是把它放到那个queue中，还是放到多个queue中？这个rule是通过Exchange 的类型定义的。
exchange的类型定义有direct、topic、headers和fanout这几种，最后一种fanout就是广播，exchange会将收到的消息发送到所有的队列中。创建一个fanout的exchange，代码如下：
channel.exchangeDeclare("logs", "fanout");
有了exchange之后，生产者就可以向exchange发送消息：
channel.basicPublish( "logs", "", null, message.getBytes());
临时队列
截至现在，我们用的queue都是有名字的：第一个是hello，第二个是task_queue。使用有名字的queue，使得在Producer和Consumer之前共享queue成为可能。 但是对于我们将要构建的日志系统，并不需要有名字的queue。我们希望得到所有的log，而不是它们中间的一部分。而且我们只对当前的log感兴趣。为了实现这个目标，我们需要两件事情： 1） 每当Consumer连接时，我们需要一个新的，空的queue。因为我们不对老的log感兴趣。幸运的是，如果在声明queue时不指定名字，那么RabbitMQ会随机为我们选择这个名字。
2）当consumer断开和队列的连接时队列应该被自动删除。
在rabbitMQ java api里，我们可以声明一个临时的、可被自动删除的队列：
String queueName = channel.queueDeclare().getQueue();
这里的queueName是一个随机产生的队列名，类似amq.gen-JzTY20BRgKO-HjmUJj0wLg.这样的名字
bindings
上面我们已经创建了一个广播exchange和一个队列，现在我们需要告诉exchange向队列中发送消息，binding就是队列和交换机之间的关系。
channel.queueBind(queueName, "logs", "");
binding完成后exchange 就会向队列中发送消息了。
最终版本
Producer，在这里就是产生log的program，基本上和前几个都差不多。最主要的区别就是publish通过了exchange而不是routing_key。
import java.io.IOException;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
public class EmitLog {
private static final String EXCHANGE_NAME = "logs";
public static void main(String[] argv)
throws java.io.IOException {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
String message = getMessage(argv);
channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
channel.close();
connection.close();
}
//...
}
还有一点要注意的是我们声明了exchange。publish到一个不存在的exchange是被禁止的。如果没有queue bindings exchange的话，log是被丢弃的。
consumer：
import com.rabbitmq.client.*;
import java.io.IOException;
public class ReceiveLogs {
private static final String EXCHANGE_NAME = "logs";
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName, EXCHANGE_NAME, "");
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
Consumer consumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope,
AMQP.BasicProperties properties, byte[] body) throws IOException {
String message = new String(body, "UTF-8");
System.out.println(" [x] Received '" + message + "'");
}
};
channel.basicConsume(queueName, true, consumer);
}
}
另一个consumer只要把输出到屏幕上的那行代码改成输出到文件，其他并无不同，这里就不贴出来了。
