当前位置：首页 > news >正文

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

news 来源：原创 2024/5/10 14:09:38

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

在这里插入图片描述

搭建消息时光机：深入探究RabbitMQ_recent_history_exchange在Spring Boot中的应用

- 引言
- 前言
- 第一：开启插件支持
- 第二：springboot整合
- 第三：效果展示
- - 交换机属性展示
  - 功能实现展示
- 第四：使用场景
- - 使用场景：
- 总结：
- 结语

引言

🌺：docker构建rabbitmq并配置延迟队列插件

⏳：Spring Boot中的RabbitMQ死信队列魔法：从异常到延迟，一网打尽【RabbitMQ实战一】

ℹ️：RabbitMQ插件详解：rabbitmq_recent_history_exchange【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 插件的实际使用场景通常涉及到需要在消费者订阅某个交换机时获取历史消息的情况。这在一些特定的应用场景中是非常有用的，以下是一些可能的使用场景和总结：

使用场景：

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