Redis Streams

定义

Redis Streams 是 Redis 5.0(2018 年)引入的日志型数据结构,由作者 Salvatore Sanfilippo 设计,灵感部分来自 Kafka。它以只追加的方式存储条目,每个条目有单调递增的 ID(默认为毫秒时间戳加序号)和一组字段值对。

核心能力

• XADD 追加、XRANGE 按 ID 区间读取、XREAD 阻塞式监听新消息;
• 消费组(XGROUP/XREADGROUP):多个消费者分摊消费,配合 XACK 确认;未确认消息进入待处理列表(PEL),可用 XCLAIM/XAUTOCLAIM 转移给其他消费者,实现故障接管;
• 支持 MAXLEN 修剪控制内存占用。

与其他方案对比

相比 Redis 原有的 List(BRPOP)和 Pub/Sub,Streams 既能持久保留消息、支持多消费组独立消费,又有确认与重投机制,可靠性明显更强;但相比 Kafka,它受内存容量限制、无分区水平扩展概念,定位是轻量级场景。

应用

适合站内消息、任务队列、事件缓冲等中小规模场景,避免为轻需求引入重型消息系统。