搭建消息时光机:深入探究RabbitMQ_recent_history_exchange在Spring Boot中的应用【RabbitMQ实战 二】

简介: 搭建消息时光机:深入探究RabbitMQ_recent_history_exchange在Spring Boot中的应用【RabbitMQ实战 二】

欢迎来到我的博客,代码的世界里,每一行都是一个故事


前言

在编程的世界里,时间似乎总是紧迫的。但是,如果你有了一台消息时光机,就能够轻松穿越异步通信的时空,实现更为精准的消息处理。今天,我们将探索RabbitMQ_recent_history_exchange这个神奇的时光机,看看它如何与Spring Boot一同构建异步通信的未来!

第一:开启插件支持

对于RabbitMQ3.6.0或更高版本,此插件已经内置到RabbitMQ中

⭐️:开启方式

# 非docker搭建,或已经进入到容器内的
rabbitmq-plugins enable rabbitmq_recent_history_exchange
# docker-compose搭建,或docker搭建
docker exec myRabbitmq rabbitmq-plugins enable rabbitmq_recent_history_exchange
# 其中myRabbitmq为你的容器名称

👊:配置成功return

第二:springboot整合

这里基础的整合和上面引言中的实战是一样的,就不过多的赘述了,只贴出关键性代码,以及相应的实现

@Bean
public CustomExchange exchange() {
  Map<String, Object> args = new HashMap<>();
  args.put("x-recent-history-length", 100); // 使用插件提供的 x-delayed-type 参数
  return new CustomExchange(MQ_EXCHANGE,"x-recent-history", true, false,args);
}

1️⃣: args.put("x-recent-history-length", 100);指的是此交换将存储通过交换发送的最新 100条消息

2️⃣: CustomExchange(MQ_EXCHANGE,"x-recent-history", true, false,args)指定类型为x-recent-history

3️⃣:防止存储某些消息

如果您不想存储某些消息,只需将"x-recent-history-no-store"带有值的标头添加true到消息中即可。

第三:效果展示

交换机属性展示

下图可以明显的看到交换机的类型,以及存储的最大条数

功能实现展示

要清楚的看到最后的实现效果,需要进行如下几步

1️⃣:上面都配置好,且交换机创建成功

2️⃣:需要实现一个队列去绑定上面的交换机,且发送一些消息

3️⃣:再创建一个新的队列绑定上面的交换机,即可出现以下效果

上面的testQueue是新创建的队列,可以发现,交换机会自动向其推历史的消息

第四:使用场景

rabbitmq_recent_history_exchange 插件的实际使用场景通常涉及到需要在消费者订阅某个交换机时获取历史消息的情况。这在一些特定的应用场景中是非常有用的,以下是一些可能的使用场景和总结:

使用场景:

  1. 新加入的消费者获取历史消息: 当一个新的消费者加入系统时,它可能需要获取之前已经发布到交换机上的消息,以确保不会错过重要的信息。这在一些实时通讯或实时监控系统中比较常见。
  2. 应用重启时的数据同步: 在应用程序重启时,如果需要将某些历史数据同步到内存中,可以使用 rabbitmq_recent_history_exchange 来获取之前的消息,而不是从数据库等持久化存储中重新加载。
  3. 实时数据流: 对于实时数据流应用,新的消费者加入时可能需要获取历史数据,以确保对整个数据流的完整性有一个良好的认知。
  4. 数据快照: 在某些场景中,需要定期或事件触发地获取一段时间内的消息数据快照。rabbitmq_recent_history_exchange 可以用于在特定时刻获取消息的快照。

总结:

  • 优势: 提供了在订阅时获取历史消息的机制,简化了对历史数据的处理,使得新的消费者能够更容易地获取之前的消息。
  • 适用性: 适用于需要在消费者订阅时获取历史消息的场景,特别是那些对实时性要求不是非常严格的应用。
  • 注意事项: 对于对实时性要求非常高的场景,可能需要谨慎使用,因为历史消息的获取可能引入一定的延迟。
  • 配置参数: 需要根据实际需求合理配置交换机和队列的参数,如历史消息的长度和过期时间。

总体而言,rabbitmq_recent_history_exchange 插件为 RabbitMQ 提供了一种在特定场景下简化历史消息获取的机制,提高了系统的灵活性。在使用时,需要根据具体业务需求和性能要求来权衡是否使用以及如何配置。

结语

深深感谢你阅读完整篇文章,希望你从中获得了些许收获。如果觉得有价值,欢迎点赞、收藏,并关注我的更新,期待与你共同分享更多技术与思考。

相关实践学习
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
相关文章
|
21天前
|
XML Java 数据库连接
spring boot 参数的过滤注解与实战
在Spring Boot应用中,对于入参的过滤,通常会涉及到对Web层的数据验证和处理。Spring Boot借助Spring框架提供了强大的验证框架支持,主要基于JSR-303/JSR-380(Bean Validation API)规范,以及Spring自身的@Valid或@Validated注解来实现请求参数的验证。以下是一些常见的使用案例来展示如何对参数进行过滤和验证。
24 1
|
30天前
|
Java Spring 容器
【二十二】springboot整合拦截器实战并对比过滤器
【二十二】springboot整合拦截器实战并对比过滤器
28 0
|
22天前
|
NoSQL Java Redis
小白版的springboot中集成mqtt服务(超级无敌详细),实现不了掐我头!!!
小白版的springboot中集成mqtt服务(超级无敌详细),实现不了掐我头!!!
204 1
|
14天前
|
安全 Java 数据安全/隐私保护
【深入浅出Spring原理及实战】「EL表达式开发系列」深入解析SpringEL表达式理论详解与实际应用
【深入浅出Spring原理及实战】「EL表达式开发系列」深入解析SpringEL表达式理论详解与实际应用
39 1
|
14天前
|
消息中间件 存储 安全
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
25 0
|
25天前
|
消息中间件 Java
springboot整合消息队列——RabbitMQ
springboot整合消息队列——RabbitMQ
71 0
|
14天前
|
消息中间件 存储 Kafka
【深入浅出 RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿一下RocketMQ和Kafka索引设计原理和方案
【深入浅出 RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿一下RocketMQ和Kafka索引设计原理和方案
40 1
|
14天前
|
Prometheus 监控 Cloud Native
Spring Boot 应用可视化监控
Spring Boot 应用可视化监控
12 0
|
20天前
|
存储 缓存 安全
Spring Boot从入门到实战
本课程从SpringBoot的最基础的安装、配置开始到SpringBoot的日志管理、Web业务开发、数据存储、数据缓存,安全控制及相关企业级应用,全程案例贯穿,案例每一步的都会讲解实现思路,全程手敲代码实现。让你不仅能够掌SpringBoot的应用,还能了解背后的原理,学习完本课程后,能够让你动手独立完成一个中小型的SpringBoot Web应用开发。
17 1
Spring Boot从入门到实战
|
28天前
|
Cloud Native Java 开发者
Spring Boot 4.0:构建云原生Java应用的前沿工具
Spring Boot 4.0:构建云原生Java应用的前沿工具