Redis XREADGROUP 没有新消息时怎么设置阻塞时间

用 Redis Stream 做消费组时，如果队列暂时没有新消息，XREADGROUP 不必忙等。把等待上限写在 BLOCK 后面即可：BLOCK 2000 表示最多等待 2000 毫秒，超时后返回空结果；BLOCK 0 则是不设上限的持续等待。

实时消费新消息时，常用写法是 XREADGROUP ... COUNT 10 BLOCK 2000 STREAMS orders >。注意，只有读取新消息的 > 游标适合配合阻塞；用 0 等历史 ID 读取当前消费者的待处理消息时，BLOCK 会被忽略。

先把等待时间写在 BLOCK 后面

最小命令可以这样写。COUNT 控制一次最多取多少条，BLOCK 只负责“没有可返回消息时等多久”。两个参数不要混为一谈。

# 最多取 10 条；没有新消息时等待 2 秒
redis-cli XREADGROUP GROUP order-workers consumer-a COUNT 10 BLOCK 2000 STREAMS orders >

# 0 表示无限等待，适合由外部信号负责停止的常驻消费者
redis-cli XREADGROUP GROUP order-workers consumer-a COUNT 10 BLOCK 0 STREAMS orders >

BLOCK 2000 不是“每 2 秒拉一次”的定时器，而是一次读取请求的最长等待时间。已经有可读消息时，命令会直接返回；没有消息时，Redis 最多等到这个时间点，然后让客户端自己决定继续循环、检查停止信号或执行重连。

为什么写了 BLOCK 还是像不阻塞

最常见的原因不是 BLOCK 失效，而是读取游标写错了。消费组读取新消息时使用 >；如果消费者中途崩溃，已经投递但还没有确认的消息会留在 Pending Entries List（PEL）里，此时需要用 0 或其他有效 ID 读取自己的待处理记录。

# 读取当前消费者尚未确认的历史消息；这里的 BLOCK 不负责等待新消息
redis-cli XREADGROUP GROUP order-workers consumer-a COUNT 10 STREAMS orders 0

# 待处理消息处理完并 XACK 后，再回到新消息游标
redis-cli XREADGROUP GROUP order-workers consumer-a COUNT 10 BLOCK 2000 STREAMS orders >

官方命令说明明确规定：当 STREAMS 后的 ID 不是 > 时，读取的是该消费者自己的待处理历史，BLOCK、NOACK 和 CLAIM 都不参与这次读取。因此，排查“为什么没有等待”时，先看 ID，再看毫秒值。

循环里怎样把超时变成可控信号

在客户端代码里，有限阻塞通常比无限阻塞更容易治理。下面用 go-redis 的参数表达同一件事：超时回到循环，真正的网络错误才进入重试或告警分支。

// 每轮最多等待 2 秒，便于检查退出信号和连接状态。
args := &redis.XReadGroupArgs{
    Group:    "order-workers",
    Consumer: "consumer-a",
    Streams:  []string{"orders", ">"},
    Count:    10,
    Block:    2 * time.Second,
}

streams, err := rdb.XReadGroup(ctx, args).Result()
if err == redis.Nil {
    // 没有新消息只是本轮超时，继续下一轮，不当成故障。
    continue
}
if err != nil {
    return err // 网络或服务错误交给上层重试策略
}

// 业务处理成功后再 XACK，避免消息过早离开 PEL。
for _, stream := range streams {
    for _, message := range stream.Messages {
        if err := handle(message); err != nil {
            return err
        }
        if err := rdb.XAck(ctx, "orders", "order-workers", message.ID).Err(); err != nil {
            return err
        }
    }
}

这里的关键不是把等待时间调得越大越好，而是让它小于应用的优雅退出、连接保活和故障探测窗口。若使用 BLOCK 0，请确认客户端能够被取消，否则进程可能一直卡在读取调用里。

按场景选择 BLOCK 和游标

常见问题

BLOCK 的单位是秒还是毫秒？

是毫秒。BLOCK 2000 约等于最多等待 2 秒，客户端自己的网络超时仍需单独配置。

超时没有消息时要执行 XACK 吗？

不用。没有返回消息就没有待确认的消息；只有业务处理成功后，才对具体消息 ID 执行 XACK。

为什么读取 PEL 时 BLOCK 没效果？

因为非 > 的 ID 表示读取当前消费者的待处理历史，命令规定此时忽略 BLOCK。先恢复 PEL，再用 > 等待新消息。