本文聚焦四步关键流程，帮助开发者从入门到精通掌握 Redis 事务 的实现要点与实战技巧。通过对 MULTI、EXEC、WATCH、DISCARD 等核心命令的逐步拆解，以及并发场景下的冲突处理与性能优化，读者可以建立清晰的事务设计思路。
第1步：理解 Redis 事务的基本原理
事务的概念与执行阶段
在 Redis 的事务模型中，原子性通过把一组命令在一次执行中完成来实现，但这与带有完整事务日志的数据库并不完全等同。真正的工作流程是：先使用 MULTI 开启事务，再把需要执行的命令逐条推送到服务器的队列，最后通过 EXEC 一次性提交，从而确保在执行阶段不会被外部请求打断。
单线程处理模型使得事务的队列化和执行具备天然的原子性保障；在同一个 Redis 实例中，所有队列化的命令都会被串行执行，避免了竞争条件产生的中途打断。
MULTI
INCR page_views
SET last_seen "2025-08-22"
EXEC
此外，在没有使用 WATCH 的情况下，事务也会通过 EXEC 的返回结果来反映执行结果，但对于更复杂的并发场景，仍然需要借助 WATCH 来实现乐观锁检测，以便在冲突发生时进行适当处理。
第2步：掌握核心命令：MULTI、EXEC、WATCH、DISCARD
命令作用与正确用法
本步聚焦四个核心命令的作用，以及它们如何协同工作来实现事务的正确边界。MULTI 用于开启事务队列；EXEC 用于提交队列中的命令；WATCH 提供乐观锁能力，监视一个或多个键在事务执行期间的被修改情况；DISCARD 可以放弃正在进行的事务。
使用 WATCH 时，若监视的键在你准备执行事务期间被其他客户端修改，EXEC 将失败，返回空结果，事务被中止。对这类冲突，通常的处理策略是重试或回退逻辑，并在应用层实现幂等性。
import redisr = redis.Redis()key = 'balance'with r.pipeline() as pipe:while True:try:pipe.watch(key)current = pipe.get(key)balance = int(current or 0)pipe.multi()pipe.set(key, balance + 10)pipe.execute()breakexcept redis.WatchError:# 发生冲突，重新尝试continuefinally:pipe.unwatch()
第3步：处理并发冲突与回滚机制
乐观锁与错误处理
在高并发场景中，单纯依赖事务可能会遇到冲突；此时 乐观锁（通过 WATCH）是常用策略，若检测到冲突即回滚并重试。DISCARD 可以显式放弃队列中的命令，确保不会错误地执行。
此外，当需要跨多个键实现原子性操作时，Lua 脚本（EVAL）成为更高效的选项，因为它在服务器端原子执行，无需往返多次，能显著降低并发时的延迟。
-- Lua 脚本：在 Redis 服务器端原子地将 amount 从 from 转移到 to
local from = KEYS[1]
local to = KEYS[2]
local amount = tonumber(ARGV[1])if tonumber(redis.call('GET', from) or '0') >= amount thenredis.call('DECRBY', from, amount)redis.call('INCRBY', to, amount)return 1
elsereturn 0
end
第4步：从入门到精通的实战流程：测试、监控与优化
实战要点：设计、测试与性能优化
进入实战阶段时，需关注边界设计、错误处理、监控与回放能力。要明确哪些操作需要幂等性，与此同时要在设计中引入重试限次和超时策略，以避免死循环。通过清晰的事务边界，可以实现稳定的并发处理。
在真实环境中，可以通过 redis-benchmark、MONITOR 与 SLOWLOG 等工具来评估事务性能和潜在瓶颈，结合应用层面的日志追踪实现可观测性，确保问题可以快速定位并修正。
# 基本压力测试：评估事务在高并发下的吞吐与延迟
redis-benchmark -t set,get,incr -n 100000 -c 50
