了解了消息和队列之后，我们需要考虑一个问题，消息是怎么进入到队列里面的呢？
现在我们知道，绑定定义了队列和交换器之间的关系。当一条消息从生产者发到 Rabbit 服务器的时候，消息将拥有一个路由键——即便是空的，然后交换器将路由键和绑定的规则进行比对，如果相匹配的话，那么消息将会投递到对应的队列。如果路由的消息不匹配任何绑定规则的话，消息将进入“黑洞”。
交换器的类型
交换器共有以下四种类型，每一种类型实现了不同的路由算法：
- direct
- fanout
- topic
- headers
direct 交换器
它是包含一个空白字符串名称的默认交换器。当声明一个队列时，它会自动绑定到默认交换器，并以队列名称作为绑定规则。可以简单地使用如下代码发送消息到声明的队列去。
$ channel -> basic_publish($msg, '', 'queue-name');
第一个参数是要发送的消息内容；第二个参数是一个空的字符串，指定了默认交换器；而第三个参数就是路由键。
direct交换器消息流
fanout 交换器
这种类型的交换器会将收到的消息广播到绑定的队列上。消息通信模式也很简单：当你发送一条消息到 fanout 交换器时，它会把消息投递给所有附加在此交换器上的队列。
这适用于对单条消息做不同方式的反应。举例来说，一个 Web 应用程序可能需要在用户上传新的头像时，用户相册必须清除缓存，同时用户应该得到些积分奖励。你可以将两个队列绑定到头像上传交换器上。一个用于清除缓存，另一个用于增加用户积分。也方便于应用程序的拓展。例如，新增一个功能，在用户上传新的头像时把旧头像迁到历史文件服务器，这时需要做的是为新的消费者写一段代码，然后声明新的队列并将其绑定到 fanout 交换器上。
fanout交换器消息流
topic 交换器
这种类型的交换器可以使来自不同源头的消息能够到达同一个队列。
topic-交换器消息流
我们用 Web 应用程序日志系统作为示例。假如你拥有多个不同的日志级别，如 error、info 和 warning。与此同时，你的应用程序分为以下几个模块：user-profile、image-gallery、msg-inbox 等。以上图为参考。
如果在发送消息的动作失败时，你想要报告一个 error 的话，则可以编写以下代码：
$ channel -> basic_publish($msg, 'logs-exchange', 'error.msg-inbox');
然后，假设你声明了一个 msg-inbox-errors 队列，你可以将其绑定到交换器上来接收消息，代码如下所示：
$ channel -> queue_binding('msg-inbox-errors', 'logs-exchange', 'error.msg-inbox');
第一个参数为队列名；第二个参数为交换器名；第三个参数为绑定规则。
这样就能确保刚才发布的消息会路由到 msg-inbox-errors 队列。
问题一：如果想要一个队列监听 msg-inbox 模块的所有 error 级别的话，怎么做呢？
解答一：可以通过将新的队列绑定到已有的同一个交换器来实现，就像下面这样：
$ channel -> queue_binding('msg-inbox-logs', 'logs-exchange', '*.msg-inbox');
msg-inbox-logs 队列将会接收从 msg-inbox 模块发来的所有 error、warning 和 info 日志信息。
问题二：如何接收所有的日志呢？
解答二：可以在把队列绑定到交换器上的时候使用通配符“#”，如下面代码：
$ channel -> queue_binding('all-logs', 'logs-exchange', '#');
通过这样的绑定方式，all-logs队列将会接收所有从Web应用程序发布的日志。
要使得之前的示例能够运行，你必须在绑定之前对队列进行声明。“*”操作符将“.”视为分隔符；与之不同的是，“#”操作符没有分块的概念，它将任意“.”字符均视为关键字的匹配部分。
headers 交换器
headers 交换器允许你匹配 AMQP 消息的 header 而非路由键。除此之外，headers 交换器和 direct 交换器完全一致，但性能会差很多，因此它并不太实用，而且几乎再也用不到了。
网友评论