Node.js 怎么读取 RabbitMQ 消息重回队列(Requeue)后被服务器标记的真实投递次数?

夏敏同学_7720

夏敏同学_7720

2026-06-01

937人浏览

原创

RabbitMQ不主动透传deliveryCount,需显式启用x-delivery-count队列参数(3.8.0+、manual ack模式下),启用后该值以Buffer形式存在于message.properties.headers中,首次投递为0。

为什么 deliveryCount 在 Node.js AMQP 客户端里拿不到?

amqp 协议本身不定义 deliverycount 字段,rabbitmq 也**不会通过标准消息属性(如 properties.headers 或 properties.deliverymode)主动下发重投次数**。你用 amqplib 收到的 message.fields 或 message.properties 里压根没有这个字段——不是你漏读了,是 rabbitmq 根本没塞进去。

常见误解是以为开启 requeue: true 后,RabbitMQ 会像 JMS 那样自动更新并透传一个计数器。实际上,RabbitMQ 只在内部维护该计数(用于 TTL、死信判定等),但默认不暴露给消费者。

怎么让 RabbitMQ 把真实投递次数带过来?

必须启用 RabbitMQ 的 x-delivery-count 头部支持,并在声明队列时显式开启:arguments: { 'x-delivery-count': true }。这是个服务端特性开关,不配就永远为空。

实操要点:

  • 队列必须是 新声明的(或删除后重建),已存在的队列不会自动追加该参数
  • 消费者连接的 Exchange 和 Queue 绑定关系无需改动,只影响队列元数据
  • 启用后,每次消息被 requeue 再投递,RabbitMQ 会在 message.properties.headers 中注入 'x-delivery-count' 字段

示例声明(amqplib):

await channel.assertQueue('my_queue', {
  durable: true,
  arguments: { 'x-delivery-count': true }
});

收到消息后怎么安全读取 x-delivery-count?

它存在于 message.properties.headers,但类型是 Buffer(AMQP 0-9-1 规范要求),不能直接当数字用。而且字段可能不存在(比如首次投递且未启用该特性时),必须做防御性检查。

正确读取方式:

抖音下载器(Node.js)
抖音下载器(Node.js)

抖音无水印视频下载和文案提取工具

下载
  • 先判断 message.properties.headers 是否为对象,再检查 'x-delivery-count' 键是否存在
  • 用 Number() 转换,不要用 parseInt()(避免隐式进制转换)
  • 注意:值为 0 表示首次投递,1 表示第一次 requeue 后再次投递,以此类推

简短示例:

const deliveryCount = message.properties.headers?.['x-delivery-count'];
const count = Number(deliveryCount);

if (count >= 3) {
  channel.nack(message, false, false); // 拒绝且不 requeue,进死信
} else {
  channel.nack(message, false, true); // requeue,下次投递 count+1
}

容易被忽略的兼容性与行为细节

这个机制依赖 RabbitMQ 3.8.0+,旧版本(如 3.7.x)即使配置了 x-delivery-count: true 也不会生效,headers 里始终没有该字段。

另一个关键点:x-delivery-count **只对 manual ack 模式有效**。如果你用的是 autoAck(noAck: true),RabbitMQ 不会跟踪投递状态,该字段必然缺失。

还有:如果消息被多个不同队列消费(通过 fanout exchange 分发),每个队列独立维护自己的 x-delivery-count,别误以为是全局计数。

真正麻烦的是——一旦你依赖这个值做业务逻辑(比如重试三次后告警),就必须确保所有下游消费者都按同样规则声明队列,且 RabbitMQ 版本统一。漏掉任意一环,count 就是 NaN,后续逻辑可能静默失败。

相关专题

更多
js获取数组长度的方法
js获取数组长度的方法

在js中,可以利用array对象的length属性来获取数组长度,该属性可设置或返回数组中元素的数目,只需要使用“array.length”语句即可返回表示数组对象的元素个数的数值,也就是长度值。php中文网还提供JavaScript数组的相关下载、相关课程等内容,供大家免费下载使用。

2023.06.20

4566

5

js刷新当前页面
js刷新当前页面

js刷新当前页面的方法:1、reload方法,该方法强迫浏览器刷新当前页面,语法为“location.reload([bForceGet]) ”;2、replace方法,该方法通过指定URL替换当前缓存在历史里(客户端)的项目,因此当使用replace方法之后,不能通过“前进”和“后退”来访问已经被替换的URL,语法为“location.replace(URL) ”。php中文网为大家带来了js刷新当前页面的相关知识、以及相关文章等内容

2023.07.04

1149

3

js四舍五入
js四舍五入

js四舍五入的方法:1、tofixed方法,可把 Number 四舍五入为指定小数位数的数字;2、round() 方法,可把一个数字舍入为最接近的整数。php中文网为大家带来了js四舍五入的相关知识、以及相关文章等内容

2023.07.04

4504

6

js删除节点的方法
js删除节点的方法

js删除节点的方法有:1、removeChild()方法,用于从父节点中移除指定的子节点,它需要两个参数,第一个参数是要删除的子节点,第二个参数是父节点;2、parentNode.removeChild()方法,可以直接通过父节点调用来删除子节点;3、remove()方法,可以直接删除节点,而无需指定父节点;4、innerHTML属性,用于删除节点的内容。

2023.09.01

900

4

JavaScript转义字符
JavaScript转义字符

JavaScript中的转义字符是反斜杠和引号,可以在字符串中表示特殊字符或改变字符的含义。本专题为大家提供转义字符相关的文章、下载、课程内容,供大家免费下载体验。

2023.09.04

1796

5

js生成随机数的方法
js生成随机数的方法

js生成随机数的方法有:1、使用random函数生成0-1之间的随机数;2、使用random函数和特定范围来生成随机整数;3、使用random函数和round函数生成0-99之间的随机整数;4、使用random函数和其他函数生成更复杂的随机数;5、使用random函数和其他函数生成范围内的随机小数;6、使用random函数和其他函数生成范围内的随机整数或小数。

2023.09.04

3285

4

如何启用JavaScript
如何启用JavaScript

JavaScript启用方法有内联脚本、内部脚本、外部脚本和异步加载。详细介绍:1、内联脚本是将JavaScript代码直接嵌入到HTML标签中;2、内部脚本是将JavaScript代码放置在HTML文件的`<script>`标签中;3、外部脚本是将JavaScript代码放置在一个独立的文件;4、外部脚本是将JavaScript代码放置在一个独立的文件。

2023.09.12

4253

6

Js中Symbol类详解
Js中Symbol类详解

javascript中的Symbol数据类型是一种基本数据类型,用于表示独一无二的值。Symbol的特点:1、独一无二,每个Symbol值都是唯一的,不会与其他任何值相等;2、不可变性,Symbol值一旦创建,就不能修改或者重新赋值;3、隐藏性,Symbol值不会被隐式转换为其他类型;4、无法枚举,Symbol值作为对象的属性名时,默认是不可枚举的。

2023.09.20

2760

5

java访问控制修饰符介绍
java访问控制修饰符介绍

java访问控制修饰符有四种,分别是public、protected、private、默认访问修饰符。详细介绍:1、public,public是最宽松的访问控制修饰符,被修饰的类、方法和变量可以被任何其他类访问,当一个类、方法或变量被声明为public时,它们可以在任何地方被访问,无论是同一个包中的类还是不同包中的类;2、protected修饰符等等。

2023.09.20

888

7

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
RabbitMQ 入门教程
RabbitMQ 入门教程

共0课时 | 131人学习

RabbitMQ 教程手册
RabbitMQ 教程手册

共0课时 | 0人学习

RabbitMQ 官方文档
RabbitMQ 官方文档

共0课时 | 0人学习