SpringAMQP - 发布订阅模式
目录
发布订阅介绍
FanoutExchange简介
FanoutExchange案例
常见小问题
DirectExchange简介
DirectExchange案例
常见小问题
TopicExchange简介
TopicExchange案例
-
发布订阅介绍
- 发布（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类中添加测试方法：
- 测试成功
