先决条件
本教程假定RabbitMQ已经安装，并运行在localhost标准端口（5672）。如果你使用不同的主机、端口或证书，则需要调整连接设置。
从哪里获得帮助
如果您在阅读本教程时遇到困难，可以通过邮件列表。
（使用.NET客户端）
在教程[3]中，我们构建了一个简单的日志系统，我们可以向多个接收者广播消息。
在本教程中，我们会日志系统其再添加一个特性，使其可以只订阅消息的一个子集。例如，将所有日志消息打印到
控制台的同时，只会将严重错误消息写入日志文件（保存到磁盘空间）。
在前面的例子中，我们创建过绑定。不知道您是否还记得下面的代码：
channel.QueueBind(queue: queueName, exchange: "logs", routingKey: "");绑定是指交换器和队列之间的关联关系。可以简单地理解为：某个队列对来自此交换器的消息感兴趣。
绑定可以采用一个额外的routingKey参数，为了避免与BasicPublish方法中相同参数混淆，我们将其称为binding key（译者注：这里是指路由键从声明角度的一种别称）。下面即是如何使用 binding key 建立一个绑定：
channel.QueueBind(queue: queueName, exchange: "direct_logs", routingKey: "black");binding key 的含义取决于交换器类型。像我们前面使用的fanout型交换器，忽略了它的值（译者注：依据fanout交换器的特性，它会没头脑地把消息广播到所有订阅的队列，所以就算指定routingKey也不会根据其过滤消息）。
Direct型交换器在上篇教程中，我们的日志记录系统会把所有消息广播给所有消费者，现在我们想要扩展使其可以根据消息的严重性过滤消息。例如，我们希望将日志消息写入磁盘的脚本仅接收严重错误的消息，而不是在警告或者信息类型的消息上浪费磁盘空间。
之前我们使用的是fanout交换器，但是它没有给我们足够的灵活性 - 它只能进行无意识的广播。
现在我们将用direct交换器替换，direct交换器背后的路由算法很简单 - 消息会进入其binding key恰好与routing key相匹配的队列。
为了说明这一点，请参考以下设置：
在上面的设置中，我们可以看到direct型交换器X与两个队列绑定。第一个队列通过键orange绑定，第二个队列有两个绑定，一个通过键black绑定、另外一个通过键green绑定。
如此设置，发布使用路由键orange的消息到交换器最终会被路由到队列Q1，路由键为black或green的消息会去向队列Q2，而其他所有的消息会被丢弃。
多重绑定
使用相同的 binding key 绑定多个队列是完全合法的。在我们的例子中，我们可以在X和Q1之间添加一个键为black的绑定。这种情况下，direct交换器会像fanout交换器一样，把消息广播到所有匹配的队列，路由键为black的消息会被分别传送到队列Q1和Q2。
发送日志我们将为日志系统使用以上模型，我们会在发送消息时使用 direct 型交换机，而不是 fanout 型。我们会基于日志的严重性作为路由键，这样的话接收端脚本将可以选择它期望接收的严重性。让我们首先聚焦在发送日志方面。
我们将要在我们日志系统使用上面的模型，我们会发送消息到一个direct型交换器，而不是fanout型交换器。我们会使用日志的严重性作为routing key。这样的话，接收脚本就可以选择性地接收它期望严重性的消息。首先我们来关注如何发送日志。
一如既往，我们需要先创建一个交换器：
channel.ExchangeDeclare(exchange: "direct_logs", type: ExchangeType.Direct);准备好发送消息：
var body = Encoding.UTF8.GetBytes(message); channel.BasicPublish(exchange: "direct_logs", routingKey: severity, basicProperties: null, body: body);简单起见，我们假定severity可以是info、warning或error任意一值。
订阅接收消息将像上一个教程一样工作，但有一个例外 - 我们将为我们感兴趣的每个严重性创建一个新的绑定。
就像之前教程一样，接收消息这一块都运行得很好，唯独有一处不同 -- 那就是我们 为自己所感兴趣的（日志的）每一种严重性创建一个新的绑定。
马上就可以像前面的教程中那样接收消息了，但是有一个不同点，我们要用自己感兴趣的所有日志严重程度分别创建一个绑定。
马上就可以像前面的教程接收消息了，但有一点不同， 我们需要为我们感兴趣的每种日志严重性建立一个新的绑定。
var queueName = channel.QueueDeclare().QueueName; foreach(var severity in args) { channel.QueueBind(queue: queueName, exchange: "direct_logs", routingKey: severity); } 组合在一起