在前面的那个简单日志系统中，我们已经学会如何广播一条消息。
这篇我们将会讲到如何将部分消息发送到部分queue中。比如，我们会直接将错误的关键信息存入硬盘中，同时仍然在控制台打印所有的日志信息。
Bindings
在前面我们已经知道binding是exchange和queue之间的一种关系（将queue和exchange绑定在一起）。简单解读就是：某个queue对某个exchange（的消息）感兴趣。
Bindings会引入一个额外的参数routing_key。为了避免混淆Channel.Publish里面的参数，这里我们把它称为binding key。
绑定key的意义取决于exchange type。之前我们用fanout exchange时，忽略了他的价值。
Direct exchange
之前我们的那个日志系统是将所有的消息广播到所有的consumer，现在我们想根据日志的等级过滤部分消息。比如我们只想将error的日志存入硬盘，而不想将warning和info的日志存入硬盘。
fanout exchange并不是那样的灵活，不能满足我们的需求，因此这里我们需要使用direct exchange来代替，direct exchange的路由规则很简单：binding key和routing key匹配时，消息将会被发送至queue中。
注：
（1）routing key是Channel.Publish是程序告诉exchange这条消息该发送到哪里。
（2）binding key是exchange和queue之间binding的名字。
（3）当routing key和binding key相等时，exchange就知道根据binding key去将这条消息分发到下面的queue中；如果程序中的routing key的值不等于任何一个binding key，那么这条message即使发送至了exchange，由于没有匹配的binding key，所以不能发送到任何一个queue中，最终的结果导致这条消息会被丢弃。
从这个流程图中可知，direct exchange x上绑定了两个queue，第一个queue的binding key是orange，第二个是black和green。
当发送一个消息至x时使用的routing key为orange，那么这条消息将会被分发到Q1，如果routing key为black或green，将会被分发到Q2，其他的消息将会被忽略丢失。
Multiple bindings
这是用相同的binding key绑定多个queue的完美解决方案。在这里样例中，我们可以在x和Q1之间增加binding key：black。direct exchange会表现得像fanout exchange一样广播所有的消息到匹配的queue中。routing key为black的消息将会被分发到Q1和Q2中。
Emitting logs
我们将会在我们的日志系统中使用这种模式。以日志的严重性作为routing key。这样，接收脚本就能根据日志严重性接收自己想要接收的。
先看看发送消息端的代码：
声明一个exchange并发送消息
为了简化样例，假设日志错误等级只有"info","warning","error"。
Subscribing
接收message的代码和前面样例很相似，不过我们得做些修改以方便receiver.go在启动时可以从命令行参数设置binding。
命令行设置binding参数。[info] [warning] [error]
接下来是receiver.go接收信息
现在我们启动两个receiver.go程序，但是他们的binding参数不同：
一个程序只关心error的日志，以将它存入disk：
另一个程序则关心info，warining和error的日志，以在控制台打印：
这样queue与exchange的binding结构就是这样的：
图源于官网，只是queue的随机名不同罢了
现在我们在sender.go发送两条消息，分别是info等级的和error等级的
看下C1（只binding了error）端的打印结果
以及C2（binding了info，warning和error）端的打印结果
再看下RabbitMQ Server的监控页面
binding了info，warning和error的queue：
只binding了error的queue：
这样就完成了将日志按等级分类的做法，在现在开发中若需要将Message分类，用binding功能就是个不错的选择。
网友评论