系列目录
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都传空值即可。
![复制代码](https://common.cnblogs.com/images/copycode.gif)
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("两个队列都收到信息")); }
![复制代码](https://common.cnblogs.com/images/copycode.gif)
管理界面可以看到信息:
4、交换机:topic类型编码
对于交换机类型来说:
direct类型:队列名就是routing key。 fanout类型:只关注交换机名称,routing key都是空。 topic类型:只有这个是重心放在routing key,而不关心队列起名规则。
下在看代码(用first、first2、first3)来演示(演示前会清空数据):
![复制代码](https://common.cnblogs.com/images/copycode.gif)
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队列都收到信息")); }
![复制代码](https://common.cnblogs.com/images/copycode.gif)
数据结果:
这里必须吐槽一下,这个规则的设计反智商啊:
这种设计,用topic模块,一个信息只能发送到一个队列:
泥媒,这真是妥委的direct加强版,还真是只能到一个队列,加了个匹配规则,变成一个很弱鸡的功能。
要同时满足发送到多个队列,就必须绑定多个绑定规则......
个人觉得设计应该反过来才对:
绑定交换机时,定义完整的路径,发布消息时,带上通配符,去匹配规则,达到可以发送一个或多个队列去才合理。
5、交换机:header类型及其使用编码
这个类型不常用,暂未想到应用场景,暂不介绍。
总结:
本篇介绍如交换机介绍及以使用其发送消息到多个队列,特别是topic的路由key的反智商设计,这设计的不实用又真废脑啊。
版权声明:本文原创发表于 博客园,作者为 路过秋天 本文欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则视为侵权。 |
个人微信公众号![]() |
创业QQ群:617713515![]() |
Donation(扫码支持作者):支付宝:![]() |
Donation(扫码支持作者):微信:![]() |
![]() |
![]() |