*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 >