PHP结合Redis实现异步任务队列方法

本文深入剖析了如何在PHP中借助Redis构建高可靠、生产级的异步队列系统，涵盖从最简LPUSH+BRPOP实现FIFO队列、到RPOPLPUSH原子转移防任务丢失、再到多Worker并发下的幂等设计与CLI常驻进程的健壮保活机制；既纠正了常见误区（如误用POP导致CPU飙升、混淆RPUSH/LPOP破坏顺序），也直面分布式现实——不追求“绝不重复”，而是通过唯一ID、SETNX锁和状态校验让任务天然可重入，并强调真正的可靠性依赖进程管理器（如supervisord）与持久化状态协同，而非仅靠Redis命令堆砌。

用 LPUSH + BRPOP 实现最简可靠队列

PHP 本身没内置队列，靠 Redis 是目前最轻量、最可控的异步方案。核心就是两个命令：LPUSH 往队列尾部塞任务，BRPOP 阻塞式从头部取任务——它比 POP 多一个超时参数，避免 worker 空转轮询。

常见错误是直接用 POP 写死循环，CPU 拉满还漏任务；或者用 RPUSH/LPOP 搞反顺序，导致任务执行顺序错乱。

• LPUSH queue_name {"job":"send_email","to":"user@x.com"} —— 入队用 LPUSH，保证 FIFO（先进先出）
• BRPOP queue_name 30 —— 出队必须用 BRPOP，30 秒超时，不忙等
• worker 启动后应先检查 Redis 连接是否存活，再进入 BRPOP 循环，否则一连失败就卡死

任务失败时怎么避免丢数据？用 RPOPLPUSH 做原子性转移

单纯 BRPOP 取出任务后，如果 PHP 进程崩溃或处理中途出错，这个任务就丢了。真正可用的队列必须支持“取出但暂不删除”，等确认执行成功再清理。

RPOPLPUSH 就是干这事的：它把任务从主队列弹出，同时推到一个临时队列（比如 queue_name_processing），整个过程原子执行，不会出现“弹出了却没推过去”的中间态。

• 入队仍用 LPUSH queue_name ...
• 取任务改用 RPOPLPUSH queue_name queue_name_processing
• 处理成功后，用 LREM queue_name_processing 1 "task_json" 删除；失败则跳过删除，让监控脚本定期扫 queue_name_processing 重投
• 注意：Redis 6.2+ 支持 LMOVE，语义更清晰，但老版本只能靠 RPOPLPUSH

多个 worker 并发消费时，为什么任务会被重复执行？

根本原因不是 Redis，而是 PHP 层没做幂等控制。即使 RPOPLPUSH 保证了“取出”原子性，只要 worker 在处理完、删任务前崩溃，重启后就会重新取到同一任务。

这不是 bug，是分布式系统常态。解决方式不是防“重复取”，而是接受重复，并确保任务本身可重入。

• 给每个任务加唯一 id 字段（如 UUID），处理前先查数据库或 Redis 是否已标记为 done
• 关键操作加 SETNX job_id:done 1 EX 3600，防止并发写入
• 邮件类任务天然幂等（发两遍邮箱也不会炸），但扣款类必须校验状态，不能只靠队列机制兜底
• 别指望 Redis 的 WATCH + MULTI 来锁整个流程——太重，且跨命令无法保证

PHP-FPM 场景下，BRPOP 长连接容易被 kill，怎么保活？

Web 请求里直接跑 BRPOP 是自杀行为。PHP-FPM 默认 max_execution_time=30，而 BRPOP 超时设成 30 秒，刚等上就超时，还可能触发 FPM 的 request_terminate_timeout 强杀进程。

队列 worker 必须脱离 Web 生命周期，用 CLI 模式常驻运行。

• 启动命令写成 php /path/to/worker.php &，加 & 后台化
• worker 脚本开头加 set_time_limit(0)，禁用超时
• 用 pcntl_signal 捕获 SIGTERM，优雅关闭（比如处理完当前任务再退出）
• 别用 nohup 简单包裹了事——没信号处理，kill -9 一来就丢任务

真正难的从来不是怎么塞进队列，而是怎么让 worker 在服务器重启、OOM killer、网络抖动之后，还能接着上次断点往下跑。这部分得靠进程管理器（supervisord/systemd）+ 持久化状态（比如用 Redis 记录最后处理的 task_id）来补全，光靠 PHP 和 Redis 搞不定。

理论要掌握，实操不能落！以上关于《PHP结合Redis实现异步任务队列方法》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！