Redis Stream消息流实战：从Producer到Consumer Group

## Redis Stream数据结构核心 Redis Stream是Redis 5.0引入的日志型数据结构，设计灵感来自Kafka和Pulsar。Stream是追加操作有序消息链表，每条消息由唯一ID和键值对字段组成。ID由毫秒时间戳加序列号组成确保全局唯一且按时间有序。XADD追加XREAD读取XRANGE范围查询。相比List支持持久化和消费者组，相比Pub/Sub消息不因离线丢失。消费者组通过XGROUP CREATE创建，组内消费者共同消费消息，组自动跟踪消费进度（Last Delivered ID），XACK确认消费完成。消费者崩溃时XCLAIM认领未确认消息实现故障恢复。 ## 消费机制与可靠性保障 XREADGROUP的BLOCK参数实现阻塞等待新消息到达。MAXLEN限制消息长度配合波浪号近似裁剪避免一次性删除大量数据的性能开销。ID设为大于号只消费新消息，设为0-0消费全部历史消息。Spring Data Redis提供StreamMessageListenerContainer声明式消费。Spring Cloud Stream提供Redis Stream Binder。Stream消息持久化在RDB和AOF中重启不丢失。相比List和Pub/Sub，Stream在生产级消息的可靠性、可追踪性和消费管理能力有质的飞跃，适合中小规模系统消息中间件。 ## 性能优化与集群部署 单条XADD微秒级，Pipeline批量写入显著提升吞吐。消息体控制1KB以内减少内存网络开销。COUNT控制每次读取数量配批量处理。集群模式Stream按ID hash分布同组消息在同一分片可能导致热点——用Key前缀分布到不同Stream横向扩展。Redis Sentinel或Cluster提供冗余和自动故障转移。监控Stream长度增长趋势、XPENDING积压量和消费延迟。告警覆盖长度超限、消费者离线超时和延迟超SLA。连接池配置对消费性能有直接影响。