Redis ZMPOP 如何按优先级批量取出任务：最小堆语义与空集合处理

任务调度表里经常有一列“优先级”，但真正取任务时，先查一批再删除会留下竞态：两个消费者可能拿到同一个成员。Redis ZMPOP 把“按分数选中”和“从 Sorted Set 删除”放在一次命令里，适合做短小、明确的优先级取件动作。

把优先级放进 Sorted Set 的 score，用 ZMPOP ... MIN COUNT n 一次取出并删除最低分任务；没有可取任务时按空数组处理，不要把空结果当成异常。

ZMPOP 解决的是“选中后立即移除”

Sorted Set 的成员唯一，score 用来排序。同一个 score 下，成员按字典序比较，所以不能把 score 相同理解成随机顺序。下面把任务 ID 作为 member，把 10、20、30 作为优先级，数字越小越先处理。

redis-cli ZADD priority:tasks 10 task:refund 20 task:invoice 30 task:email
redis-cli ZMPOP 1 priority:tasks MIN COUNT 2
1) "priority:tasks"
2) 1) "task:refund"
   2) "10"
   3) "task:invoice"
   4) "20"

返回值先给出实际命中的 key，再给出 member-score 对。执行完成后，task:refund 和 task:invoice 已经不在 priority:tasks 中；这正是它和“ZRANGE 查出来、再 ZREM”的关键差异。

MIN、MAX 与 COUNT 怎么落到业务规则

MIN 代表最低分优先，MAX 代表最高分优先。若业务定义是“数值越大越紧急”，就用 MAX，不要只改注释。COUNT 5 表示最多取五个，不承诺一定返回五个。

# 最高分优先，最多取 1 个
redis-cli ZMPOP 1 priority:tasks MAX COUNT 1

# 先确认剩余成员；这里只读，不会改变队列
redis-cli ZRANGE priority:tasks 0 -1 WITHSCORES

生产代码还要给每个 member 配一份任务详情，例如 task:refund 对应一个 Hash。ZMPOP 只负责队列索引的原子移除，不会替你保证“弹出后业务处理一定成功”。处理进程崩溃时，任务已经离开 Sorted Set，必须使用处理中集合、可靠日志或补偿表保存恢复依据。

多个 Sorted Set 的顺序不是全局最小堆

ZMPOP 可以传多个 key，但它会从参数列表中第一个非空的 Sorted Set 取成员，然后只在这个 key 内按 MIN 或 MAX 排序。它不会把所有 key 合并后寻找全局最低分。

redis-cli ZADD queue:critical 100 task:critical
redis-cli ZADD queue:normal 1 task:normal
redis-cli ZMPOP 2 queue:critical queue:normal MIN COUNT 1
# 命中 queue:critical，而不是分数更小的 queue:normal

因此，多队列写法表达的是“按队列优先级选来源”，不是“跨队列统一排序”。如果业务要求全局最小分，优先把任务写入同一个 Sorted Set；如果必须分队列，应用层要明确接受这种顺序，或分别消费后自行协调。

空集合、重复消费与故障恢复

当所有传入 key 都不存在或为空时，ZMPOP 返回空结果；使用客户端时应把它解释为“当前没有任务”，再结合轮询间隔或阻塞命令做调度。不要因为空结果就创建一个永久错误状态。

任务一旦弹出，Redis 只完成了队列侧的移除。要避免业务处理过程中进程退出造成丢单，可以把任务状态写入处理中 Hash，处理成功后删除；或者改用 Redis Streams 消费组，让 pending entries list 记录待确认消息。重试时要带业务幂等键，不能简单把同一任务无限塞回队列。

还有一个容易忽略的边界：ZMPOP 属于写命令，复杂度是 O(K) + O(M*log(N))，其中 K 是 key 数量、M 是弹出数量、N 是被选 Sorted Set 的成员数。批量大小不要用“越大越好”来决定，应该按单次业务处理时长和 Redis 延迟预算压测。

常见问题

ZMPOP 和 ZPOPMIN 有什么区别？

ZPOPMIN 只处理一个 Sorted Set；ZMPOP 可以传多个 key，并返回实际命中的 key。

COUNT 大于集合成员数会报错吗？

不会。实际弹出数量取集合当前成员数与 COUNT 中较小的值。

多个 key 会按所有任务的 score 统一排序吗？

不会。它先选择参数列表中的第一个非空 key，再在该 key 内按 MIN 或 MAX 取成员。

ZMPOP 能保证任务处理成功吗？

不能。它只保证队列成员被移除；业务侧需要处理中记录、幂等和失败补偿。

小结

用 ZMPOP 做优先级任务队列时，先确定 score 方向，再确定单队列还是多队列。单队列更接近真正的最小堆；多 key 则是“队列顺序优先、队列内 score 排序”。空结果是正常状态，弹出后的业务可靠性则需要由处理记录和补偿机制补上。