hyperf用redis zset实现延迟任务需严控三环节：写入时score必须为整型绝对时间戳，member须唯一可反序列化；扫描须用lua脚本原子执行“取+删”，禁用非原子的zrangebyscore+zrem；多实例部署需通过task进程或redis分布式锁避免重复扫描。
Hyperf 里用 Redis ZSet 实现延迟任务，核心就三步
不是配个 hyperf/redis 就能跑起来，关键在「写入时机」「扫描逻辑」「并发争抢」三个环节。ZSet 的 score 必须是绝对时间戳（比如 time() + 1800），不能是相对秒数；member 必须可反序列化且带唯一标识（如订单号）；扫描不能靠 zRangeByScore 拿完再删，否则多 Worker 下大概率重复消费。
为什么不能直接用 zRangeByScore + zRem 两步走
因为这不是原子操作。两个 Worker 同时查到同一条 score ≤ now 的任务，都拿到 member，接着各自调 zRem，只有一个成功，另一个执行了无效逻辑（比如重复关单）。真实线上环境必须用 Lua 脚本把“取+删”锁死在 Redis 服务端：
local tasks = redis.call('ZRANGEBYSCORE', KEYS[1], 0, ARGV[1], 'LIMIT', 0, 1)
if #tasks > 0 then
redis.call('ZREM', KEYS[1], tasks[1])
return tasks[1]
end
return nil
Hyperf 中可通过 $redis->eval($script, 1, $key, $now) 调用，避免业务层做 if-else 判断。
DelayQueueService 类里要注意的四个参数细节
你封装的队列服务类里，这几个地方不注意就会卡住：
-
zAdd的score必须是整型时间戳，PHP 的time()可以，但microtime(true)不行——ZSet 不支持浮点 score -
zRangeByScore的min建议设为0，而不是-inf，避免 Redis 解析开销 -
zAdd的member推荐用 JSON 字符串，但必须确保不含控制字符或未转义双引号，否则json_decode失败 - 扫描间隔别设成 1 秒轮询——高并发下 Redis QPS 爆涨；建议用
swoole_timer_tick(5000, ...)每 5 秒扫一次，配合 Lua 原子操作已足够及时
多实例部署时，如何避免多个进程同时启动扫描器
Hyperf 默认每个 Worker 进程都会加载你的定时扫描逻辑，结果就是 N 个进程每 5 秒都去 Redis 查一遍。解决方式只有两种：
- 用
Swoole\Server::task把扫描逻辑扔进 Task 进程，再通过@OnTask注解绑定，确保全局只有一份执行体 - 加 Redis 分布式锁：在扫描前
setnx delay_queue:scan_lock 1，并设expire 10，抢到锁的才执行，其余跳过 - 更稳妥的做法是结合两者：Task 进程内先拿锁，再执行 Lua 扫描，完成后释放锁
真正难的不是写对 ZSet 命令，而是让多个 PHP 进程在无协调机制下不互相干扰——这点在本地单 Worker 测试时完全暴露不出来，上线后才会暴雷。
