系列目录

RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。

RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。

RabbitMQ 入门系列：3、基础含义：持久化、排它性、自动删除、强制性、路由键。

RabbitMQ 入门系列：4、基础编码：官方SDK使用：链接创建、单例改造、发送消息、接收消息。

RabbitMQ 入门系列：5、基础编码：交换机的进阶介绍及编码方式。

RabbitMQ 入门系列：6、保障消息：不丢失：发送方、Rabbit存储端、接收方。

RabbitMQ 入门系列：7、保障消息：不重复消费：产生消息的唯一ID。

RabbitMQ 入门系列：8、扩展内容：接收信息时：可否根据RoutingKey过滤监听信息，答案是不能。

RabbitMQ 入门系列：9、扩展内容：死信队列：真不适合当延时队列。

RabbitMQ 入门系列：10、扩展内容：延时队列：延时队列插件及其有限的适用场景。

前言：

本篇介绍交换机的进阶介绍及编码方式。

1、 交换机的类型：

在第二篇文时，曾简单介绍过交换机，但没太深入，那是为了避免入门阻碍太多。

本篇再稍为加深一下交换机的介绍，但也是点到为止：

交换机默认有4个类型：

direct：1条信息仅允许发送到1个队列。（RoutingKey匹配队列名）

fanout：1条信息发送到所有绑定的队列。（忽略RoutingKey）

header：1条信息发送到匹配的队队。（用header头部数据匹配）

topic：1条信息发送到匹配RoutingKey规则的队列。（一般用#和*通配符）

通配符号#（无视.点号）和*（遇到.点号则中止）说明：

topic.#那么这个队列会接收topic开头的消息，如topic.hello.world
topic.*那么这个队列只接收topic开头后面一个的消息，如topic.hello

1、交换机：direct类型及其使用编码

实际上，之前的介绍中，在使用的代码中都避开了交换机。

其实不是没用到，只是用到的是默认交换机（AMQP default）：

1、它是direct类型，因此RoutingKey匹配队列名。

2、它默认通向所有的队列，即绑定了所有的队列。

3、交换机名称传值时默认传空值。

下面进行1个简单的消息发送：

channel.BasicPublish(“”, “first", false, null, Encoding.UTF8.GetBytes("这是要发送的内容aaa"));

从Web控制中心查看数据，可以看到，路由使用了默认的，而RoutingKey 则是对应了队列了名称。

3、交换机：fanout类型的使用编码

对fanout类型的使用，所有的routekey都传空值即可。

using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
{
    //定义队列
    channel.QueueDeclare("user.order");
    channel.QueueDeclare("user.birth");

    //定义交换机
    channel.ExchangeDeclare("user", "fanout");

    //交换机绑定2个队列
    channel.QueueBind("user.order", "user", "");
    channel.QueueBind("user.birth", "user", "");

    //发送到交换机，直接到达2个队列
    channel.BasicPublish("user", "", false, null, Encoding.UTF8.GetBytes("两个队列都收到信息"));

}

管理界面可以看到信息：

4、交换机：topic类型编码

对于交换机类型来说：

direct类型：队列名就是routing key。

fanout类型：只关注交换机名称，routing key都是空。

topic类型：只有这个是重心放在routing key，而不关心队列起名规则。

下在看代码（用first、first2、first3）来演示（演示前会清空数据）：

using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
{
　　 //定义交换机
    channel.ExchangeDeclare("user_topic", "topic");

    //交换机绑定3个队列
    channel.QueueBind("first", "user_topic", "#.order");
    channel.QueueBind("first2", "user_topic", "#.birth");
    channel.QueueBind("first3", "user_topic", "#.birth");

    //发送到交换机，直接到达2个队列
    channel.BasicPublish("user_topic", "user.order", false, null, Encoding.UTF8.GetBytes("1队列都收到信息"));
    channel.BasicPublish("user_topic", "user.birth", false, null, Encoding.UTF8.GetBytes("2队列都收到信息"));


}

数据结果：

这里必须吐槽一下，这个规则的设计反智商啊：

这种设计，用topic模块，一个信息只能发送到一个队列：

泥媒，这真是妥委的direct加强版，还真是只能到一个队列，加了个匹配规则，变成一个很弱鸡的功能。

要同时满足发送到多个队列，就必须绑定多个绑定规则......

个人觉得设计应该反过来才对：

绑定交换机时，定义完整的路径，发布消息时，带上通配符，去匹配规则，达到可以发送一个或多个队列去才合理。

5、交换机：header类型及其使用编码

这个类型不常用，暂未想到应用场景，暂不介绍。 

总结：

本篇介绍如交换机介绍及以使用其发送消息到多个队列，特别是topic的路由key的反智商设计，这设计的不实用又真废脑啊。

个人微信公众号

创业QQ群：617713515

Donation(扫码支持作者)：支付宝：

Donation(扫码支持作者)：微信：