-
rabbitmq五种模式详解(含实现代码)
一、五种模式详解
1.简单模式(Queue模式)
当生产端发送消息到交换机,交换机根据消息属性发送到队列,消费者监听绑定队列实现消息的接收和消费逻辑编写.简单模式下,强调的一个队列queue只被一个消费者监听消费.
1.1 结构
- 生产者:生成消息,发送到交换机
- 交换机:根据消息属性,将消息发送给队列
- 消费者:监听这个队列,发现消息后,获取消息执行消费逻辑
1.2应用场景
常见的应用场景就是一发,一接的结构
例如:
- 手机短信
- 邮件单发
2.争抢模式(Work模式)
强调的也是后端队列与消费者绑定的结构
2.1结构
- 生产者:发送消息到交换机
- 交换机:根据消息属性将消息发送给队列
- 消费者:多个消费者,同时绑定监听一个队列,之间形成了争抢消息的效果
2.2应用场景
- 抢红包
- 资源分配系统
3.路由模式(Route模式 Direct定向)
从路由模式开始,关心的就是消息如何到达的队列,路由模式需要使用的交换机类型就是路由交换机(direct)
3.1 结构
- 生产端:发送消息,在消息中处理消息内容,携带一个routingkey
- 交换机:接收消息,根据消息的routingkey去计算匹配后端队列的routingkey
- 队列:存储交换机发送的消息
- 消费端:简单模式 工作争抢
3.2应用场景
- 短信
- 聊天工具
- 邮箱。。
手机号/邮箱地址,都可以是路由key
4.发布订阅模式(Pulish/Subscribe模式 Fanout广播)
不计算路由的一种特殊交换机
4.1结构
4.2应用场景
- 消息推送
- 广告
5.主题模式(Topics模式 Tpoic通配符)
路由key值是一种多级路径。中国.四川.成都.武侯区
5.1结构
-
生产端:携带路由key,发送消息到交换机
-
队列:绑定交换机和路由不一样,不是一个具体的路由key,而可以使用*和#代替一个范围
| * | 字符串,只能表示一级 |
| --- | --- |
| # | 多级字符串 | -
交换机:根据匹配规则,将路由key对应发送到队列
-
消息路由key:
- 北京市.朝阳区.酒仙桥
- 北京市.#: 匹配true
- 上海市.浦东区.*: 没匹配false
- 新疆.乌鲁木齐.#
5.2 应用场景
- 做物流分拣的多级传递.
6.完整结构
二、代码实现
1.创建SpringBoot工程
1.1 工程基本信息
1.2 依赖信息
1.3 配置文件applicasion.properties
2.简单模式
2.1 创建SimpleQueueConfig 简单队列配置类
2.2 编写生产者
2.3 编写消费者
2.4 编写访问类
2.5 测试启动项目访问 simpleQueueTest
- 访问地址:http://127.0.0.1:8801/rabbitMq/simpleQueueTest
- 结果:
3.Work队列
3.1 编写工作配置
3.2 编写生产者
3.3 编写消费者1
3.4 编写消费者2
3.5 编写测试方法
3.6 测试启动项目访问 workQueueTest
- 访问地址http://127.0.0.1:8801/rabbitMq/workQueueTest
- 结果:
控制台打印,发现10条消息 偶数条消费者1获取,奇数条消费者2获取,并且平均分配。 当然通过代码实现按需分配,即谁的性能强,谁优先原则,实现负载均衡。 配置可控分配数
4. 发布订阅模式(Publish/Subscibe模式)
订阅模式–多个消费者监听不同的队列,但队列都绑定同一个交换机
4.1 编写订阅配置类
4.2 编写订阅生产者
4.3 编写订阅消费者1
4.4 编写订阅消费者2
4.5 编写测试方法
3.6 测试启动项目访问 fanoutQueueTest
- 访问地址http://127.0.0.1:8801/rabbitMq/fanoutQueueTest
- 结果:
控制台打印 ,发现两个绑定了不同队列的消费者都接受到了同一条消息查看RabbitMq 服务器:
5. 路由模式(Route模式 Direct定向)
5.1 编写路由配置类
5.2 编写生产者
5.3 编写消费者1
5.4 编写消费者2
5.5 编写访问类
5.6 测试启动项目访问directQueueTest1 , directQueueTest2
- 访问地址http://127.0.0.1:8801/rabbitMq/directQueueTest1
- 访问地址http://127.0.0.1:8801/rabbitMq/directQueueTest2
-
结果:
-
directQueueTest1:
-
directQueueTest2:
-
directQueueTest1:
6. 主题模式(Topics模式 Tpoic通配符)
6.1 编写路由配置类
6.2 编写生产者
6.3 编写消费者1
6.4 编写消费者2
6.5 编写访问类
6.6 测试启动项目访问topicQueueTest1 , topicQueueTest2
- 访问地址http://127.0.0.1:8801/rabbitMq/topicQueueTest1
- 访问地址http://127.0.0.1:8801/rabbitMq/topicQueueTest2
-
结果:
-
topicQueueTest1,两个消费者都能消费
- topicQueueTest2,只有消费者2 可以消费
-
topicQueueTest1,两个消费者都能消费
至此,五种队列的实现已结束!
7. 实现生产者消息确认
7.1 配置文件
7.2 编写消息发送确认类 RabbitConfirmCallback
7.3 编写消息发送交换机返回机制RabbitConfirmReturnCallBack
7.4 RabbitMQ配置
在我们的rabbit队列配置类里设置RabbitTemplate 举例:
启动项目发送消息,消息被正常消费,confim回调返回ack=true如果我们将exchange修改,发送到一个不存在的exchange中,会怎么样呢?
会发现confirm回调为false,打印出结果为不存在topicExchange1111的交换机
如果我们在消费端处理逻辑时出错会怎么样呢?修改消费端代码我们在消费时让它报错 confirm回调为true,但是在rabbitmq的web界面会发现存在5条没有消费的消息
如果我们把
中最后一个参数改为false呢,会发现在web管理界面没有未被消费的消息,说明这条消息已经被摒弃。
实际开发中,到底是打回到队列呢还是摒弃,要看自己的需求,但是打回队列应该有次数限制,不然会陷入死循环。 继续测试,将routingKey修改为一个没有的key,
7.5 结论
- 如果消息没有到exchange,则confirm回调,ack=false
- 如果消息到达exchange,则confirm回调,ack=true
- exchange到queue成功,则不回调return
- exchange到queue失败,则回调return
8. 项目示例代码:
下载地址:springboot-rabbitmq-demo_1619322789961
__EOF__