目录

  1. Stream概述
  2. 常用命令
  3. Stream数据模型
  4. Stream的应用场景
  5. 性能优化
  6. 使用注意事项
  7. 参考资料

1. Stream概述

Redis Stream 是 Redis 5.0 引入的一种新的数据类型，旨在提供高效的 消息队列 和 日志存储 功能。Stream 数据类型支持类似 消息队列 的功能，同时也具备高效的 按时间顺序读取数据 和 消费者组管理 等特性。它允许应用程序以流的形式处理数据，支持生产者（写入）和消费者（读取）的解耦操作。

Stream 可以用于构建分布式日志系统、事件流处理和任务队列等场景，具备高吞吐量和高可用性。

2. 常用命令

Redis Stream 提供了一系列命令来操作数据流和管理消费者组。

命令描述
XADD key ID field value [field value ...]向流中添加一条消息，ID 可以指定消息的唯一标识符。
XRANGE key [start] [end] [COUNT count]获取流中的消息，根据 ID 范围返回消息。
XREAD [BLOCK milliseconds] [COUNT count] STREAMS key [key ...]从流中读取消息。
XGROUP CREATE key groupID ID创建一个消费者组。
XREADGROUP GROUP groupID consumer STREAMS key [key ...]从消费者组读取消息。
XACK key groupID ID [ID ...]确认消费某条消息。
XDEL key ID [ID ...]删除一条或多条消息。

示例：