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

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核心模型

Binding
Producer
Exchange
Queue
Consumer

二、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)触发条件

  1. 消息被消费者拒绝(basic.reject/nack)且不重新入队
  2. 消息TTL过期
  3. 队列达到最大长度限制

3.2 延迟队列实现原理

TTL过期
主队列
死信交换器
实际消费队列

四、订单超时实战案例

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);}}
}

五、关键注意事项

  1. TTL设置策略

    • 队列级别TTL:适用于统一过期时间的场景
    • 消息级别TTL:需注意队列中存在不同TTL时的处理策略
    • 两者同时设置时,取较小值
  2. 消息阻塞问题

    • 使用单独的延迟队列处理不同延迟时间需求
    • 避免在同一个队列中混合不同TTL的消息
  3. 消息可靠性保障

    // 开启生产者确认
    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);}
    }
    

六、扩展应用场景

  1. 定时任务调度(替代轮询方案)
  2. 重试机制实现(通过TTL设置重试间隔)
  3. 分布式事务最终一致性保障
  4. 智能家居设备状态延迟同步

总结

本文深入剖析了RabbitMQ在Spring Boot中的整合应用,通过完整的订单超时案例演示了延迟队列与死信队列的实现方案。建议在实际开发中结合具体业务场景进行参数调优,并配合监控系统实现消息的可观测性。对于更复杂的延迟需求,可考虑RabbitMQ官方提供的延迟消息插件(rabbitmq-delayed-message-exchange)。

相关文章:

22、《Spring Boot消息队列:RabbitMQ延迟队列与死信队列深度解析》

Spring Boot消息队列实战&#xff1a;RabbitMQ延迟队列与死信队列深度解析 引言 在现代分布式系统中&#xff0c;消息队列承担着解耦、削峰填谷和异步通信的重要职责。本文将深入探讨Spring Boot与RabbitMQ的整合应用&#xff0c;重点解析延迟队列与死信队列的实现原理及实战…...

linux 命令+相关配置记录(持续更新...)

linux 命令记录相关配置记录 磁盘切换 cd D&#xff1a;#这里表示切换到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) 模型&#xff0c;然后使用 Docker Compose 一键部署了 Dify 社区版平台。 LLM大语言模型私有化部署-使用Dify与Qwen2.5打造专属知识库&#xff1a;在 Dify 平台上&#xff0c;通过普通编排的方式&#xff0c;创建了基于…...

Windows 图形显示驱动开发-WDDM 3.2-自动显示切换(二)

在 GPU0 和 GPU1 之间共享数据 在某些情况下&#xff0c;也许可以在某些时候带来更好的用户体验&#xff1a; GPU0 和 GPU1 来自同一个 IHV。GPU0 可以将操作系统无法解读的显示配置相关信息传递给 GPU1。 数据 Blob 由 GUID 描述&#xff0c;如果 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 网络安全应急响应概念 网络安全应急响应是指为应对网络安全事件&#xff0c;相关人员或组织机构对网络安全事件进行监测、预警、分析、响应和恢复等工作。 17.2.3 网络安…...

使用 DeepSeek + OmniParser v2 + UIAutomation 实现 GUI 应用自动化测试的探索

一、背景 UI 自动化测试一直是软件开发中的难点之一。尽管有许多工具和技术(如 Selenium、Appium 等)可以帮助我们实现自动化测试,但这些工具在面对复杂的 UI 变化时,往往需要大量的维护工作。随着人工智能技术的进步,尤其是自然语言处理(NLP)和计算机视觉(CV)技术的…...

Spring Security面试题

Spring Security面试题 基础概念 Q1: Spring Security的核心功能有哪些&#xff1f; 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. 核心技术创新&#xff08;1&#xff09;集群协同控制技术&#xff08;2&#xff09;感知与能源系统升级 2. 行业应用落地&#xff08;1&#xff09;智慧城市与安防&#xff08;2&#xff09;应急救援&#xff08;…...

【亲测有效】百度Ueditor富文本编辑器添加插入视频、视频不显示、和插入视频后二次编辑视频标签不显示,显示成img标签,二次保存视频被替换问题,解决方案

【亲测有效】项目使用百度Ueditor富文本编辑器上传视频相关操作问题 1.百度Ueditor富文本编辑器添加插入视频、视频不显示 2.百度Ueditor富文本编辑器插入视频后二次编辑视频标签不显示&#xff0c;在编辑器内显示成img标签&#xff0c;二次保存视频被替换问题 问题1&#xff1…...

ubuntu windows双系统踩坑

我有个台式机&#xff0c;先安装的ubuntu&#xff0c;本来想专门用来做开发&#xff0c;后面儿子长大了&#xff0c;给他看了一下星际争霸、魔兽争霸&#xff0c;立马就迷上了。还有一台windows的笔记本&#xff0c;想着可以和他联局域网一起玩&#xff0c;在ubuntu上用wine跑魔…...

嵌入式八股文(五)硬件电路篇

一、名词概念 1. 整流和逆变 &#xff08;1&#xff09;整流&#xff1a;整流是将交流电&#xff08;AC&#xff09;转变为直流电&#xff08;DC&#xff09;。常见的整流电路包括单向整流&#xff08;二极管&#xff09;、桥式整流等。 半波整流&#xff1a;只使用交流电的正…...

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):图像直方图

在图像处理中&#xff0c;直方图是一种非常重要的工具&#xff0c;它可以帮助我们了解图像的像素分布情况。通过分析图像的直方图&#xff0c;我们可以进行图像增强、对比度调整、图像分割等操作。 1 什么是图像直方图&#xff1f; 图像直方图是图像像素强度分布的图形表示&am…...

力扣LeetCode:1656 设计有序流

题目&#xff1a; 有 n 个 (id, value) 对&#xff0c;其中 id 是 1 到 n 之间的一个整数&#xff0c;value 是一个字符串。不存在 id 相同的两个 (id, value) 对。 设计一个流&#xff0c;以 任意 顺序获取 n 个 (id, value) 对&#xff0c;并在多次调用时 按 id 递增的顺序…...

NGINX配置TCP负载均衡

前言 之前本人做项目需要用到nginx的tcp负载均衡&#xff0c;这里是当时配置做的笔记&#xff1b;欢迎收藏 关注&#xff0c;本人将会持续更新 文章目录 配置Nginx的负载均衡 配置Nginx的负载均衡 nginx编译安装需要先安装pcre、openssl、zlib等库&#xff0c;也可以直接编译…...

vm和centos

安装 VMware Workstation Pro 1. 下载 VMware Workstation Pro 访问 VMware 官方网站&#xff08;https://www.vmware.com/cn/products/workstation-pro/workstation-pro-evaluation.html &#xff09;&#xff0c;在该页面中点击 “立即下载” 按钮&#xff0c;选择适合你操作…...

百度网盘下载加速终极指南:如何用PDown免费突破限速限制

百度网盘下载加速终极指南&#xff1a;如何用PDown免费突破限速限制 【免费下载链接】pdown 百度网盘下载器&#xff0c;2020百度网盘高速下载 项目地址: https://gitcode.com/gh_mirrors/pd/pdown 你是否曾经为百度网盘的下载速度而烦恼&#xff1f;当你急需下载一个重…...

rust 1.95.0 最新版发布:语言特性、编译器、平台支持、标准库、Rustdoc 与兼容性变更全解析

rust 1.95.0 最新版发布&#xff1a;语言特性、编译器、平台支持、标准库、Rustdoc 与兼容性变更全解析 2026年4月16日&#xff0c;Rust 1.95.0 正式发布。作为一次重要版本更新&#xff0c;这一版在语言层、编译器、平台支持、标准库、Rustdoc 以及兼容性方面都带来了相当丰富…...

终极视频下载助手:一键抓取网页视频的完整解决方案

终极视频下载助手&#xff1a;一键抓取网页视频的完整解决方案 【免费下载链接】VideoDownloadHelper Chrome Extension to Help Download Video for Some Video Sites. 项目地址: https://gitcode.com/gh_mirrors/vi/VideoDownloadHelper 还在为无法下载网页视频而烦恼…...

45+图像工具+本地AI,这个自托管神器太香了

处理图片时&#xff0c;总是需要打开多个工具&#xff1f;在线工具担心隐私&#xff0c;本地工具功能不全&#xff1f;有了这个自托管的图像处理工具&#xff0c;这些问题都能解决。它把45种图像工具、本地AI功能和批量处理能力打包到一个Docker容器里&#xff0c;你的图片永远…...

Zotero-SciHub插件:一键获取学术文献的终极解决方案

Zotero-SciHub插件&#xff1a;一键获取学术文献的终极解决方案 【免费下载链接】zotero-scihub A plugin that will automatically download PDFs of zotero items from sci-hub 项目地址: https://gitcode.com/gh_mirrors/zo/zotero-scihub 在学术研究的世界里&#x…...

告别重复劳动:5分钟掌握Python剪映自动化,视频剪辑效率提升10倍!

告别重复劳动&#xff1a;5分钟掌握Python剪映自动化&#xff0c;视频剪辑效率提升10倍&#xff01; 【免费下载链接】JianYingApi Third Party JianYing Api. 第三方剪映Api 项目地址: https://gitcode.com/gh_mirrors/ji/JianYingApi 你是否厌倦了每天重复同样的视频剪…...

交通灯控制电路里的‘幽灵’:一次完整的竞争与冒险现象排查实录(附波形分析)

交通灯控制电路里的‘幽灵’&#xff1a;一次完整的竞争与冒险现象排查实录&#xff08;附波形分析&#xff09; 数字电路设计中最令人头疼的问题之一&#xff0c;莫过于那些看似随机出现的异常现象。上周在实验室调试一个交通灯控制电路时&#xff0c;我们就遇到了这样一个&qu…...

ECharts地图实战:从自定义点聚合到交互式图例的完整视觉方案

1. ECharts地图基础配置与数据准备 第一次接触ECharts地图开发时&#xff0c;我被它强大的可视化能力震撼到了。记得当时接手一个区域门店分布监控项目&#xff0c;需要在地图上展示上千个点位&#xff0c;如果直接用散点图展示&#xff0c;整个地图就会变成密密麻麻的"芝…...

[Android] 网易云音乐 v6.2.81 车机官方定制版

[Android] 网易云音乐 v6.2.81 车机官方定制版 链接&#xff1a;https://pan.xunlei.com/s/VOqUjtKLwmWbrMNeegZ4Ir-eA1?pwddnap# 极简轻快&#xff0c;告别卡顿&#xff0c;它在任何设备上都运行如飞。 零广告零打扰&#xff1a;在这里&#xff0c;你的眼睛和耳朵只属于音乐…...

Stable Yogi 模型Visio流程图绘制:AI应用系统架构设计与部署流程可视化

Stable Yogi 模型Visio流程图绘制&#xff1a;AI应用系统架构设计与部署流程可视化 你是不是也遇到过这种情况&#xff1f;和团队讨论一个AI项目的技术方案&#xff0c;讲了半天&#xff0c;大家还是对系统怎么跑起来、各个模块怎么交互一头雾水。或者写技术文档时&#xff0c…...