xreadgroup 和 xack 在 lua 脚本中被禁用，因 redis 沙箱禁止阻塞及消费者组命令；lua 仅支持 xadd、xdel、xtrim、xrange 等安全命令；替代方案是用 xrange + xadd 原子预占消息，ack 须由客户端执行。
不能直接在Lua脚本里调用 XREADGROUP 或 XACK ——这些命令在Lua中被禁用，强行调用会报错 ERR unknown command。
为什么 XREADGROUP 在Lua里不可用
Redis 的 Lua 沙箱环境明确禁止了所有带阻塞行为（BLOCK）、消费者组管理（XGROUP）和流读取类命令（XREAD、XREADGROUP、XPENDING 等）。这是出于执行安全与原子性保障的硬性限制，不是版本或配置问题。
常见错误现象：
- 脚本中写
redis.call('XREADGROUP', ...)→ 直接返回ERR unknown command 'XREADGROUP' - 试图用
redis.pcall捕获也无效，底层就是不注册这些命令
能用的 Stream 相关 Lua 命令只有这几个
目前（Redis 5.0–7.4）Lua 脚本中**仅允许使用**以下 Stream 命令：
Redis Skill - 高性能缓存管理
下载
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
-
XADD：安全，可用于原子化写入 + 自增 ID 生成 -
XDEL：删除指定 ID 消息（需已知 ID） -
XTRIM：按长度或时间裁剪流，防止无限增长 -
XRANGE/XREVRANGE：范围查询，但无法配合消费者组语义（如 pending、ack） -
XLEN、XINFO（部分子命令）：只读元信息
注意：XRANGE 返回的是原始消息数组结构，没有自动过滤、分组或 ACK 状态标记，得靠业务自己解析 ID 和字段。
替代方案：用 XADD + 外部协调实现原子预占
想模拟“读一条、标记为 pending、再处理”，又不想暴露竞态，可以绕过 XREADGROUP，改用 XADD 写入一个临时“占位消息”，再由外部服务轮询或监听该占位流：
- 生产者调用
XADD写入主流orders - Lua 脚本做两件事：
① 用XRANGE orders - + COUNT 1拿最新消息 ID
② 用XADD reserved_orders * consumer_id {msg_id}记录“某消费者正尝试处理该 ID” - 这个
reserved_orders是辅助流，不参与消费组，只用于冲突检测 - 后续业务逻辑查
reserved_orders确认未被抢占，再调用XACK（由客户端发）
这样既保持了关键判断在 Lua 中原子执行，又避开了禁用命令。性能损耗极小，因为 XRANGE + XADD 都是 O(log N) 且无阻塞。
最容易被忽略的一点
很多人以为 “Lua 脚本能操作所有 Redis 命令”，但在 Stream 场景下，XREADGROUP 和 XACK 的缺失意味着：真正的消费者组生命周期（claim → process → ack → failover）必须由客户端代码控制，Lua 只能做“前置校验”或“后置清理”。把 ACK 逻辑塞进 Lua 是徒劳的，它根本不会执行。
