之前发布的文章因为在编辑后代码部分在手机上看不清已被及时删除，本文重新编辑好之后再发布一次，带来不便请谅解！
專 欄
❈
ZZR，Python中文社区专栏作者，OpenStack工程师，曾经的NLP研究者。主要兴趣方向：OpenStack、Python爬虫、Python数据分析。
Blog：http://skydream.me/
CSDN：http://blog.csdn.net/titan0427/article/details/50365480
❈
fanout exchange
在上一篇中，task_queue所解决的问题是，一个message只能被一种consumer所接收。现在我们有了新的需求，我们需要一个日志系统，我们希望有两种consumer，一种consumer将日志输出到屏幕，另一种consumer写到disk。为了实现这个目的，我们希望message被投到两个queue中，交给不同的consumer进行处理。如下所示：
对于producer，不再指定哪一个queue来接收消息，而是哪一个exchange来接收消息。exchange不保存信息，如果没有queue绑定在这个exchange上的话，消息就丢失了。代码如下：
对于consumer，自己创建临时queue（exclusive=True，当这个consumer终止，这个queue就销毁），将这个queue接到exchange上，然后通过这个queue接收exchange发出的消息：
如下图所示，每一个consumer都建了自己的临时queue，并与exchange进行了绑定：
direct exchange
上面的例子中，queue_bind()的时候我们没有指定routing_key（为了避免混淆，后续将其称为binding_key）。binding_key的功能与exchange的类型有关。对于fanout exchange而言，binding_key没有意义。对于direct exchange而言，如下图所示，只有消息的routing_type与queue的binding_key相同时才会发送到该queue：
可以指定相同的binding_key，如下图所示：
借此，我们可以将日志系统改造为以下模式，不同的consumer只接收特定类型的日志信息：
完整代码如下：
topic exchang
topic exchange与direct exchange类似，只是它允许binding_key使用特殊字符（注意，特殊字符代表的是单词，不是字母）：
- *：代表一个单词
- #：代表零个或多个单词
比如下面这个例子。routing_key定义为"<celerity>.<colour>.<species>"。举几个routing_key匹配的例子：
- quick.orange.rabbit：一，二
- lazy.orange.elephant：一，二
- quick.orange.fox：一
- lazy.brown.fox：三
- lazy.pink.rabbit：二，三（但只发一次，因为二和三是同一个队列）
- quick.brown.fox：无，舍弃
- orange：无，舍弃
- quick.orange.male.rabbit：无，舍弃
- lazy.orange.male.rabbit：三
当binding_key不使用这些特殊字符时，topic exchange其实就是direct exchange；当binding_key使用#时，topic exchange其实就是fanout exchange，也就是所有消息都接收。
一些极端的例子：
binding_key：*，routing_key：空串。不匹配。
binding_key：#.*，routing_key：..。匹配。
binding_key：#.*，routing_key：apple。匹配。
完整代码：
总结
在上一篇中:
再回顾一下上面的代码。首先明确，这种情况使用的是默认exchange。对于producer，它将消息交给exchange，然后exchange通过routing key来判断要将消息交到哪个queue。实际上相当于将消息直接发送到queue中。而consumer直接指定queue的名字，也就是它直接绑定到这个queue。这个过程中exchange其实没什么存在感。
