Redis Streams 消费组与顺序保证(XADD、XREADGROUP、Claim 与 ID)关键实践与参数生产:`XADD mystream * field value`;控制每条的大小与字段结构。消费组:`XGROUP CREATE mystream group $`;`XREADGROUP GROUP group consumer COUNT N`。PEL 与 Claim:对超时未确认的条目使用 `XCLAIM` 转移;设置超时窗口与重试预算。顺序保证:单分区内按 ID 顺序消费;跨消费者需避免并发导致乱序。验证方法压测下观察 PEL 大小与超时条目;统计 Claim 成功率与重复处理率。故障演练:消费者崩溃与恢复后的一致性。指标:lag、重试次数与吞吐。注意事项控制消息大小与字段规范;避免过大导致性能问题。结合幂等与去重;确保重复处理不影响结果。长期堆积需滚动归档或转储到持久存储。

发表评论 取消回复