当前位置:首页 > 文章列表 > 科技周边 > 业界新闻 > 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 释放为“可立即转交”,并通过 SILENT、FAIL、FATAL 区分失败责任。

一句话理解: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 消息。因此它会优先于等待空闲时间的旧消息。

这个优先级只有在接管语义下生效。没有 CLAIM 的 XREADGROUP 仍只读取从未投递的新消息;恢复消费者应明确使用 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 的读取或使用 XCLAIM、XAUTOCLAIM。

所有失败都应该用 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推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    686次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    701次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    757次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    719次使用
  • MMBench详解:多模态大模型基准测试、功能特点与使用指南
    MMBench
    MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
    558次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码