rmdir.cn

XREAD

从 Stream 读取消息

语法

XREAD [COUNT count] [BLOCK ms] STREAMS key [key ...] ID [ID ...]

说明

XREAD 从一个或多个 Stream 中读取消息。支持阻塞读取(BLOCK)、从指定 ID 之后读取。

参数

  • COUNT

    最多返回的消息数量

  • BLOCK

    阻塞等待的毫秒数(0 表示无限)

  • ID必填

    起始消息 ID($ 最新,0-0 从头)

示例

读取所有消息

从 Stream 开头读取

XREAD STREAMS mystream 0-0

阻塞读取

等待新消息(最多 5 秒)

XREAD BLOCK 5000 STREAMS mystream $

限制数量

只读取最新的 10 条

XREAD COUNT 10 STREAMS mystream 0-0