*Redis XREADGROUP 命令 以消费者组方式读取 Stream 消息

*语法

XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] ID [ID ...]

*说明

以消费者组的方式从多个 Stream 读取消息。

选项

  • NOACK:不将消息加入 pending 列表(不需要 XACK)
  • >:读取新的未分配消息

*返回值

  • 数组:消息列表或 nil

*时间复杂度

  • O(N),N 是返回的消息数量

*版本兼容性

Redis 版本 说明
>= 5.0.0 可用

*示例

# 消费者组读取新消息
redis-cli XREADGROUP GROUP mygroup consumer1 STREAMS mystream >

# 阻塞等待
redis-cli XREADGROUP GROUP mygroup consumer1 BLOCK 5000 STREAMS mystream >