Какие знаешь очереди?

Очереди в контексте PHP Backend разработки

Как backend-разработчик с фокусом на PHP, я работал с различными типами очередей, которые можно разделить на несколько категорий:

1. Очереди в памяти (In-Memory Queues)

Эти очереди хранят задачи в оперативной памяти и идеальны для высокопроизводительных сценариев, но не устойчивы к сбоям.

Примеры:

• Redis (с использованием структур данных List, Streams или Sorted Sets)
• Memcached
• Встроенные структуры данных PHP (SPLQueue, массивы)

// Пример использования Redis в качестве очереди
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// Добавление задачи в очередь
$redis->lPush('email_queue', json_encode([
    'to' => 'user@example.com',
    'subject' => 'Welcome Email',
    'body' => 'Welcome to our service!'
]));

// Обработка задач из очереди
while ($task = $redis->rPop('email_queue')) {
    $data = json_decode($task, true);
    processEmail($data);
}

2. Очереди на основе брокеров сообщений (Message Brokers)

Наиболее распространенный тип в enterprise-приложениях, обеспечивающий надежность, масштабируемость и расширенные функции.

Популярные решения:

• RabbitMQ (AMQP протокол) - наиболее зрелый и функциональный
• Apache Kafka - для потоковой обработки больших объемов данных
• Amazon SQS - полностью управляемая очередь в AWS
• Beanstalkd - простая и быстрая очередь

// Пример работы с RabbitMQ через библиотеку php-amqplib
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

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

// Объявление очереди
$channel->queue_declare('task_queue', false, true, false, false);

// Отправка сообщения
$message = new AMQPMessage('Hello World!', ['delivery_mode' => 2]);
$channel->basic_publish($message, '', 'task_queue');

3. Очереди на основе баз данных

Используют таблицы БД для хранения задач. Менее производительны, но просты в настройке и отладке.

// Пример таблицы очереди в MySQL
CREATE TABLE job_queue (
    id INT AUTO_INCREMENT PRIMARY KEY,
    job_type VARCHAR(50) NOT NULL,
    payload JSON,
    status ENUM('pending', 'processing', 'completed', 'failed') DEFAULT 'pending',
    attempts INT DEFAULT 0,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    processed_at TIMESTAMP NULL
);

4. Очереди в фреймворках PHP

Современные PHP-фреймворки предоставляют абстракции над очередями:

• Laravel Queues с драйверами для Redis, Beanstalkd, SQS, Database
• Symfony Messenger с транспортами для Doctrine, Redis, AMQP
• Yii2 Queue Extension

// Пример задачи в Laravel
namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;

class ProcessPodcast implements ShouldQueue
{
    use Queueable;
    
    public function handle()
    {
        // Обработка подкаста
    }
}

// Отправка задачи в очередь
ProcessPodcast::dispatch($podcast)->onQueue('audio-processing');

5. Специализированные очереди для PHP

• GearmanJobServer - система распределения задач
• PHP-Resque (адаптация Redis-based очереди Resque для Ruby)
• Tarantool Queue - in-memory хранилище данных с поддержкой очередей

Ключевые критерии выбора очереди:

1. Производительность - Redis и Kafka показывают лучшие результаты
2. Надежность - RabbitMQ с подтверждением доставки (acknowledgments)
3. Масштабируемость - горизонтальное масштабирование воркеров
4. Отслеживание - мониторинг и Dead Letter Queues
5. Задержки - отложенное выполнение и повторные попытки
6. Приоритеты - обработка задач с разными приоритетами

Архитектурные паттерны с очередями:

• Worker Pattern - несколько воркеров обрабатывают задачи из одной очереди
• Pub/Sub - широковещательная рассылка сообщений
• Fan-out - распределение задач между разными очередями
• Dead Letter Queue - обработка неудачных задач

На практике выбор очереди зависит от конкретных требований проекта. Для большинства веб-приложений я рекомендую Redis как баланс между производительностью и функциональностью, либо RabbitMQ для сложных enterprise-систем с повышенными требованиями к надежности. Современные облачные решения типа AWS SQS или Google Pub/Sub также отлично подходят для микросервисных архитектур, избавляя от необходимости администрировать инфраструктуру.