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

本文主要是介绍SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!


文章目录

  • 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交换机适用于需要精确路由消息到指定队列的场景,是一种简单而高效的消息传递方式。



在这里插入图片描述



这篇关于SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/860866

相关文章

Java中的String.valueOf()和toString()方法区别小结

《Java中的String.valueOf()和toString()方法区别小结》字符串操作是开发者日常编程任务中不可或缺的一部分,转换为字符串是一种常见需求,其中最常见的就是String.value... 目录String.valueOf()方法方法定义方法实现使用示例使用场景toString()方法方法

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论:List 的 contain

MySQL双主搭建+keepalived高可用的实现

《MySQL双主搭建+keepalived高可用的实现》本文主要介绍了MySQL双主搭建+keepalived高可用的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,... 目录一、测试环境准备二、主从搭建1.创建复制用户2.创建复制关系3.开启复制,确认复制是否成功4.同

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("

Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

《SpringBoot+MyBatisPlus高效开发实战从入门到进阶优化(推荐)》本文将详细介绍SpringBoot+MyBatisPlus的完整开发流程,并深入剖析分页查询、批量操作、动... 目录Spring Boot + MyBATis Plus 高效开发实战:从入门到进阶优化1. MyBatis

SpringCloud动态配置注解@RefreshScope与@Component的深度解析

《SpringCloud动态配置注解@RefreshScope与@Component的深度解析》在现代微服务架构中,动态配置管理是一个关键需求,本文将为大家介绍SpringCloud中相关的注解@Re... 目录引言1. @RefreshScope 的作用与原理1.1 什么是 @RefreshScope1.

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

Spring Boot 配置文件之类型、加载顺序与最佳实践记录

《SpringBoot配置文件之类型、加载顺序与最佳实践记录》SpringBoot的配置文件是灵活且强大的工具,通过合理的配置管理,可以让应用开发和部署更加高效,无论是简单的属性配置,还是复杂... 目录Spring Boot 配置文件详解一、Spring Boot 配置文件类型1.1 applicatio

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定

Java中StopWatch的使用示例详解

《Java中StopWatch的使用示例详解》stopWatch是org.springframework.util包下的一个工具类,使用它可直观的输出代码执行耗时,以及执行时间百分比,这篇文章主要介绍... 目录stopWatch 是org.springframework.util 包下的一个工具类,使用它