SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)

简介: SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)

上一篇文章中的 Fanout 模式,一条消息,会被所有订阅其交换机的队列都消费。


但是,在某些场景下,我们希望不同的消息被不同的队列消费。这时就要用到 Direct类型的交换机。


Direct 交换机特点


在Direct模型下:


  • 队列与交换机的绑定,不能是任意绑定了,而是要指定一个RoutingKey(路由key)
  • 消息的发送方在 向 Exchange发送消息时,也必须指定消息的 RoutingKey。
  • Exchange不再把消息交给每一个绑定的队列,而是根据消息的Routing Key进行判断,只有队列的Routingkey与消息的 Routing key完全一致,才会接收到消息


实战


我们定义一个定向交换机( Direct Exchange )

再定义两个队列,让这两个队列绑定到该交换机上,并且按照如下图 key 的规则绑定.

声明交换及其队列(以注解方式)


上篇文章是按照基于@Bean的方式声明队列和交换机比较麻烦,Spring还提供了基于注解方式来声明。

consumerSpringRabbitListener 中添加两个消费者,同时基于注解来声明队列和交换机:

 /** 基于注解的来声明交换机和队列及其绑定关系 */
@RabbitListener( bindings = @QueueBinding(
        exchange = @Exchange(name = "test2024.direct", type = ExchangeTypes.DIRECT),
        value = @Queue(name = "test2024.direct.redOrBlueOrYellow"),
        key = {"red", "yellow", "blue"}
))
public void rabbitListener5(String message) {
    System.out.println("红黄蓝: " + message);
}

@RabbitListener( bindings = @QueueBinding(
        exchange = @Exchange(name = "test2024.direct", type = ExchangeTypes.DIRECT),
        value = @Queue(name = "test2024.direct.WhiteOrBlack"),
        key = {"white", "black"}
))
public void rabbitListener6(String message) {
    System.out.println("黑白: " + message);
}
/** 基于注解的来声明交换机和队列及其绑定关系 */

启动上面的服务后 我们发现指定的交换机和队列都创建好了


发消息

//  测试定向交换机
@Test
public void test03() throws InterruptedException {
    String exchangeName = "test2024.direct";
    String[] keyArray = {"red", "yellow", "blue", "black", "white"};
    String message = "this is a message from direct! key: ";
    for (int i = 0; i < 50; i++) {
        int index = new Random().nextInt(keyArray.length);
        rabbitTemplate.convertAndSend(exchangeName, keyArray[index], message + keyArray[index]);
    }
    Thread.sleep(500);
}


看到数据都规规整整的进入指定的key对应的队列,并被消费.


应用


Direct 交换机适用于一对一的消息传递模式,它通过消息的路由键(Routing Key)将消息发送到与之完全匹配的队列中。因此,Direct交换机常用于以下情况:


  • 点对点通信:当系统中存在一对一的通信需求时,可以使用Direct交换机来确保消息被准确地路由到目标队列。例如,订单系统中将订单消息发送到指定的订单处理队列。
  • 任务分发:在分布式系统中,可以使用Direct交换机来将任务分发到不同的工作节点。每个工作节点都可以绑定一个特定的队列,根据任务的类型或者其他属性,将任务发送到相应的队列中。
  • 系统内部通知:当系统需要向特定的用户或者部门发送通知消息时,可以使用Direct交换机来确保消息仅发送给目标接收者,而不会广播给所有用户。
  • 错误处理:在系统中可能会发生错误,需要将错误消息发送到指定的队列中进行处理。Direct交换机可以将错误消息准确地路由到错误处理队列,方便进行后续的排查和处理。


Direct交换机适用于需要精确路由消息到指定队列的场景,是一种简单而高效的消息传递方式。


相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
1月前
|
消息中间件 JSON Java
RabbitMQ的springboot项目集成使用-01
RabbitMQ的springboot项目集成使用-01
|
1月前
|
消息中间件 Java Spring
Springboot 集成Rabbitmq之延时队列
Springboot 集成Rabbitmq之延时队列
142 0
|
1月前
|
消息中间件 Java
SpringBoot基于RabbitMQ实现死信队列 (SpringBoot整合RabbitMQ实战篇)
SpringBoot基于RabbitMQ实现死信队列 (SpringBoot整合RabbitMQ实战篇)
49 1
|
1月前
|
消息中间件 安全 Java
SpringBoot基于RabbitMQ实现消息可靠性
SpringBoot基于RabbitMQ实现消息可靠性
49 0
|
1月前
|
消息中间件 Java
SpringBoot实现RabbitMQ的通配符交换机(SpringAMQP 实现Topic交换机)
SpringBoot实现RabbitMQ的通配符交换机(SpringAMQP 实现Topic交换机)
16 1
|
消息中间件 网络协议 Java
Springboot 整合RabbitMq ,用心看完这一篇就够了
Springboot 整合RabbitMq ,用心看完这一篇就够了
1515 0
Springboot 整合RabbitMq ,用心看完这一篇就够了
|
消息中间件 Java
SpringBoot整合RabbitMQ
SpringBoot整合RabbitMQ
138 0
|
消息中间件 Java 数据格式
SpringBoot整合RabbitMQ
RabbitMQ是开源消息队列系统,用erlang语言开发。如果不了解可以查看官网http://www.rabbitmq.com/ 这篇文章介绍一个springboot简单整合RabbitMQ。
2656 0
|
1月前
|
Java 应用服务中间件 Maven
SpringBoot 项目瘦身指南
SpringBoot 项目瘦身指南
78 0
|
1月前
|
缓存 安全 Java
Spring Boot 面试题及答案整理,最新面试题
Spring Boot 面试题及答案整理,最新面试题
168 0

热门文章

最新文章