Redis Stream 速查：消费者组与 pending 处理
Redis Stream 速查：消费者组与 pending 处理
安全风信子
发布于 2025-11-18 19:30:04
发布于 2025-11-18 19:30:04
一句话承诺：四条命令跑通生产者-消费者组与堆积处理。
基本命令
# 追加消息
XADD mystream * msg "hello"
# 创建消费者组
XGROUP CREATE mystream mygroup $ MKSTREAM
# 读取（阻塞）
XREADGROUP GROUP mygroup c1 COUNT 10 BLOCK 0 STREAMS mystream >
# 确认消费
XACK mystream mygroup 169399-0Pending 处理
# 查看未确认消息
XPENDING mystream mygroup
# 转交消息（超时重投）
XCLAIM mystream mygroup c2 60000 169399-0场景建议
操作 | 建议 |
|---|---|
读取 | 使用 BLOCK 降低轮询开销 |
确认 | 批量 XACK 提升性能 |
重试 | XCLAIM + 超时阈值 |
常见坑与替代法
- 坑：消费者崩溃导致 pending 堆积。替代：定期 XPENDING + XCLAIM 回收。
- 坑：ID 管理复杂。替代：使用 > 自动分配。
下一篇预告
API 网关速配：Nginx 子路径转发与 Header 透传。
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2025-11-12，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录
腾讯云开发者
