PHP异步任务队列实现-php教程-PHP中文网

PHP实现异步任务本质是剥离耗时操作交由外部进程处理，主流方案为：1. Redis+CLI Worker（轻量级）；2. RabbitMQ/Kafka+php-amqplib（中高可用）；3. 第三方SaaS（免运维）。

php异步任务队列实现

PHP里没有原生异步任务队列

PHP 进程天生是同步阻塞的，fpm 或 cli 执行完当前脚本就退出，不存在“后台常驻线程”这种东西。所谓“PHP异步任务队列”，本质是把耗时操作剥离出主请求流程，交由外部进程或服务处理——你得靠别的程序来兜底。

常见错误现象：sleep(10) 放在控制器里，用户等 10 秒白屏；用 exec("php job.php &") 启动子进程，结果父进程一结束子进程就被 kill（尤其在 FPM 下）；或者直接在代码里开 pcntl_fork()，但没做信号处理、资源回收，跑几天后进程堆积、内存泄漏。

别指望 set_time_limit(0) + ignore_user_abort(true) 实现可靠队列——HTTP 连接断开后，FPM worker 可能随时回收该进程
CLI 模式下用 pcntl 要手动管理子进程生命周期，且 Windows 不支持
所有“伪异步”方案（如 curl_multi、stream_socket_client 非阻塞调用）只适用于 I/O 并发，不解决 CPU 密集型任务排队问题

真正可用的三种落地方式

选哪种取决于你的部署环境、运维能力、任务量级。没有银弹，只有权衡。

轻量级：Redis + 独立 CLI Worker —— 用 LPUSH 推任务，BRPOP 阻塞拉取，Worker 进程常驻运行。适合中小流量、单机部署。注意设置 timeout 参数防卡死，用 php -d max_execution_time=0 worker.php 启动，并配合 supervisord 管理进程生死
中高可用：RabbitMQ / Kafka + php-amqplib —— 利用消息中间件的持久化、ACK、重试机制。需额外维护 MQ 服务，但任务不丢、可监控、支持横向扩展。注意 channel->basic_qos 设置预取数量，避免 Worker 积压太多未确认消息
免运维托管：第三方 SaaS（如 Bunny.net Tasks、Cloudflare Workers + KV） —— 把任务 JSON POST 过去，回调 URL 接收结果。省心但可控性低，不适合含敏感数据或强事务一致性要求的场景

用 Redis 实现最简可用队列的实操要点

别从零写调度器。直接用 phpredis 扩展 + 简单结构，5 分钟能跑起来。

任务推入：

btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理：站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

$redis->lPush('queue:send_email', json_encode([
    'to' => 'user@example.com',
    'template' => 'welcome',
    'data' => ['name' => 'Alice']
]));

Worker 轮询（关键！不能用 LRANGE）：

// 阻塞 3 秒，没任务就继续等
$job = $redis->brPop(['queue:send_email'], 3);
if ($job) {
    $payload = json_decode($job[1], true);
    sendEmail($payload); // 你的业务逻辑
}

必须用 BRPOP，不是 RPOP —— 否则空轮询打爆 Redis CPU
不要在 Worker 里做 sleep(1) 等待，那只是掩盖问题，实际是忙等
任务失败时，别直接丢弃。写个 queue:failed list 存失败原始数据，方便人工重放
CLI Worker 启动命令加 --no-ansi 和 -d display_errors=stderr，方便日志捕获

为什么 Laravel Horizon 或 Symfony Messenger 不建议新手直接上

它们封装了底层细节，但隐藏了关键决策点。比如 Horizon 默认用 Redis 的 zset 做延迟队列，但如果你没调大 redis.maxmemory 或没配 maxmemory-policy，延迟任务积压会导致 Redis OOM；Messenger 的 failure_transport 默认写文件，上线后磁盘被日志撑爆却查不到源头。