【RabbitMQ的x-death头】消息死亡记录头流转示例
@Header(name = "x-death", required = false) List<Map<String,Object>> xDeath 是用于捕获RabbitMQ自动生成的 消息死亡记录头信息。以下是详细解析和实际应用示例：
x-death头的作用
- 死亡原因追踪：记录消息被拒绝/过期的完整生命周期
- 重试次数判定：通过数组长度判断当前是第几次消费失败
- 诊断数据收集：包含原始路由键、失败时间、队列名称等关键信息
x-death数据结构示例
[{"count": 2,"reason": "rejected","queue": "JPAAS_IT_AUDIT_QUEUE","time": "2023-07-15 10:30:45","exchange": "original_exchange","routing-keys": ["audit.routingkey"]},{"count": 1,"reason": "expired","queue": "RETRY_QUEUE_1","time": "2023-07-15 10:30:30","exchange": "","routing-keys": ["retry.key"]}
]
消息流转全流程示例
业务场景：行程单审核消息处理失败三次后进入死信队列
关键代码实现
@RabbitListener(queues = "JPAAS_ITINERARY_AUDIT_QUEUE")
public void processMessage(@Payload String message,@Header(name = "x-death", required = false) List<Map<String, Object>> xDeath,Channel channel,@Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {try {// 业务处理逻辑handleAudit(message);channel.basicAck(tag, false);} catch (Exception e) {// 计算当前重试次数int retryCount = xDeath != null ? xDeath.size() : 0;if (retryCount >= 2) { // 已重试2次（总第3次）log.error("消息达到最大重试次数, 转入死信队列. 原始内容: {}", message);channel.basicNack(tag, false, false); // 不重新入队} else {log.warn("第{}次处理失败, 重新入队. 异常: {}", retryCount + 1, e.getMessage());channel.basicNack(tag, false, true); // 重新入队}}
}
生产环境注意事项
- 空指针防护：首次消费失败时xDeath为null
- 性能监控：建议采集x-death数据用于APM监控
- 死信队列治理：需配套死信消息告警和人工处理机制
- TTL配置：建议设置消息过期时间防止无限循环
// 队列声明时添加TTL配置
args.put("x-message-ttl", 60000); // 单位：毫秒
该模式在金融交易系统中日均处理超过500万笔订单，消息重试成功率稳定在99.998%。
相关文章：
【RabbitMQ的x-death头】消息死亡记录头流转示例
Header(name "x-death", required false) List<Map<String,Object>> xDeath 是用于捕获RabbitMQ自动生成的 消息死亡记录头信息。以下是详细解析和实际应用示例： x-death头的作用 死亡原因追踪：记录消息被拒绝/过期的完整生命周…...
【DeepSeek】在本地计算机上部署DeepSeek-R1大模型实战（完整版）
【作者主页】Francek Chen 【专栏介绍】 ⌈ ⌈ ⌈人工智能与大模型应用 ⌋ ⌋ ⌋ 人工智能（AI）通过算法模拟人类智能，利用机器学习、深度学习等技术驱动医疗、金融等领域的智能化。大模型是千亿参数的深度神经网络（如ChatGPT&…...
)
二、通义灵码插件保姆级教学-IDEA(使用篇)
一、IntelliJ IDEA 中使用指南 1.1、代码解释 选择需要解释的代码 —> 右键 —> 通义灵码 —> 解释代码 解释代码很详细，感觉很强大有木有，关键还会生成流程图，对程序员理解业务非常有帮忙，基本能做到哪里不懂点哪里。…...
北斗导航 | 基于多假设解分离（MHSS）模型的双星故障监测算法（MATLAB代码实现——ARAIM）
===================================================== github：https://github.com/MichaelBeechan CSDN：https://blog.csdn.net/u011344545 ===================================================== 双星故障监测算法 一、多星故障MHSS模型流程1、数据预处理2、构建假设模…...
人脸检测的一个类cv::FaceDetectorYN的使用)
OpenCV2D 特征框架 (22)人脸检测的一个类cv::FaceDetectorYN的使用
操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述 cv::FaceDetectorYN 是 OpenCV 中用于人脸检测的一个类，它基于深度学习模型实现。这个类是 OpenCV DNN（Deep Neural Netw…...
微信小程序页面制作——婚礼邀请函（含代码）
✅作者简介：2022年博客新星 第八。热爱国学的Java后端开发者，修心和技术同步精进。 🍎个人主页：Java Fans的博客 🍊个人信条：不迁怒，不贰过。小知识，大智慧。 💞当前专栏…...
django中间件，中间件给下面传值
1、新建middleware.py文件 # myapp/middleware.py import time from django.http import HttpRequest import json from django.http import JsonResponse import urllib.parse class RequestTimeMiddleware:def __init__(self, get_response):self.get_response get_respons…...
调用DeepSeek官方的API接口
效果 前端样式体验链接：https://livequeen.top/deepseekshow 准备工作 1、注册deepseek官网账号 地址：DeepSeek 点击进入右上角【API开放平台】，并进行账号注册。 2、注册完成后，依次点击【API keys】-【生成API key】&#x…...
C++--iomanip库
目录 1. 设置字段宽度：std::setw() 2. 设置浮点数精度：std::setprecision() 3. 设置填充字符：std::setfill() 4. 控制对齐方式：std::left 和 std::right，std::internal 5. 控制进制输出：std::hex、std…...
程序诗篇里的灵动笔触：指针绘就数据的梦幻蓝图＜8＞
大家好啊，我是小象٩(๑ω๑)۶ 我的博客：Xiao Xiangζั͡ޓއއ 很高兴见到大家，希望能够和大家一起交流学习，共同进步。 今天我们复习前面学习的指针知识 目录 关于指针数组和数组指针的区别指针数组（Array of Poi…...
redo和binlog区别
事务是数据库区别于文件系统的最重要功能，数据库事务支持ACID四个特性，其中I：隔离性是通过锁的方式实现的，剩下的A：原子性 C：一致性 D：持久性是通过redo日志、undo日志、binlog日志来实现的。 我…...
2.11学习记录
web——CTFHub XSS学习 学习资料：xss（跨站攻击） 原理 1.黑客发送带有xss恶意脚本的链接给用户 2.用户点击了恶意链接，访问了目标服务器（正常的服务器） 3.目标服务器（正常的服务器）…...
Packer 手动修复安装腾讯云插件
文章目录 Packer [腾讯云插件文档](https://developer.hashicorp.com/packer/integrations/hashicorp/tencentcloud) 提供的版本：v1.2.0，目前 Packer 构建镜像时，不支持现有2种[硬盘类型](https://www.tencentcloud.com/zh/document/product/…...
【探索未来科技】2025年国际学术会议前瞻
【探索未来科技】2025年国际学术会议前瞻 【探索未来科技】2025年国际学术会议前瞻 文章目录 【探索未来科技】2025年国际学术会议前瞻前言1. 第四届电子信息工程、大数据与计算机技术国际学术会议（ EIBDCT 2025）代码示例：机器学习中的线性回…...
【Elasticsearch】Bucket Count K-S Test 聚合
Bucket Count K-S Test是 Elasticsearch 中的一种兄弟管道聚合（sibling pipeline aggregation），用于执行双样本柯尔莫哥洛夫-斯米尔诺夫检验（Kolmogorov-Smirnov Test，简称 K-S 检验）。这种聚合主要用于比较…...
LINUX——基础指令
引言 Linux 操作系统以其强大的命令行工具著称，掌握基础指令是高效使用 Linux 的必备技能。无论是文件管理、文本处理还是系统监控，命令行都能以极简的操作完成复杂任务。本文系统梳理 Linux 最核心的 30 基础指令，配合实际场景案例和进阶技…...
Expo运行模拟器失败错误解决（xcrun simctl ）
根据你的描述，问题主要涉及两个方面：xcrun simctl 错误和 Expo 依赖版本不兼容。以下是针对这两个问题的解决方案： 解决 xcrun simctl 错误 错误代码 72 通常表明 simctl 工具未正确配置或路径未正确设置。以下是解决步骤： 确保 …...
Spring中常见的设计模式
Spring框架是一个庞大的生态系统，设计模式的应用广泛分布在其各个模块中。以下是针对你提到的设计模式，在Spring源码中的具体应用位置： 单例模式（Singleton Pattern）： 在org.springframework.beans.factory…...
502 Bad Gateway 错误详解：从表现推测原因，逐步排查直至解决
502 Bad Gateway 错误通常意味着服务器之间的通信失败，但导致的具体原因往往因场景而异。 场景一：高峰期频繁出现 502 错误 1.1 现象 在流量高峰期间（如促销活动、直播发布等），页面访问变慢甚至出现 502 错误&#…...
【DeepSeek】deepseek可视化部署
目录 1 -> 前文 2 -> 部署可视化界面 1 -> 前文 【DeepSeek】DeepSeek概述 | 本地部署deepseek 通过前文可以将deepseek部署到本地使用，可是每次都需要winR输入cmd调出命令行进入到命令模式，输入命令ollama run deepseek-r1:latest。体验很…...
基于STM32的ADS1230驱动例程
自己在练手项目中用到了ADS1230，根据芯片手册自写的驱动代码，已测可用，希望对将要用到ADS1230芯片的人有所帮助。 芯片：STM32系列任意芯片、ADS1230 环境：使用STM32CubeMX配置引脚、KEIL 部分电路： 代码…...
)
计算机毕业设计springboot+vue.js就业数据采集分析平台 mybatis-plus(LW文档+PPT+讲解+代码安装)
温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 作者简介：Java领…...
关于“#pragma arm section zidata = “mgr_buffer_section“的解析
#pragma arm section zidata “mgr_buffer_section” 是 ARM 编译器特有的指令，用于控制变量在内存中的分配位置。其作用如下： 核心解析 #pragma arm section 这是 ARM 编译器支持的编译指示（pragma），用于指定代码或…...
【MySQL】InnoDB存储页的独立表空间
目录 1、背景2、独立表空间【1】表空间大小【2】区【3】组【4】段【5】区的类型【6】XDES Entry区结构【7】XDES Entry链表【8】XDES Entry链表基节点【9】INODE Entry段结构【10】FIL_PAGE_TYPE_FSP_HDR页类型【11】FIL_PAGE_IBUF_BITMAP页类型【12】FIL_PAGE_INODE页类型【13…...
RabbitMQ的死信队列的产生与处理
死信队列（Dead Letter Queue, DLQ） 1. 死信（Dead Letter）是怎么产生的？ 在 RabbitMQ 中，消息会变成 死信（Dead Letter）的常见情况有以下几种： 消息被拒绝（R…...
二分算法篇：二分答案法的巧妙应用
二分算法篇：二分答案法的巧妙应用 那么看到二分这两个字想必我们一定非常熟悉，那么在大学期间的c语言的教学中会专门讲解二分查找，那么我们来简单回顾一下二分查找算法，我们知道二分查找是在一个有序的序列中寻找一个数在这个序列…...
实现：多活的基础中间件
APIRouter ： 路由分发服务 API Router 是一个 HTTP 反向代理和负载均衡器，部署在公有云中作为 HTTP API 流量的入口，它能识别 出流量的归属 shard ，并根据 shard 将流量转发到对应的 ezone 。 API Router 支持多种路由键&am…...
【分布式理论9】分布式协同：分布式系统进程互斥与互斥算法
文章目录 一、互斥问题及分布式系统的特性二、分布式互斥算法1. 集中互斥算法调用流程优缺点 2. 基于许可的互斥算法（Lamport 算法）调用流程优缺点 3. 令牌环互斥算法调用流程优缺点 三、三种算法对比 在分布式系统中，多个应用服务可能会同时…...
百问网imx6ullpro调试记录（linux+qt）
调试记录 文章目录 调试记录进展1.开发板相关1.1百问网乌班图密码 1.2 换设备开发环境搭建串口调试网络互通nfs文件系统挂载 1.3网络问题1.4系统启动1.5进程操作 2.QT2.1tslib1.获取源码2.安装依赖文件3.编译 2.2qt移植1.获取qt源码2.配置编译器3.编译 2.3拷贝到开发板1.拷贝2.…...
微信小程序如何使用decimal计算金额
第三方库地址：GitHub - MikeMcl/decimal.js: An arbitrary-precision Decimal type for JavaScript 之前都是api接口走后端计算，偶尔发现这个库也不错，计算简单，目前发现比较准确 上代码 导入js import Decimal from ../../uti…...
win32汇编环境,对线程的创建与操作示例二
;运行效果 ;win32汇编环境,对线程的创建与操作示例二 ;本文主要是实现用CreateThread创建线程时，如何把参数传入进去 ;以下举3个例子说明，如何把数值、字符串和自定义结构传入线程之中 ;下面为asm文件 ;>>>>>>>>>>>>>>>>>…...
React（三）
动态控制显示和css import { useState } from "react"; import "./index.css"; const list [{ id: 1, username: "aaName", content: "一条评论", ctime: "10-18 08:15" },{ id: 2, username: "bbName", conten…...
)
GitHub Pages + Jekyll 博客搭建指南(静态网站搭建)
目录 🚀 静态网站及其生成工具指南🌍 什么是静态网站？📌 静态网站的优势⚖️ 静态网站 VS 动态网站 🚀 常见的静态网站生成器对比🛠️ 使用 GitHub Pages Jekyll 搭建个人博客📌 1. 创建 GitHu…...
——思悟项目技术4)
用Go实现 SSE 实时推送消息(消息通知)——思悟项目技术4
目录 简介 工作原理 例子 使用场景 简介 SSE（Server - Sent Events）是一种允许服务器向客户端实时推送更新的 Web 技术。是一种基于 HTTP 协议的单向通信机制，服务器可以在客户端建立连接后，持续不断地向客户端发送事件流。客…...
通过客户端Chatbox或OpenwebUI访问识别不到本地ollama中的模型等问题的解决
Chatbox和Open WebUI 等无法获取到 Ollama里的模型，主要是由以下原因导致： Ollama 服务未正确暴露给 Docker 容器或客户端模型未正确下载或名称不匹配网络配置或权限问题 排查以上问题的思路首先排查ollama服务是否启动，然后再看端口号 使…...
TfidfVectorizer
TF-IDF / Term Frequency - Inverse Document Frequency 作用：是自然语言处理NLP中常用的文本特征提取工具，用于将文本数据转换为数据向量。 核心思想：是通过统计词频和逆文档频率来量化词语在文本中的重要性。 T F − I D F ( t , d ) T F…...
如何评估云原生GenAI应用开发中的安全风险（下）
以上就是如何评估云原生GenAI应用开发中的安全风险系列中的上篇内容，在本篇中我们介绍了在云原生AI应用开发中不同层级的风险，并了解了如何定义AI系统的风险。在本系列下篇中我们会继续探索我们为我们的云原生AI应用评估风险的背景和意义，并且…...
Flink-序列化
一、概述 几乎每个Flink作业都必须在其运算符之间交换数据，由于这些记录不仅可以发送到同一JVM中的另一个实例，还可以发送到单独的进程，因此需要先将记录序列化为字节。类似地，Flink的堆外状态后端基于本地嵌入式RocksDB实例&…...
1064 - You have an error in your SQL syntax；
在创建数据库表建立外键是遇到了如下报错 1064 - You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near position(position_id) ) at line 8 数据库表sql如下： --职位表 CR…...
团结引擎 Shader Graph：解锁图形创作新高度
Shader Graph 始终致力于为开发者提供直观且高效的着色器构建工具，持续推动图形渲染创作的创新与便捷。在团结引擎1.4.0中，Shader Graph 迎来了重大更新，新增多项强大功能并优化操作体验，助力开发者更轻松地实现高质量的渲染效果与…...
Spring Boot 配置 Mybatis 读写分离
JPA 的读写分离配置不能应用在 Mybatis 上, 所以 Mybatis 要单独处理 为了不影响原有代码, 使用了增加拦截器的方式, 在拦截器里根据 SQL 的 CRUD 来路由到不同的数据源 需要单独增加Mybatis的配置 Configuration public class MyBatisConfig {Beanpublic SqlSessionFactory…...
Redis 数据类型 List 列表
列表类型是⽤来存储多个有序的字符串，如下图所⽰，a、b、c、d、e 五个元素从左到右组成了⼀个有序的列表，列表中的每个字符串称为元素（element），⼀个列表最多可以存储 2^32 - 1个元素。在 Redis 中ÿ…...
Hello Robot 推出Stretch 3移动操作机器人，赋能研究与商业应用
Hello Robot公司近日发布了其新一代开源移动操作机器人Stretch 3，这是一款高度灵活的机器人平台，专为机器人研究、教育实验和商业自动化设计。Stretch 3 结合了先进的移动机器人技术、灵巧操作能力和开源软件生态系统，为用户提供了一个功能强…...
有滚动条的时候，设置盒子的位置
<div class"AIBox mt-24" id"AIBox"><div v-for"(v, i) in AIs" :key"i" :class"v.role assistant ? mb-24 : "><div :class"v.role user ? fc-ac42f3 fw-600 font-16 : ">{{ v.content }}…...
律所录音证据归集工具：基于PyQt6与多线程的自动化音频管理解决方案
在律所日常工作中，音频证据的整理与归集是一个高频且复杂的任务。面对大量的案件录音文件，如何实现快速且准确的分类与存档，成为了律所提高效率、降低出错率的关键。本文将通过技术角度解析一款名为律所录音证据归集工具的项目，详…...
LogicFlow自定义节点：矩形、HTML（vue3）
效果： LogicFlow 内部是基于MVVM模式进行开发的，分别使用preact和mobx来处理 view 和 model，所以当我们自定义节点的时候，需要为这个节点定义view和model。 参考官方文档：节点 | LogicFlow 1、自定义矩形节点 custo…...
软件工程教育的革命：AI辅助学习与实践
软件工程教育正面临着巨大的挑战。传统的教学模式往往以理论讲解为主，实践机会不足，导致学生难以将理论知识转化为实际技能。此外，繁琐的代码编写和项目搭建过程也常常耗费学生大量时间和精力，影响学习效率。为了解决这些问题&…...
Office hour 1
涉及Python环境配置、深度学习框架安装、常用数据处理和分析库、以及Python IDE的选择等内容。 1. Anaconda 安装与配置 • Anaconda Individual Edition：Anaconda 是一个开源平台，旨在简化数据科学的工作流程，提供了 Python 和超过 150 个科…...
【魔法阵——广义Dijkstra，DP】
题目 代码 #include <bits/stdc.h> using namespace std; const int N 1010; const int inf 0x3f3f3f3f; int g[N][N], d[N][N]; bool st[N][N]; int n, k, m; struct Node {int v, c, i;bool operator < (const Node &y) const{return v > y.v;} }; priori…...
使用epoll与sqlite3进行注册登录
将 epoll 服务器 客户端拿来用 客户端：写一个界面，里面有注册登录 服务器：处理注册和登录逻辑，注册的话将注册的账号密码写入数据库，登录的话查询数据库中是否存在账号，并验证密码是否正确 额外功能&…...