Redis WATCH 后 EXEC 返回 nil 时怎么判断事务被谁打断
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 键在提交前被触碰 | 重新读取、重算,再有限次重试 |
| 错误回复 | 排队阶段或执行某条命令时出错 | 按错误类型修正,不要盲目当冲突重试 |

监视窗口里,哪些变化会让事务失败
排查时先固定窗口:从发出 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 端一次完成;不要无限提高重试次数。

常见问题
EXEC 返回空数组和返回 nil 是一回事吗?
不是。nil/null 表示 WATCH 条件失败,事务没有执行;空数组则可能是事务本身没有排队命令,具体仍要看客户端对协议的映射。
EXEC 结果集合里有一个错误,要不要整笔重试?
先看错误类型。执行阶段的单条命令错误不等同于 WATCH 冲突,盲目重试可能重复执行其他已成功的命令。
能不能通过 Redis 直接查出哪个客户端改了键?
不能从这次 EXEC 回包直接查出。应在业务写入链路记录请求 ID、操作者和目标键;监控工具可以辅助定位时间窗口,但不能把 nil 解释成某个客户端的证据。
Redis 官方事务文档和 EXEC 命令说明都把 nil/null 定义为被监视键触碰后的条件失败。把这个边界守住,再分别处理冲突、队列错误和执行错误,重试日志才会真正有诊断价值。
Go recover 在 defer 中返回后 named result 如何避免静默成功
- 上一篇
- Go recover 在 defer 中返回后 named result 如何避免静默成功
- 下一篇
- Go Cmd 输出管道忘记关闭时怎么避免子进程卡住
-
- 数据库 · Redis | 6小时前 | Redis · Redis SCAN Redis游标遍历 SCAN全量查询 Redis键空间 COUNT参数
- Redis SCAN 为什么不能当作一次性全量遍历
- 236浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis Lua 脚本怎样通过 KEYS 和 ARGV 区分参数
- 313浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis ZSET 怎样查询分数区间内的成员
- 484浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis Hash 怎样一次读取多个字段并设置 TTL
- 104浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis Stream 消费组为什么重复收到消息
- 463浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis Stream XREAD COUNT 怎样限制单次读取消息数
- 166浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis Stream 怎样查看消费者组待处理消息
- 250浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis JSON.SET 路径不存在为什么没有创建对象
- 204浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis EXPIRE 怎样只在新 TTL 更短时更新
- 244浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis JSON.SET 怎样只在键存在时更新
- 173浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis CLIENT PAUSE WRITE 的主节点切换步骤与写入保护边界
- 458浏览 收藏
-
- 数据库 · Redis | 6小时前 |
- Redis GETDEL 怎样读取后删除键
- 306浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 614次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 653次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 686次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 646次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 475次使用
-
- Go与Redis实现分布式互斥锁和红锁
- 2022-12-22 117浏览
-
- Go+Redis实现延迟队列实操
- 2023-02-23 426浏览
-
- 一文搞懂Go语言操作Redis的方法
- 2023-01-07 171浏览
-
- Golang分布式应用之Redis示例详解
- 2023-01-07 113浏览
-
- Go Redis客户端使用的两种对比
- 2022-12-30 195浏览

