当前位置:首页 > 文章列表 > 数据库 > Redis > Redis WATCH 后 EXEC 返回 nil 时怎么判断事务被谁打断

Redis WATCH 后 EXEC 返回 nil 时怎么判断事务被谁打断

来源:17golang原创 2026-09-08 07:19:06 0浏览 收藏

Redis 里看到 WATCH 后的 EXEC 返回 nil/null,先不要把它当成“事务里某条命令返回空”。它表示提交条件已经失效:至少一个被监视的键,在 WATCH 之后、EXEC 被处理之前发生了变化。这个回包能证明有冲突,却不能直接告诉你是哪个客户端、哪条命令或哪个键造成的触碰。

要点速览
  • EXEC 成功通常返回按排队顺序排列的结果集合;nil/null 是整笔乐观锁事务被放弃。
  • 外部写入、过期或淘汰都可能让监视条件失效;MULTI 中排队的命令不会在提交前触发自己的 WATCH 条件。
  • 重试必须重新读取最新值并重新计算;想知道“谁打断”,要靠业务审计信息,不能从 EXEC nil 猜出来。

EXEC 返回 nil 到底说明了什么

MULTI 只负责把命令放进队列,真正执行发生在 EXEC。加上 WATCH order:1001 后,Redis 会把 EXEC 变成一个条件提交:只要监视键仍未被修改,就执行整组命令;条件失效则整组不执行。

因此要区分三种结果:

现象含义处理方向
结果集合条件成立,事务中的命令已按顺序执行读取每个元素,确认业务结果
nil/null至少一个 WATCH 键在提交前被触碰重新读取、重算,再有限次重试
错误回复排队阶段或执行某条命令时出错按错误类型修正,不要盲目当冲突重试
Redis WATCH 监视窗口、业务快照、外部写入、过期淘汰与 EXEC nil null 的静态关系图
图1:WATCH 监视窗口只负责判断条件是否仍成立,EXEC 的 nil/null 表示条件失效,不携带具体打断者身份。

监视窗口里,哪些变化会让事务失败

排查时先固定窗口:从发出 WATCH 开始,到 Redis 收到并处理 EXEC 为止。另一个客户端对被监视键执行写操作,可能使条件失效;键的过期或淘汰也可能触发同样结果。即使最后读到的值“看起来没变”,也不能据此把 nil 判成客户端库故障,因为你看到的只是提交后的状态,而不是窗口内发生过的每一次触碰。

还有两个容易混淆的边界。第一,事务中排队的写命令在 EXEC 前并未执行,不会因为“自己排队了写入”而提前触发 WATCH。第二,语法或参数问题可能在排队阶段暴露;而类型不匹配等错误可能作为结果集合中的单个错误返回。它们都不是 WATCH 冲突。

如果客户端把协议层的 nil/null 包装成异常,例如 redis-py 常见的 WatchError,应用层应该识别这个专门的冲突类型。不要用“所有 RedisError 都重试”的宽泛规则,否则连接故障、权限错误和错误命令会被掩盖。

为什么 EXEC nil 不能告诉你是谁打断的

Redis 的 EXEC 回包只携带“条件提交成功”或“条件提交失败”这层信息。它不返回冲突键列表、修改它的客户端 ID、具体命令,也不区分是业务写入还是过期/淘汰。因此,“事务被谁打断”不能靠解析 nil 得到。

如果业务确实要追责或统计冲突来源,可以在写入路径增加操作 ID、业务主体和目标键的审计记录,把同一个请求 ID 写进日志或事件流;同时记录 WATCH 键集合、读取版本摘要、EXEC 结果和重试次数。这样能在业务侧关联“谁在什么时候尝试修改”,但要注意这仍是应用记录,不是 Redis 从 EXEC 回包反推出的身份。

正确的重试边界:重新读取、重新计算、重新提交

冲突后最忌讳复用旧快照。正确做法是让下一轮重新建立监视、读取最新值、按最新值计算目标,再创建新的事务队列。下面用 redis-py 表达这个边界;其他客户端虽然异常类型不同,判断原则相同。

import time
import redis

def increase_with_watch(r, key, delta, max_retries=5):
    for attempt in range(max_retries):
        try:
            # 每一轮都使用新的事务上下文,避免带着旧快照重提
            with r.pipeline() as pipe:
                pipe.watch(key)
                raw = pipe.get(key)
                current = int(raw or 0)
                target = current + delta

                # 读取完成后才进入排队阶段
                pipe.multi()
                pipe.set(key, target)
                result = pipe.execute()

                # 返回结果集合才代表这一轮提交成功
                return {"ok": True, "attempt": attempt + 1, "result": result}
        except redis.WatchError:
            # 只把 WATCH 冲突当作可重试事件,并给竞争者留出机会
            time.sleep(0.01 * (2 ** attempt))

    # 达到上限后交给调用方,不把冲突伪装成成功
    return {"ok": False, "reason": "watch_conflict_retry_exhausted"}

这里的关键不是指数退避本身,而是三件事:失败后重新读取、重试次数有上限、最终失败可被上层看见。高竞争键还应考虑降低单键争用、把可合并更新改成原子命令,或改用脚本把读取和写入放到 Redis 端一次完成;不要无限提高重试次数。

Redis WATCH 冲突重试中的旧快照、最新值读取、业务重算、EXEC 提交与审计边界关系图
图2:重试必须回到最新值读取,Redis 只返回冲突结果;操作 ID、责任方和重试原因需要由业务审计层补齐。

常见问题

EXEC 返回空数组和返回 nil 是一回事吗?

不是。nil/null 表示 WATCH 条件失败,事务没有执行;空数组则可能是事务本身没有排队命令,具体仍要看客户端对协议的映射。

EXEC 结果集合里有一个错误,要不要整笔重试?

先看错误类型。执行阶段的单条命令错误不等同于 WATCH 冲突,盲目重试可能重复执行其他已成功的命令。

能不能通过 Redis 直接查出哪个客户端改了键?

不能从这次 EXEC 回包直接查出。应在业务写入链路记录请求 ID、操作者和目标键;监控工具可以辅助定位时间窗口,但不能把 nil 解释成某个客户端的证据。

Redis 官方事务文档和 EXEC 命令说明都把 nil/null 定义为被监视键触碰后的条件失败。把这个边界守住,再分别处理冲突、队列错误和执行错误,重试日志才会真正有诊断价值。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go recover 在 defer 中返回后 named result 如何避免静默成功Go recover 在 defer 中返回后 named result 如何避免静默成功
上一篇
Go recover 在 defer 中返回后 named result 如何避免静默成功
Go Cmd 输出管道忘记关闭时怎么避免子进程卡住
下一篇
Go Cmd 输出管道忘记关闭时怎么避免子进程卡住
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之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测试功能,助您快速选择最适合项目的高性能大语言模型。
    19次使用
  • SuperCLUE中文大模型评测基准:功能、能力维度与应用指南
    SuperCLUE
    SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
    177次使用
  • C-Eval中文评测基准:大语言模型多学科能力评估指南
    C-Eval
    深入了解C-Eval中文评估套件,涵盖52个学科与4级难度。本文详解其功能特点、Zero-shot/Few-shot使用方法及代码示例,助您全面评测LLM中文理解与泛化能力。
    111次使用
  • AI Prompt Library:免费AI提示词库,助力ChatGPT高效创作与营销
    AI Prompt Library
    探索AI Prompt Library免费资源库,涵盖营销、写作及多场景AI提示词。兼容ChatGPT、Claude等工具,一键复制优化输出,提升工作效率。
    38次使用
  • Generrated:DALL·E 2/3 AI绘画提示词灵感库与图像对比平台
    Generrated
    Generrated汇集9300+张DALL·E生成图像及对应提示词,支持查看完整图集、对比DALL·E 2与3版本差异,是AI绘图新手学习Prompt设计与获取创作灵感的实用工具。
    18次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码