22、《Spring Boot消息队列:RabbitMQ延迟队列与死信队列深度解析》
Spring Boot消息队列实战:RabbitMQ延迟队列与死信队列深度解析
引言
在现代分布式系统中,消息队列承担着解耦、削峰填谷和异步通信的重要职责。本文将深入探讨Spring Boot与RabbitMQ的整合应用,重点解析延迟队列与死信队列的实现原理及实战应用。通过完整的代码示例和配置讲解,帮助开发者掌握构建可靠消息系统的核心技能。
一、消息队列核心基础
1.1 消息队列核心概念
- 生产者(Producer):消息的创建和发送者
- 消费者(Consumer):消息的接收和处理者
- Broker:消息代理服务器(RabbitMQ实例)
- Exchange:消息路由规则定义(Direct/Topic/Fanout/Headers)
- Queue:消息存储的队列容器
- Binding:交换器与队列的绑定关系
1.2 RabbitMQ核心模型
二、Spring Boot整合RabbitMQ
2.1 环境配置
<!-- pom.xml -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
# application.yml
spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest
2.2 基础消息收发实现
生产者配置
@Configuration
public class RabbitConfig {@Beanpublic Queue demoQueue() {return new Queue("demo.queue", true); // 持久化队列}
}@Service
public class MessageSender {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message) {rabbitTemplate.convertAndSend("demo.queue", message);}
}
消费者实现
@Component
@RabbitListener(queues = "demo.queue")
public class MessageReceiver {@RabbitHandlerpublic void process(String message) {System.out.println("Received: " + message);}
}
三、死信队列与延迟队列原理
3.1 死信队列(DLX)触发条件
- 消息被消费者拒绝(basic.reject/nack)且不重新入队
- 消息TTL过期
- 队列达到最大长度限制
3.2 延迟队列实现原理
四、订单超时实战案例
4.1 队列配置
@Configuration
public class OrderQueueConfig {// 死信交换器@Beanpublic DirectExchange orderDLX() {return new DirectExchange("order.dlx.exchange");}// 实际消费队列@Beanpublic Queue orderProcessQueue() {return new Queue("order.process.queue");}// 延迟队列(订单超时队列)@Beanpublic Queue orderDelayQueue() {Map<String, Object> args = new HashMap<>();args.put("x-dead-letter-exchange", "order.dlx.exchange");args.put("x-message-ttl", 60000); // 1分钟超时args.put("x-dead-letter-routing-key", "order.process");return new Queue("order.delay.queue", true, false, false, args);}@Beanpublic Binding binding() {return BindingBuilder.bind(orderProcessQueue()).to(orderDLX()).with("order.process");}
}
4.2 订单服务实现
@Service
public class OrderService {@Autowiredprivate RabbitTemplate rabbitTemplate;public void createOrder(Order order) {// 1. 保存订单到数据库orderRepository.save(order);// 2. 发送延迟消息rabbitTemplate.convertAndSend("", // 默认直接发送到队列"order.delay.queue",order.getId(),message -> {message.getMessageProperties().setExpiration("60000"); // 单独设置消息TTLreturn message;});}
}
4.3 超时处理器
@Component
@RabbitListener(queues = "order.process.queue")
public class OrderTimeoutProcessor {@RabbitHandlerpublic void handleOrderTimeout(String orderId) {Order order = orderRepository.findById(orderId);if (order.getStatus() == OrderStatus.UNPAID) {order.setStatus(OrderStatus.CANCELED);orderRepository.save(order);log.warn("订单超时取消:{}", orderId);}}
}
五、关键注意事项
-
TTL设置策略
- 队列级别TTL:适用于统一过期时间的场景
- 消息级别TTL:需注意队列中存在不同TTL时的处理策略
- 两者同时设置时,取较小值
-
消息阻塞问题
- 使用单独的延迟队列处理不同延迟时间需求
- 避免在同一个队列中混合不同TTL的消息
-
消息可靠性保障
// 开启生产者确认 spring.rabbitmq.publisher-confirm-type=correlated // 开启消费者手动ACK @RabbitListener(queues = "queue") public void process(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) {try {// 业务处理channel.basicAck(tag, false);} catch (Exception e) {channel.basicNack(tag, false, true);} }
六、扩展应用场景
- 定时任务调度(替代轮询方案)
- 重试机制实现(通过TTL设置重试间隔)
- 分布式事务最终一致性保障
- 智能家居设备状态延迟同步
总结
本文深入剖析了RabbitMQ在Spring Boot中的整合应用,通过完整的订单超时案例演示了延迟队列与死信队列的实现方案。建议在实际开发中结合具体业务场景进行参数调优,并配合监控系统实现消息的可观测性。对于更复杂的延迟需求,可考虑RabbitMQ官方提供的延迟消息插件(rabbitmq-delayed-message-exchange)。
相关文章:
22、《Spring Boot消息队列:RabbitMQ延迟队列与死信队列深度解析》
Spring Boot消息队列实战:RabbitMQ延迟队列与死信队列深度解析 引言 在现代分布式系统中,消息队列承担着解耦、削峰填谷和异步通信的重要职责。本文将深入探讨Spring Boot与RabbitMQ的整合应用,重点解析延迟队列与死信队列的实现原理及实战…...
linux 命令+相关配置记录(持续更新...)
linux 命令记录相关配置记录 磁盘切换 cd D:#这里表示切换到D盘查看wsl 安装的linux 子系统 wsl --list -vwsl 卸载 linux 子系统 wsl --unregister -xxx # xxx 表示子系统的名字备份Linux 子系统 导出 wsl --export xxx yyy # xxx 表示子系统的名字 yyy 表示压…...
ssh工具
文章目录 ssh简介ssh远程连接Linux下使用SSH安装安装ssh服务端安装ssh客户端 命令启动重启查看ssh的状态 ssh 配置文件ssh连接地址 配置文件基本配置注意通配符心跳和密钥ssh的Include跳板 ProxyJump内网穿透 Windows下使用SSH安装ssh 配置文件ssh连接地址 配置文件 ssh简介 s…...
LLM大语言模型私有化部署-使用Dify的工作流编排打造专属AI诗词数据分析师
背景 前面的文章通过 Ollama 私有化部署了 Qwen2.5 (7B) 模型,然后使用 Docker Compose 一键部署了 Dify 社区版平台。 LLM大语言模型私有化部署-使用Dify与Qwen2.5打造专属知识库:在 Dify 平台上,通过普通编排的方式,创建了基于…...
Windows 图形显示驱动开发-WDDM 3.2-自动显示切换(二)
在 GPU0 和 GPU1 之间共享数据 在某些情况下,也许可以在某些时候带来更好的用户体验: GPU0 和 GPU1 来自同一个 IHV。GPU0 可以将操作系统无法解读的显示配置相关信息传递给 GPU1。 数据 Blob 由 GUID 描述,如果 GPU1 的驱动程序能理解数据…...
基于CentOS7安装kubesphere和Kubernetes并接入外部ES收集日志
一、修改所有节点主机名 主节点就修改成master hostnamectl set-hostname master 然后输入bash刷新当前主机名 工作节点1就修改成node1 hostnamectl set-hostname node1 然后输入bash刷新当前主机名 二、全部节点安装依赖并同步时间 yum -y install socat conntrack ebta…...
软考教材重点内容 信息安全工程师 第17章 网络安全应急响应技术原理与应用
17.1 网络安全应急响应概述 网络安全应急响应是针对潜在发生的网络安全事件而采取的网络安全措施。 17.1.1 网络安全应急响应概念 网络安全应急响应是指为应对网络安全事件,相关人员或组织机构对网络安全事件进行监测、预警、分析、响应和恢复等工作。 17.2.3 网络安…...
使用 DeepSeek + OmniParser v2 + UIAutomation 实现 GUI 应用自动化测试的探索
一、背景 UI 自动化测试一直是软件开发中的难点之一。尽管有许多工具和技术(如 Selenium、Appium 等)可以帮助我们实现自动化测试,但这些工具在面对复杂的 UI 变化时,往往需要大量的维护工作。随着人工智能技术的进步,尤其是自然语言处理(NLP)和计算机视觉(CV)技术的…...
Spring Security面试题
Spring Security面试题 基础概念 Q1: Spring Security的核心功能有哪些? public class SecurityBasicDemo {// 1. 基本配置public class SecurityConfigExample {public void configDemo() {ConfigurationEnableWebSecuritypublic class SecurityConfig extends …...
从零开始构建基于DeepSeek的智能客服系统
在当今的数字化时代,智能客服系统已经成为企业与客户沟通的重要桥梁。它不仅能够提升客户体验,还能大幅降低企业的运营成本。本文将带领你从零开始,使用PHP和DeepSeek技术构建一个功能强大的智能客服系统。我们将通过具体的案例和代码示例,深入探讨如何实现这一目标。 1. …...
Linux故障排查和性能优化面试题及参考答案
目录 如何查看 Linux 系统中的 CPU、内存、磁盘等资源使用情况? 什么是 Linux 中的负载(Load Average)?如何解读它? 如何通过 top 和 htop 命令监控系统性能? 如何使用 mpstat 命令来查看 CPU 的利用情况? 如何分析系统 CPU 瓶颈? 如何分析 CPU 瓶颈?如何优化 CP…...
【无人集群系列---大疆无人集群技术进展、技术路线与未来发展方向】
大疆无人集群技术进展、技术路线与未来发展方向 一、技术进展1. 核心技术创新(1)集群协同控制技术(2)感知与能源系统升级 2. 行业应用落地(1)智慧城市与安防(2)应急救援(…...
【亲测有效】百度Ueditor富文本编辑器添加插入视频、视频不显示、和插入视频后二次编辑视频标签不显示,显示成img标签,二次保存视频被替换问题,解决方案
【亲测有效】项目使用百度Ueditor富文本编辑器上传视频相关操作问题 1.百度Ueditor富文本编辑器添加插入视频、视频不显示 2.百度Ueditor富文本编辑器插入视频后二次编辑视频标签不显示,在编辑器内显示成img标签,二次保存视频被替换问题 问题1࿱…...
ubuntu windows双系统踩坑
我有个台式机,先安装的ubuntu,本来想专门用来做开发,后面儿子长大了,给他看了一下星际争霸、魔兽争霸,立马就迷上了。还有一台windows的笔记本,想着可以和他联局域网一起玩,在ubuntu上用wine跑魔…...
嵌入式八股文(五)硬件电路篇
一、名词概念 1. 整流和逆变 (1)整流:整流是将交流电(AC)转变为直流电(DC)。常见的整流电路包括单向整流(二极管)、桥式整流等。 半波整流:只使用交流电的正…...
flink使用demo
1、添加不同数据源 package com.baidu.keyue.deepsight.memory.test;import com.baidu.keyue.deepsight.memory.WordCount; import com.baidu.keyue.deepsight.memory.WordCountData; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.api.…...
OpenCV(8):图像直方图
在图像处理中,直方图是一种非常重要的工具,它可以帮助我们了解图像的像素分布情况。通过分析图像的直方图,我们可以进行图像增强、对比度调整、图像分割等操作。 1 什么是图像直方图? 图像直方图是图像像素强度分布的图形表示&am…...
力扣LeetCode:1656 设计有序流
题目: 有 n 个 (id, value) 对,其中 id 是 1 到 n 之间的一个整数,value 是一个字符串。不存在 id 相同的两个 (id, value) 对。 设计一个流,以 任意 顺序获取 n 个 (id, value) 对,并在多次调用时 按 id 递增的顺序…...
NGINX配置TCP负载均衡
前言 之前本人做项目需要用到nginx的tcp负载均衡,这里是当时配置做的笔记;欢迎收藏 关注,本人将会持续更新 文章目录 配置Nginx的负载均衡 配置Nginx的负载均衡 nginx编译安装需要先安装pcre、openssl、zlib等库,也可以直接编译…...
vm和centos
安装 VMware Workstation Pro 1. 下载 VMware Workstation Pro 访问 VMware 官方网站(https://www.vmware.com/cn/products/workstation-pro/workstation-pro-evaluation.html ),在该页面中点击 “立即下载” 按钮,选择适合你操作…...
ngx_set_environment
1 定义 ngx_set_environment 函数 定义在 ./nginx-1.24.0/src/core/nginx.cchar ** ngx_set_environment(ngx_cycle_t *cycle, ngx_uint_t *last) {char **p, **env;ngx_str_t *var;ngx_uint_t i, n;ngx_core_conf_t *ccf;ngx_pool_…...
告别数据线?实测用手机Termux+网络串口给ESP32无线OTA升级
手机Termux网络串口实现ESP32无线OTA升级全攻略 想象一下这样的场景:你正坐在咖啡馆里,突然灵感迸发想修改ESP32设备的固件。传统方式需要翻出数据线、连接电脑、打开开发环境...但现在,只需掏出手机就能完成从代码修改到固件烧录的全流程。这…...
抖音批量下载神器:5分钟完成视频素材采集的终极指南
抖音批量下载神器:5分钟完成视频素材采集的终极指南 【免费下载链接】douyin-downloader A practical Douyin downloader for both single-item and profile batch downloads, with progress display, retries, SQLite deduplication, and browser fallback support…...
Pixel Script Temple 数据可视化:Matlab风格图表像素化生成应用
Pixel Script Temple 数据可视化:Matlab风格图表像素化生成应用 1. 引言:当科学数据遇上像素艺术 科研工作者经常面临一个两难选择:一方面需要精确呈现复杂数据,另一方面又希望图表能吸引读者注意。传统Matlab生成的图表虽然专业…...
3步解决:RTL8852BE Wi-Fi 6网卡Linux驱动完全指南
3步解决:RTL8852BE Wi-Fi 6网卡Linux驱动完全指南 【免费下载链接】rtl8852be Realtek Linux WLAN Driver for RTL8852BE 项目地址: https://gitcode.com/gh_mirrors/rt/rtl8852be 当我们为Linux系统配备RTL8852BE Wi-Fi 6无线网卡时,常会遇到驱动…...
CefFlashBrowser完整指南:如何在2024年完美运行Flash游戏和内容
CefFlashBrowser完整指南:如何在2024年完美运行Flash游戏和内容 【免费下载链接】CefFlashBrowser Flash浏览器 / Flash Browser 项目地址: https://gitcode.com/gh_mirrors/ce/CefFlashBrowser 还在为Flash内容无法在现代浏览器中播放而烦恼吗?C…...
揭秘SITS2026核心结论:3类开发者正被AI代码工具淘汰,你属于哪一类?
第一章:SITS2026总结:智能代码生成改变开发范式 2026奇点智能技术大会(https://ml-summit.org) 在SITS2026大会上,智能代码生成技术已从辅助工具跃升为重构软件生命周期的核心引擎。主流模型展现出跨语言语义理解、上下文感知补全与可验证契…...
Subtitle Edit视频字幕编辑软件:开源字幕编辑软件解决时间轴调整与格式转换难题
在制作或修改视频字幕时,你是否遇到过这些问题:从网上下载的字幕与视频不同步,需要整体提前或推迟几秒;字幕文件是SRT格式,但播放器只支持ASS格式,找不到合适的转换工具;或者字幕中有错别字、时间重叠,手动检查费时费力。这些问题的核心,是需要一款专业的字幕编辑软件…...
python打包成 .so的实现步骤
为什么要将python打包成so文件Python是一种面向对象的解释型计算机程序设计语言,具有丰富和强大的库,使用其开发产品快速高效。python的解释特性是将py编译为独有的二进制编码pyc文件,然后对pyc中的指令进行解释执行,但是pyc的反编…...
Qwen3-14B高性能推理部署教程:vLLM加速+显存调度策略深度解析
Qwen3-14B高性能推理部署教程:vLLM加速显存调度策略深度解析 1. 环境准备与快速部署 Qwen3-14B作为通义千问最新发布的大语言模型,在14B参数规模下展现出惊人的推理和生成能力。本文将手把手教你如何在RTX 4090D 24GB显存环境下高效部署这个模型。 1.…...
