Очереди задач в PHP: полное руководство для начинающих

Онлайн-тренажер Python для начинающих

Изучайте Python легко и без перегрузки теорией. Решайте практические задачи с автоматической проверкой, получайте подсказки на русском языке и пишите код прямо в браузере — без необходимости что-либо устанавливать.

Начать курс

Введение в очереди задач в PHP

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

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

Что такое очередь задач и зачем она нужна?

Представьте, что ваш сайт должен отправить 1000 писем после регистрации пользователя. Если выполнять это синхронно, страница будет загружаться несколько минут. Пользователь уйдёт, а сервер будет заблокирован. Очередь решает эту проблему: задача отправки писем помещается в очередь и обрабатывается фоновым воркером, а пользователь мгновенно получает ответ.

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

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

Архитектура очередей задач в PHP

Типичная система очередей состоит из трёх компонентов:

Продюсер (Producer) — часть кода, которая добавляет задачи в очередь
Очередь (Queue) — хранилище задач (часто на базе Redis, Beanstalkd или базы данных)
Воркер (Worker) — скрипт, который постоянно слушает очередь и выполняет задачи

В PHP для работы с очередями чаще всего используют библиотеки php-resque, Laravel Queue (если работаете с Laravel) или enqueue/fs. Мы рассмотрим общий подход, который можно адаптировать под любой фреймворк.

Практический пример: создание очереди задач на чистом PHP

Давайте создадим простую систему очередей с использованием Redis. Установите Redis и расширение phpredis или используйте predis/predis через Composer.

Шаг 1: Подготовка окружения

composer require predis/predis

Шаг 2: Создание продюсера

Продюсер будет добавлять задачи в очередь. Создадим файл producer.php:

<?php
require 'vendor/autoload.php';

use Predis\Client as RedisClient;

class JobProducer {
    private $redis;
    
    public function __construct() {
        $this->redis = new RedisClient([
            'scheme' => 'tcp',
            'host'   => '127.0.0.1',
            'port'   => 6379,
        ]);
    }
    
    public function addJob(string $queueName, array $jobData): void {
        $job = json_encode([
            'id' => uniqid(),
            'data' => $jobData,
            'created_at' => time()
        ]);
        
        // Используем RPUSH для добавления в конец очереди
        $this->redis->rpush("queue:{$queueName}", $job);
        echo "Задача добавлена в очередь {$queueName}\n";
    }
}

// Пример использования
$producer = new JobProducer();
$producer->addJob('emails', [
    'to' => 'user@example.com',
    'subject' => 'Добро пожаловать!',
    'body' => 'Спасибо за регистрацию...'
]);
?>

Шаг 3: Создание воркера

Воркер будет обрабатывать задачи из очереди. Создадим файл worker.php:

<?php
require 'vendor/autoload.php';

use Predis\Client as RedisClient;

class JobWorker {
    private $redis;
    private $running = true;
    
    public function __construct() {
        $this->redis = new RedisClient([
            'scheme' => 'tcp',
            'host'   => '127.0.0.1',
            'port'   => 6379,
        ]);
    }
    
    public function processQueue(string $queueName): void {
        echo "Воркер запущен для очереди: {$queueName}\n";
        
        while ($this->running) {
            // Используем BLPOP для блокирующего чтения (ждём задачу до 5 секунд)
            $job = $this->redis->blpop("queue:{$queueName}", 5);
            
            if ($job) {
                $jobData = json_decode($job[1], true);
                $this->executeJob($jobData);
            }
        }
    }
    
    private function executeJob(array $jobData): void {
        echo "Обработка задачи #{$jobData['id']}...\n";
        
        // Здесь ваша бизнес-логика
        $data = $jobData['data'];
        // Например, отправка email
        // mail($data['to'], $data['subject'], $data['body']);
        
        echo "Задача #{$jobData['id']} выполнена успешно\n";
    }
    
    public function stop(): void {
        $this->running = false;
    }
}

// Запуск воркера
$worker = new JobWorker();
$worker->processQueue('emails');
?>

Шаг 4: Запуск системы

В одном терминале запустите воркер:

php worker.php

В другом терминале добавьте задачу:

php producer.php

Вы увидите, как воркер мгновенно подхватывает задачу и обрабатывает её. Обратите внимание на использование BLPOP — это блокирующая операция, которая ждёт появления новой задачи до 5 секунд, не нагружая процессор.