SpringAMQP - 发布订阅模式
| 阿里云国内75折 回扣 微信号：monov8 |
| 阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6 |
目录
-
发布订阅介绍
- 发布Publish、订阅Subscribe
- 发布订阅模式与之前案例的区别就是允许将同一消息发送给多个消费者
- 实现方式是加入了exchange交换机
- Exchange交换机
- 一方面接收生产者发送的消息
- 另一方面知道如何处理消息
- 例如递交给某个特别队列、递交给所有队列、或是将消息丢弃
- 到底如何操作取决于Exchange的类型
- 常见exchange类型包括
- Fanout广播将消息交给所有绑定到交换机的队列
- Direct路由把消息交给符合指定routing key 的队列
- Topic话题把消息交给符合routing pattern的队列
- 注意exchange负责消息路由而不是存储路由失败则消息丢失
-
FanoutExchange简介
- 在广播模式下消息发送流程是这样的
- 可以有多个队列
- 每个队列都要绑定到 Exchange交换机
- 生产者发送的消息只能发送到交换机交换机来决定要发给哪个队列生产者无法决定
- 交换机把消息发送给绑定过的所有队列
- 订阅队列的消费者都能拿到消息
-
FanoutExchange案例
- 利用SpringAMQP演示FanoutExchange的使用
- 实现思路如下
- 1.在consumer服务中利用代码声明队列、交换机并将两者绑定
- 2.在consumer服务中编写两个消费者方法分别监听fanout.queue1和fanout.queue2
- 3.在publisher中编写测试方法向icpc.fanout发送消息
- 步骤1在consumer服务声明Exchange、Queue、Binding
- 步骤2在consumer服务声明两个消费者
- 在consumer服务的SpringRabbitListener类中添加两个方法
- 分别监听fanout.queue1和fanout.queue2
- 步骤3在publisher服务发送消息到FanoutExchange
- 在publisher服务的SpringAmqpTest类中添加测试方法
- 测试成功
-
常见小问题
- 交换机的作用是什么
- 接收publisher发送的消息
- 将消息按照规则路由到与之绑定的队列
- 不能缓存消息路由失败消息丢失
- FanoutExchange的会将消息路由到每个绑定的队列
- 声明队列、交换机、绑定关系的Bean是什么
- Queue
- FanoutExchange
- Binding
-
DirectExchange简介
- 在Fanout模式中一条消息会被所有订阅的队列都消费
- 但是在某些场景下我们希望不同的消息被不同的队列消费
- 这时就要用到Direct类型的Exchange
- Direct Exchange 会将接收到的消息根据规则路由到指定的Queue因此称为路由模式(routes)
- 在Direct模型下
- 队列与交换机的绑定不能是任意绑定了而是要指定一个RoutingKey路由key
- 消息的发送方在向 Exchange 发送消息时也必须指定消息的 RoutingKey
- Exchange不再把消息交给每一个绑定的队列而是根据消息的Routing Key进行判断只有队列的Routingkey与消息的 Routing key 完全一致才会接收到消息
-
DirectExchange案例
- 利用SpringAMQP演示DirectExchange的使用
- 实现思路如下
- 1.利用＠RabbitListener声明Exchange、Queue、RoutingKey
- 2.在consumer服务中编写两个消费者方法分别监听direct.queue1和direct.queue2
- 3.在publisher中编写测试方法向icpc.direct发送消息
- 步骤1在consumer服务声明Exchange、Queue
- 1.在consumer服务中编写两个消费者方法分别监听direct.queue1和direct.queue2
- 2.并利用＠RabbitListener声明Exchange、Queue、RoutingKey
- 步骤2在publisher服务发送消息到DirectExchange
- 在publisher服务的SpringAmqpTest类中添加测试方法
- 测试成功
-
常见小问题
- 描述下Direct交换机与Fanout交换机的差异
- Fanout交换机将消息路由给每一个与之绑定的队列
- Direct交换机根据RoutingKey判断路由给哪个队列
- 如果多个队列具有相同的RoutingKey则与Fanout功能类似
- 基于@RabbitListener注解声明队列和交换机有哪些常见注解
- @Queue
- @Exchange
-
TopicExchange简介
- Topic类型的Exchange与Direct相比
- 都是可以根据RoutingKey把消息路由到不同的队列
- 只不过Topic类型Exchange可以让队列在绑定Routing key 的时候使用通配符
- #匹配一个或多个词
- *匹配1个词
- 举例
- icpc.#能够匹配icpc.spu.insert 或者 icpc.spu
- icpc.*只能匹配icpc.spu
-
TopicExchange案例
- 利用SpringAMQP演示TopicExchange的使用
- 实现思路如下
- 1.并利用@RabbitListener声明Exchange、Queue、RoutingKey
- 2.在consumer服务中编写两个消费者方法分别监听topic.queue1和topic.queue2
- 3.在publisher中编写测试方法向icpc.topic发送消息
- 步骤1在consumer服务声明Exchange、Queue
- 1.在consumer服务中编写两个消费者方法分别监听topic.queue1和topic.queue2
- 2.并利用＠RabbitListener声明Exchange、Queue、RoutingKey
- 步骤2在publisher服务发送消息到TopicExchange
- 在publisher服务的SpringAmqpTest类中添加测试方法
- 测试成功
