PHP任务队列：RabbitMQ、Beanstalkd和Gearman

PHP任务队列：RabbitMQ、Beanstalkd和Gearman

在现代Web应用程序中，经常需要异步执行耗时或资源密集型操作，而无需用户等待响应。典型示例包括：发送邮件通知、生成报告、处理图像、与外部API交互。为了解决这些问题，PHP中使用了任务队列（job queues）。它们允许将请求逻辑与后台处理分离，从而提高界面响应速度和系统可扩展性。

在本文中，我们将详细介绍三种用于在PHP中组织队列的流行工具：RabbitMQ、Beanstalkd和Gearman。您将了解它们的特点、架构、使用示例，并学会为您的项目选择最合适的解决方案。

1. RabbitMQ

RabbitMQ是一个强大的消息代理，实现了AMQP（高级消息队列协议）。它支持复杂的路由场景、交换机（exchanges）、优先级队列、投递确认等功能。RabbitMQ非常适合微服务架构以及需要可靠消息投递的系统。

安装与连接

在PHP中使用RabbitMQ需要用到php-amqplib库。通过Composer安装：

composer require php-amqplib/php-amqplib

示例：发送邮件通知

我们将创建一个生产者（发送者）和一个消费者（处理器）用于后台发送邮件。

文件 producer.php：

<?phprequire_once '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([    'email' => 'user@example.com',    'subject' => '欢迎！',    'body' => '感谢您的注册。']);

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

$channel->basic_publish($msg, '', 'email_queue');

echo " [x] 消息已发送";

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

文件 consumer.php：

<?phprequire_once '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);    // 模拟发送邮件    sleep(2);    echo " [x] 邮件已发送至 {$data['email']}";    $msg->ack();};

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

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

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

2. Beanstalkd

Beanstalkd是一个轻量级、快速且易于使用的队列管理器。它采用类似于memcached的协议，非常适合不需要复杂路由的场景。Beanstalkd支持优先级、延迟（delay）和任务执行时间（TTR）。

安装

PHP的客户端库为pda/pheanstalk：

composer require pda/pheanstalk

示例：图像处理

假设我们需要为上传的图像创建缩略图。

文件 producer.php：

<?phprequire_once 'v