PHP 任务队列：初学者完整指南

PHP 任务队列简介

在现代 Web 开发中，经常需要执行耗时或资源密集型操作，而又不让用户等待。例如：发送邮件群发、生成 PDF 报告、处理图像或与外部 API 集成。这时，任务队列 (job queues) 就派上了用场——它是后端开发人员的关键工具之一。

任务队列是一种机制，允许将资源密集型操作推迟到后台执行，从而释放应用程序的主线程来处理新的请求。在本文中，我们将详细讲解如何在 PHP 中处理任务队列，从基本概念到实际示例。

什么是任务队列，为什么需要它？

想象一下，您的网站在用户注册后需要发送 1000 封邮件。如果同步执行，页面将加载几分钟。用户会离开，服务器也会被阻塞。队列解决了这个问题：发送邮件的任务被放入队列，由后台工作进程处理，而用户会立即收到响应。

使用队列的主要优势

\n
• 改善用户体验 — 用户无需等待长时间操作完成
\n
• 提高性能 — 服务器处理请求更快
\n
• 可扩展性 — 可以添加更多工作进程来处理队列
\n
• 容错性 — 任务失败时可以重新放入队列
\n
• 任务调度 — 在特定时间执行任务
\n

PHP 任务队列架构

典型的队列系统由三个组件组成：

\n
• 生产者 (Producer) — 将任务添加到队列的代码部分
\n
• 队列 (Queue) — 任务存储（通常基于 Redis、Beanstalkd 或数据库）
\n
• 工作进程 (Worker) — 持续监听队列并执行任务的脚本
\n

在 PHP 中，处理队列最常用的库是 php-resque、Laravel Queue（如果您使用 Laravel）或 enqueue/fs。我们将介绍一种通用方法，可以适应任何框架。

实践示例：使用纯 PHP 创建任务队列

让我们使用 Redis 创建一个简单的队列系统。安装 Redis 和 phpredis 扩展，或通过 Composer 使用 predis/predis。

步骤 1：环境准备

composer require predis/predis

步骤 2：创建生产者

生产者将任务添加到队列。创建文件 producer.php：

<?php\nrequire 'vendor/autoload.php';\n\nuse Predis\\Client as RedisClient;\n\nclass JobProducer {\n    private $redis;\n    \n    public function __construct() {\n        $this->redis = new RedisClient([\n            'scheme' => 'tcp',\n            'host'   => '127.0.0.1',\n            'port'   => 6379,\n        ]);\n    }\n    \n    public function addJob(string $queueName, array $jobData): void {\n        $job = json_encode([\n            'id' => uniqid(),\n            'data' => $jobData,\n            'created_at' => time()\n        ]);\n        \n        // 使用 RPUSH 将任务添加到队列末尾\n        $this->redis->rpush("queue:{$queueName}", $job);\n        echo "任务已添加到队列 {$queueName}\\n";\n    }\n}\n\n// 使用示例\n$producer = new JobProducer();\n$producer->addJob('emails', [\n    'to' => 'user@example.com',\n    'subject' => '欢迎！',\n    'body' => '感谢您的注册...'\n]);\n?>

步骤 3：创建工作进程

工作