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

系列目录

​​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的反智商设计，这设计的不实用又真废脑啊。

​​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、扩展内容：延时队列：延时队列插件及其有限的适用场景。

​​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、扩展内容：延时队列：延时队列插件及其有限的适用场景。