Redis 利用 Lua 脚本保证消息队列出队原子性，核心是将“读取消息”与“标记状态”封装在单个 EVAL 命令中，依托 Redis 单线程模型确保执行期间不被打断。适用高并发场景，但需注意脚本超时阻塞风险及错误不回滚机制。
先说结论：Redis Lua 脚本通过单线程独占执行机制，确保出队操作期间无其他命令插入，实现逻辑原子性。
- 适合：高并发下需要“取消息 + 记状态”原子完成的场景。
- 先看：脚本内避免耗时操作，防止阻塞主线程。
- 建议：配合业务层超时重试机制，Lua 本身不提供 ACK 回滚。
命令速用版
以下脚本实现从列表弹出消息并记录到已处理集合，确保两步操作原子完成：
EVAL "local msg = redis.call('lpop', KEYS[1]); if not msg then return nil end; redis.call('sadd', KEYS[2], msg); return msg" 2 queue:msgs queue:acked参数说明：KEYS[1] 为消息列表名，KEYS[2] 为已处理集合名，数字 2 表示 KEYS 数组长度。
为什么会这样
Redis 执行 Lua 脚本的原子性源于其单线程命令调度模型，脚本被视为一条完整命令执行。
Redis 主线程采用事件循环模型，当一个 Lua 脚本开始执行时，主线程不会切换上下文去处理其他客户端的请求。脚本内的 redis.call 调用直接进入内部执行队列，不经过网络解析和排队。从其他客户端视角看，要么脚本尚未执行，要么脚本已经全部执行完成，中间不存在可见的中间状态。这种语义类似于 MULTI/EXEC 事务，但支持更复杂的逻辑判断。
分步处理
1. 定义 Key 结构：明确消息队列 Key（如 queue:msgs）和状态记录 Key（如 queue:acked），确保集群模式下落在同一 Slot。
2. 编写脚本逻辑：使用 lpop 取出消息，判断非空后使用 sadd 记录状态，最后返回消息内容。避免在脚本内进行网络请求或文件 I/O。
3. 加载与执行：通过 SCRIPT LOAD 缓存脚本获取 SHA 值，后续使用 EVALSHA 调用以减少网络传输开销。
4. 异常处理：使用 redis.pcall 包裹可能出错的命令，防止脚本意外中断导致部分命令已执行却无法回滚。
怎么验证是否生效
1. 并发测试：启动多个消费者客户端同时执行出队脚本，检查消息是否被重复消费。
2. 数据核对：验证 queue:msgs 列表长度减少量与 queue:acked 集合增加量是否一致。
3. 监控延迟：观察 Redis 延迟监控指标，确认脚本执行时间未触发超时警告。
常见坑
1. 脚本超时阻塞：脚本执行时间过长会阻塞 Redis 主线程，严重时触发 SCRIPT_KILL 或超时断连。避免在脚本中遍历大量 Key。
2. 错误不回滚：Lua 脚本的原子性仅保证执行过程不被打断，不保证失败回滚。若脚本中间报错，已执行的命令不会撤销。
3. 集群兼容性问题：KEYS 必须是真实存在的 Key 名，不能动态拼接。若动态构造 Key 名，集群模式下会报 CROSSSLOT 错误。
常见问题
Lua 脚本原子性和数据库事务原子性一样吗？
不一样。数据库事务原子性指要么全部成功要么全部回滚，Redis Lua 脚本原子性指执行期间不被打断，但出错不回滚。
脚本执行出错会影响已执行的操作吗？
会。若脚本中间命令失败，之前已成功执行的 redis.call 命令依然生效，不会自动撤销。
集群模式下使用 Lua 脚本要注意什么？
所有操作的 Key 必须落在同一 Slot。KEYS 数组中的 Key 会被 Redis 提前校验，动态拼接的 Key 会导致集群报错。
参考来源
- Redis 官方文档：Lua scripting
- 技术社区实践指南：Redis 如何利用 Lua 脚本实现简单的消息队列_保证消息原子获取
- 技术社区实践指南：Redis 为什么使用 Lua 脚本可以保证原子性？
- 技术社区实践指南：如何在 Redis 中利用 Lua 脚本保证多命令执行的原子性