Redis Streams 事件驱动与消费者组治理（2025）

Redis Streams 事件驱动与消费者组治理（2025）一、模型与命令基本命令：`XADD` 写入事件、`XREAD`/`XREADGROUP` 读取、`XACK` `确认` 消费。消费者组：`XGROUP CREATE` 建组与游标初始化；多消费者并发。二、待处理队列与重试待处理队列：`XPENDING` 观测未确认消息；对超时消息使用 `XCLAIM` 进行转移与重试。重试策略：指数退避与最大重试次数；死信队列记录异常事件。回溯：通过游标与范围读取实现事件 `回溯` 与重放。三、扩展与限流扩展：按分片或多流拆分热点；消费者水平扩展并按键路由。限流：对生产/消费侧设定速率与并发上限，防止队列堆积。去重：以事件 ID 或业务键去重，避免重复处理。四、观测与维护指标：队列长度、滞留时间、确认率、重试/转移次数。维护：定期压缩与清理历史；设置最大长度与修剪策略。安全：权限与命名空间隔离。注意事项关键词（Redis Streams、消费者组、确认、待处理队列、回溯）与正文一致。分类为“数据/消息/Redis”，不超过三级。参数需在真实负载与容灾演练中验证。