Redis如何利用ZSet处理具有过期时间的任务？-Redis-PHP中文网

zset不支持成员自动过期，需用score存时间戳并定时扫描；zrangebyscore必须用"-inf"和动态计算的时间戳，避免硬编码；推荐lua脚本原子性执行“取+删”；秒/毫秒精度依业务选择；无真正自动过期，依赖外部轮询或事件驱动。

redis如何利用zset处理具有过期时间的任务？

ZSet 本身不支持单个成员过期，但用 score 当时间戳 + 定时扫描，是目前最常用、最可控的延迟任务落地方式。

zrangebyscore 拉取到期任务必须用 "-inf" 范围

不能写成 zrangebyscore key 0 now 这种硬编码数值——因为 score 是 Unix 时间戳（秒级或毫秒级），而 now 不是 Redis 内置变量。实际要用客户端计算当前时间戳传入，或在 Lua 脚本里调用 redis.call("TIME") 获取。

正确示例（Python）：r.zrangebyscore("delay_queue", "-inf", str(int(time.time())))
错误写法：zrangebyscore delay_queue 0 1720862160 —— 每次都要动态算，硬编码会漏任务
注意：如果 score 存的是毫秒时间戳（如 Java System.currentTimeMillis()），那比较时也得用毫秒，别混用秒和毫秒

zremrangebyscore 清理已处理任务要配合原子性保障

拉出任务 → 执行业务 → 删除任务，这三步不是原子的。若执行完业务但删除失败，会导致重复触发。所以推荐用 zremrangebyscore 在确认执行前就删，或者用 Lua 脚本把“取+删”打包成一步。

Redis 8.2.3

Redis 8.2.3 是一款安全优先的高性能键值存储系统。该版本紧急修复了可能引发远程代码执行（RCE）的高危漏洞（CVE-2025-62507），并解决了 HyperLogLog 及 Cuckoo Filter 等数据结构在特定场景下的崩溃问题。建议所有用户立即升级，以保障生产环境的系统稳定与数据安全。

下载

安全做法（Lua）：

local tasks = redis.call("ZRANGEBYSCORE", KEYS[1], "-inf", ARGV[1])<br>if #tasks > 0 then<br>  redis.call("ZREMRANGEBYSCORE", KEYS[1], "-inf", ARGV[1])<br>end<br>return tasks

不推荐裸用 zrangebyscore + zrem 两步：中间 crash 或网络中断会导致任务残留或重复
如果任务执行耗时长，建议先 zrem 再执行，避免其他 worker 同时捞到同一任务

score 精度选秒还是毫秒取决于业务容忍度

秒级精度适合分钟级延迟任务（如短信重发、订单超时关单）；毫秒级适合亚秒级调度（如实时竞价、心跳续期），但会增加 Redis 内存占用和排序开销。

Java 示例存毫秒：template.opsForZSet().add("queue", taskId, System.currentTimeMillis() + 5000)
Python 存秒更省：r.zadd("queue", {task_id: int(time.time()) + 30})
注意：Redis 的 TIME 命令返回的是秒级时间戳（数组第一项），想对齐毫秒需乘 1000，否则 Lua 里比大小会错位