如何用Redis实现按优先级和入队时间排序的任务优先队列

针对你需要的「优先级高先出队，同优先级入队早先出队」的需求，Redis的**有序集合（Sorted Set）**是最适合的实现方案，完全可以替代Java的PriorityQueue，且能支持分布式场景，精度和可靠性都有保障。

核心思路 #

利用Sorted Set的score排序特性，将「优先级+入队时间」组合成一个无冲突的score，让Sorted Set自动按规则排序，出队时直接取排序最靠前的元素即可。

具体的score设计逻辑：

• 优先级越高，score的高位数值越大，保证高优先级任务排在前面
• 同优先级下，入队时间越早，score的低位数值越大（通过Long.MAX_VALUE - 时间戳实现），保证早入队的任务排在前面

这样Sorted Set会自动按score从大到小排序，用ZPOPMAX命令就能直接取出符合规则的任务。

具体实现步骤 #

1. 入队操作 #

• 为每个任务生成唯一ID（比如UUID），任务的具体内容可以存在Redis的String或Hash结构中，用任务ID作为key
• 计算score：

  // 假设priority是整数类型，范围比如0-1000
  long priority = task.getPriority();
  long timestamp = System.currentTimeMillis();
  // 用10^13作为优先级和时间戳的分隔（毫秒时间戳是13位），避免数值重叠
  long score = priority * 10000000000000L + (Long.MAX_VALUE - timestamp);
  

• 执行Redis命令：

  ZADD task_queue <score> <task_id>
  

2. 出队操作 #

• 原子性取出并删除排序最靠前的任务：

  ZPOPMAX task_queue
  

• 拿到任务ID后，从Redis中取出对应的任务内容执行，执行完成后可删除任务内容的key：

  GET task:<task_id>
  DEL task:<task_id>
  

3. 批量出队（可选） #

如果需要一次性取出多个任务，用Lua脚本保证原子性，避免任务被重复取走：

-- 入参：KEYS[1]是队列名，ARGV[1]是要取出的任务数量
local taskIds = redis.call('ZREVRANGE', KEYS[1], 0, ARGV[1]-1)
if #taskIds > 0 then
    redis.call('ZREM', KEYS[1], unpack(taskIds))
end
return taskIds

调用方式：

EVAL "上面的Lua脚本内容" 1 task_queue 5

细节优化 #

• 避免时间戳冲突：如果同一毫秒内有大量同优先级任务，可改用纳秒级时间戳（System.nanoTime()），或者在score中加入Redis全局自增序列（用INCR生成），确保同优先级任务的score唯一且顺序正确
• 持久化保障：开启Redis的RDB或AOF持久化，避免重启后任务丢失
• 重试机制：任务执行失败需要重试时，重新计算score（用当前时间作为入队时间）后再次入队，重试任务会排在同优先级任务的后面，符合预期
• 性能优化：Sorted Set的ZADD、ZPOPMAX都是O(logN)复杂度，性能足够支撑高并发场景

内容的提问来源于stack exchange，提问作者Jack Yer