Redis BZMPOP 怎样阻塞等待多个排名集合的数据

Redis 里有多个按分数排序的待处理集合时，BZMPOP 可以把“找数据”和“等待数据”合成一次操作：只要任意集合有成员，就按 MIN 或 MAX 取出；如果全部为空，连接会等待新成员到来或等待超时。它要求 Redis 7.0 及以上，最容易出错的地方是 numkeys、COUNT 和集群 key 槽位。

先确认 BZMPOP 的阻塞边界

BZMPOP 是 ZMPOP 的阻塞版本。假设高优先级和普通优先级各有一个 sorted set，消费者不必先轮询两个 key：Redis 会从参数中的 key 列表寻找可取数据。只要找到一个非空集合，命令按指定方向弹出成员；只有全部集合都为空时，才进入等待。

timeout 是最多阻塞的秒数，可以是小数；值为 0 表示一直等。建议把它和消费者的处理周期、客户端读超时一起设计，避免服务端还在等而客户端已经断开。命令在事务或 Lua 脚本中不会保持阻塞，而是按非阻塞的 ZMPOP 语义执行。

按语法组织多个有序集合

命令顺序固定为：timeout numkeys key [key ...] MIN|MAX [COUNT count]。例如一次最多取三个最低分成员：

# numkeys=2，后面必须正好跟两个 sorted-set key
redis-cli BZMPOP 10 2 jobs:high jobs:normal MIN COUNT 3

这里最多等待 10 秒，检查两个集合，并从优先级列表中选择最低分成员。MIN 适合分数越小越早处理的队列，MAX 则取最高分；COUNT 省略时默认是 1。不要把 key 数量写成 1，也不要把 COUNT 放到 key 列表之前，否则 Redis 会把参数解释错。

处理返回 key 与成员分数

成功返回的是二元素结构：第一部分是实际弹出数据的 key，第二部分是成员与分数组成的列表。即使传入多个集合，也不能根据参数列表下标猜测来源；应以返回的 key 为准。若取完最后一个成员，Redis 会删除对应的 sorted set。

# 用 RESP2 查看返回结构；命令本身不会返回“第几个 key”
redis-cli --raw BZMPOP 2 2 jobs:high jobs:normal MIN COUNT 2

当等待到期且没有成员可取时，RESP2 返回 Nil，RESP3 返回 Null。应用层应把它当成“本轮没有任务”，而不是把空值写入任务表。批量消费时还要注意，复杂度为 O(K) + O(M*log(N))，其中 K 是 key 数，M 是弹出数量，N 是有序集合中的元素数。

在生产环境收紧连接与集群边界

阻塞命令占用一个客户端连接。消费者池应为等待连接设置数量上限，并让 timeout 小于客户端读超时，超时后由应用记录一次空轮询并重新发起命令。若业务确实需要长等待，可以使用较大的有限值，但仍要让优雅停机能够关闭阻塞连接。

Redis Cluster 中，BZMPOP 属于多 key 写操作，多个 key 需要落在同一个 hash slot。可以把相关队列写成 {jobs}:high、{jobs}:normal，让花括号内的 hash tag 一致；否则可能出现 CROSSSLOT。这不是性能参数问题，而是数据布局边界，应该在建 key 规范时一次确定。

# 用相同 hash tag 让多个队列进入同一 slot
redis-cli BZMPOP 5 2 '{jobs}:high' '{jobs}:normal' MAX COUNT 1

常见问题

BZMPOP 和 ZMPOP 的主要区别是什么

BZMPOP 增加了等待语义；有数据时两者的弹出行为一致，全部为空时前者等待，后者立即返回空值。

timeout 写 0 是否更适合消费者

不一定。它会无限阻塞，适合由连接管理器明确控制生命周期的场景；普通服务更容易使用有限超时配合取消和重连。

为什么多个 key 会出现 CROSSSLOT

Redis Cluster 要求这类多 key 操作在同一槽位。给相关 key 使用相同 hash tag，或重新设计为单 key 队列，才能解决。

把 BZMPOP 当作“带等待的批量有序弹出”即可：先固定分数方向，再校准 key 数量，最后根据返回 key 处理结果，并为阻塞连接和 Cluster 槽位留下明确边界。