Очереди задач для PHP: RabbitMQ, Gearman и Redis

В современных веб-приложениях на PHP часто возникает необходимость выполнять длительные или ресурсоёмкие операции без блокировки основного потока пользователя. Отправка email-рассылок, генерация отчётов, обработка изображений, работа с видео — все эти задачи лучше выполнять асинхронно, в фоне. Для этого существуют очереди задач (job queues) — механизмы, которые позволяют отложить выполнение задачи и обработать её позже с помощью воркеров.

В этой статье мы рассмотрим три популярных инструмента для организации очередей задач в PHP: RabbitMQ, Gearman и Redis. Вы узнаете, в каких случаях их использовать, и увидите примеры кода.

Зачем нужны очереди задач?

Основные преимущества использования очередей:

Асинхронность — пользователь не ждёт завершения тяжёлой операции.
Масштабирование — вы можете запускать множество воркеров для параллельной обработки.
Отказоустойчивость — если воркер упал, задача остаётся в очереди и будет обработана позже.
Разделение ответственности — код отправки задачи и код её обработки слабо связаны.

1. RabbitMQ — мощный брокер сообщений

RabbitMQ — это полноценный брокер сообщений, поддерживающий протокол AMQP. Он обеспечивает гарантированную доставку, маршрутизацию, подтверждения и многое другое. Подходит для сложных систем с высокой нагрузкой.

Для работы с RabbitMQ в PHP используется расширение php-amqplib.

Установка

composer require php-amqplib/php-amqplib

Пример: отправка задачи

<?php
require_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(['email' => 'user@example.com', 'subject' => 'Привет!']);
$msg = new AMQPMessage($data, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);

$channel->basic_publish($msg, '', 'email_queue');
echo "Задача отправлена в очередь\n";

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

Пример: воркер (обработчик)

<?php
require_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);

$callback = function ($msg) {
    $data = json_decode($msg->body, true);
    echo "Отправка письма на {$data['email']} с темой '{$data['subject']}'\n";
    // Здесь реальная отправка 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();
}

2. Gearman — распределённая система заданий

Gearman специализируется на распределённой обработке задач. Он позволяет вызывать функции на удалённых серверах или в фоновом режиме. Отлично подходит для микросервисной архитектуры.

Для PHP существует расширение gearman (PECL).

Установка

sudo apt install gearman-job-server
pecl install gearman

Пример: клиент (отправка задачи)

<?php
$client = new GearmanClient();
$client->addServer('127.0.0.1', 4730);

$result = $client->doBackground('send_email', json_encode([
    'email' => 'user@example.com',
    'subject' => 'Привет!'
]));

echo "Задача отправлена, ID: $result\n";

Пример: воркер

<?php
$worker = new GearmanWorker();
$worker->addServer('127.0.0.1', 4730);

$worker->addFunction('send_email', function ($job) {
    $data = json_decode($job->workload(), true);
    echo "Обработка письма для {$data['email']}\n";
    // Логика отправки
    return true;
});

while ($worker->work()) {
    // бесконечный цикл
}