消费组相关技术文章-Golang学习网

数据库 · Redis | 3星期前 | Redis · 消息队列 · 故障排查 · 消息堆积 Redis Stream 消费组 XPENDING XAUTOCLAIM

Redis Stream 消费组出现消息堆积时，先用 XPENDING 判断待处理消息的数量、最老时间和消费者归属，再用 XAUTOCLAIM 接管超时消息，最后按小批量确认、失败重试和监控恢复顺序处理。

439 收藏

数据库 · Redis | 3星期前 | Redis · 消息队列 · Stream · redis streams 重试 XREADGROUP XACK PEL pending

在 Redis Streams 下游，ACK 只是消费确认，不是消息删除；pending 列表、last-delivered-id 与重试窗口一起决定消息是否真正安全出队。本文用 redis-cli 的最小链路验证常见误区和可上线检查点。

339 收藏

数据库 · Redis | 3个月前 | Redis · 消息队列 · Stream · redis 消息队列 Redis Stream 消费组 XREADGROUP XACK XPENDING XAUTOCLAIM

用订单异步处理场景讲清楚 Redis Stream 的实用队列模型：生产者写入消息，消费组分配任务，Worker 处理成功后 ACK，失败或超时的消息进入待确认列表，再通过 XPENDING 和 XAUTOCLAIM 做重投。

187 收藏