当前位置:首页 > 文章列表 > 科技周边 > 业界新闻 > Redis 8.8 Streams NACK 如何影响失败消息转交

Redis 8.8 Streams NACK 如何影响失败消息转交

来源:17golang原创 2026-09-10 09:43:50 0浏览 收藏

Redis Streams 里,消费者拿到消息后如果既不能确认成功,又不想让它在 PEL 中等到空闲超时,Redis 8.8 新增的 XNACK 就是针对这个缺口的处理方式。它不会删除 Stream 消息,而是把 pending entry 释放为“可立即转交”,并通过 SILENTFAILFATAL 区分失败责任。

一句话理解:XACK 表示处理成功并移出 PEL,XNACK 表示处理失败但保留消息,让同组其他消费者尽快重新领取。
要点速览
  • XNACK 自 Redis Open Source 8.8.0 提供,核心是立即释放 pending message。
  • SILENT 回退一次投递计数,FAIL 保持计数,FATAL 把计数置为最大值。
  • 消息会进入 PEL 头部的 NACK 优先区;使用 CLAIM 的读取才能优先接回它。

XNACK 改变的是 PEL 里的归属,不是删除消息

旧流程里,消费者失败后通常只能留下消息,再由其他消费者通过 XPENDING 配合 XCLAIM,或直接使用 XAUTOCLAIM,等消息达到空闲时间后接管。Redis 8.8 的 XNACK 把“我现在处理不了,请交给别人”变成了显式动作,减少了等待空闲阈值的延迟。

最小语法如下。IDS 后的数字是消息 ID 数量,命令返回实际释放回消费组 PEL 的消息数。

#!/usr/bin/env bash
# 将当前消费者无法处理的 pending message 立即释放给同组消费者
redis-cli XNACK orders order-workers FAIL IDS 1 1710000000000-0

# 成功处理后仍使用 XACK;它会从 PEL 移除消息
redis-cli XACK orders order-workers 1710000000000-0
Redis 8.8 Streams XNACK 将 pending 消息从 Consumer A 释放到消费者组 PEL 的 NACKed 优先区并交给 Consumer B 的关系示意图
图1:XNACK 释放的是消费者组 PEL 中的 pending entry,消息仍留在 Stream,只是恢复为可转交状态。

三种模式决定重试计数怎么走

模式选择的关键不是“哪一个更强”,而是这次失败是否应该算作一次有效投递。内部故障或优雅停机一般选 SILENT;当前消费者资源不足、换一个消费者可能成功时选 FAIL;内容损坏、疑似毒消息或恶意输入则选 FATAL,方便后续按最大投递计数识别并进入死信处理。

模式适合场景delivery counter后续动作
SILENT停机、外部依赖暂时不可达减 1允许正常重试
FAIL当前消费者内存或资源不足不变交给其他消费者尝试
FATAL格式错误、毒消息、疑似恶意消息设为最大值识别后做死信处理

不要把 FATAL 当成 Redis 自动创建死信队列。它只是写入一个明确的失败信号,死信转存、告警和人工修复仍要由业务消费者实现。

Redis 8.8 XNACK 的 SILENT FAIL FATAL 三种模式与投递计数和失败消息转交结果关系示意图
图2:三种 XNACK 模式表达三类不同责任判断,要区分可换消费者重试与应进入死信处理的毒消息。

失败消息如何优先交给其他消费者

执行成功后,消息会被标记为无归属,最后投递时间设为 0,并放到 PEL 头部的 NACKed 区域;同一区域内保持 FIFO,之后才是既未 ACK 也未 NACK 的普通 pending 消息。因此它会优先于等待空闲时间的旧消息。

这个优先级只有在接管语义下生效。没有 CLAIMXREADGROUP 仍只读取从未投递的新消息;恢复消费者应明确使用 CLAIM 路径,并保留 XPENDING 作为观察入口。

#!/usr/bin/env bash
# 仅查看消费组 pending 概况,不把输出当成业务成功证明
redis-cli XPENDING orders order-workers

# 读取并接管可领取的 pending message;先处理 XNACKed 区域
redis-cli XREADGROUP GROUP order-workers worker-b COUNT 10 CLAIM 0 STREAMS orders >

上线前先确认版本和托管形态

XNACK 的官方命令文档标注为 Redis Open Source 8.8.0 新增。升级后可以先确认服务端版本,再在灰度消费组中测试返回数、PEL 数量和业务幂等性:

#!/usr/bin/env bash
# 先确认连接到的服务端版本,避免客户端升级但服务端仍旧版本
redis-cli INFO server | awk -F: '/^redis_version:/{print $2}'

# 目标环境确认支持后,再用一条已知 pending ID 做灰度验证
redis-cli XNACK orders order-workers SILENT IDS 1 1710000000000-0

官方资料入口:https://redis.io/docs/latest/commands/xnack/。当前 XNACK 命令页的兼容性表对 Redis Software 与 Redis Cloud 标为不兼容,所以云上或商业发行版不能只看“Redis 8.8”字样,应以目标环境的命令支持矩阵和灰度结果为准。无论选择哪种模式,业务处理都仍需幂等,XNACK 解决的是转交时机和重试语义,不是重复消费的消除。

常见问题

XNACK 会把消息从 Stream 删除吗?

不会。它保留 Stream entry 和 PEL 引用,只解除当前消费者归属;成功处理仍应调用 XACK

XNACK 后为什么普通 XREADGROUP 读不到消息?

因为普通读取仍面向从未投递的新消息。要恢复 pending 消息,需要走带 CLAIM 的读取或使用 XCLAIMXAUTOCLAIM

所有失败都应该用 FAIL 吗?

不应该。停机或消费者自身故障用 SILENT 更能避免无意义地增加投递次数;确认消息本身不可处理时才用 FATAL,并由业务侧负责死信流程。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go 泛型类型参数的 comparable 约束为什么不能覆盖所有接口值Go 泛型类型参数的 comparable 约束为什么不能覆盖所有接口值
上一篇
Go 泛型类型参数的 comparable 约束为什么不能覆盖所有接口值
Python 3.15 的 abi3t 与 cp315t wheel 如何选择
下一篇
Python 3.15 的 abi3t 与 cp315t wheel 如何选择
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    61次使用
  • SuperCLUE中文大模型评测基准:功能、能力维度与应用指南
    SuperCLUE
    SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
    216次使用
  • C-Eval中文评测基准:大语言模型多学科能力评估指南
    C-Eval
    深入了解C-Eval中文评估套件,涵盖52个学科与4级难度。本文详解其功能特点、Zero-shot/Few-shot使用方法及代码示例,助您全面评测LLM中文理解与泛化能力。
    145次使用
  • AI Prompt Library:免费AI提示词库,助力ChatGPT高效创作与营销
    AI Prompt Library
    探索AI Prompt Library免费资源库,涵盖营销、写作及多场景AI提示词。兼容ChatGPT、Claude等工具,一键复制优化输出,提升工作效率。
    79次使用
  • Generrated:DALL·E 2/3 AI绘画提示词灵感库与图像对比平台
    Generrated
    Generrated汇集9300+张DALL·E生成图像及对应提示词,支持查看完整图集、对比DALL·E 2与3版本差异,是AI绘图新手学习Prompt设计与获取创作灵感的实用工具。
    56次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码