PHP任务队列：RabbitMQ、Gearman和PhpAmqpLib

PHP任务队列：RabbitMQ、Gearman和PhpAmqpLib

在现代Web应用中，对用户的响应速度至关重要。长时间运行的操作（如发送邮件、生成PDF、处理图像、数据解析）不应阻塞主执行流程。解决这个问题的方法是使用任务队列（job queues）。它们允许将后台任务委托给异步工作的工作者进程。

在PHP生态系统中，有几种成熟的解决方案可用于组织队列。我们来考察三个关键工具：PhpAmqpLib（RabbitMQ的客户端）、Gearman以及通过其AMQP协议使用的原生RabbitMQ。

为什么PHP中需要任务队列？

典型场景：用户在网站上注册。系统需要：

• 将数据保存到数据库
• 发送欢迎邮件
• 创建PDF合同
• 启动垃圾邮件检查

没有队列时，用户需要等待所有操作完成。使用队列后：

• 主进程保存数据并将任务发送到队列
• 用户立即收到“成功”响应
• 后台工作者依次处理任务

这提升了用户体验和系统稳定性。

1. RabbitMQ和PhpAmqpLib

RabbitMQ是一个强大的消息代理，支持AMQP 0-9-1协议。PhpAmqpLib是一个纯PHP实现的客户端，用于与RabbitMQ交互，无需外部扩展。

安装

composer require php-amqplib/php-amqplib

示例：发送任务（生产者）

<?phprequire_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\\Connection\\AMQPStreamConnection;use PhpAmqpLib\\Message\\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');$channel = $connection->channel();

// 声明队列（如果不存在则创建）$channel->queue_declare('email_queue', false, true, false, false);

$data = json_encode([    'to' => 'user@example.com',    'subject' => '欢迎',    'body' => '欢迎！']);

$msg = new AMQPMessage($data, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);$channel->basic_publish($msg, '', 'email_queue');

echo " [x] 已发送: $data";

$channel->close();$connection->close();

示例：工作者（消费者）

<?phprequire_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\\Connection\\AMQPStreamConnection;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');$channel = $connection->channel();

$channel->queue_declare('email_queue', false, true, false, false);

echo " [*] 等待任务。按CTRL+C退出";

$callback = function ($msg) {    $data = json_decode($msg->body, true);    // 模拟发送邮件    echo " [x] 发送邮件至 {$data['to']}: {$data['subject']}";    sleep(2); // 模拟工作    echo " [x] 完成";    $msg->ack(); // 确认处理};

$channel->basic_qos(null, 1, null);$channel->basic_consume('email_queue', '', false, false, false, false, $callback);

while ($channel->is_consuming()) {    $channel->wait();}

优点：可靠性高，支持复杂路由（主题、标头），消息持久化，集群支持。

缺点：需要安装和配置RabbitMQ服务器（Erlang，通过Web界面管理）。

2. Gearman

Gearman是一个分布式任务系统。由三个组件组成：客户端（发送任务）、工作者（执行任务）、服务器（调度器）。通过二进制协议工作。

安装

首先安装Gearman服务器和PHP扩展：

sudo apt-get install gearman-job-s