Очереди

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

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

Хотя вы можете найти более сложные расширения PHP для работы с очередями в ваших приложениях, таких как RabbitMQ; Phalcon предоставляет клиент для Beanstalk, сервера очереди задач, вдохновленного Memcache. Он прост, легок и полностью специализирован для очередей задач.

Помещение задач в очередь

После подключения к Beanstalk вы можете вставить столько задач, сколько потребуется. Вы можете определить структуру сообщения в соответствии с потребностями приложения:

use Phalcon\Queue\Beanstalk;

// Connect to the queue
$queue = new Beanstalk(
    [
        "host" => "192.168.0.21",
        "port" => "11300",
    ]
);

// Insert the job in the queue
$queue->put(
    [
        "processVideo" => 4871,
    ]
);

Доступные параметры подключения:

В приведенном выше примере мы сохранили сообщение, которое позволит фоновой задаче обработать видео. Сообщение сохраняется в очереди немедленно и не имеет определенного срока действия.

Дополнительные параметры, такие как время выполнения, приоритет и задержка, могут быть переданы во втором параметре:

// Insert the job in the queue with options
$queue->put(
    [
        "processVideo" => 4871,
    ],
    [
        "priority" => 250,
        "delay"    => 10,
        "ttr"      => 3600,
    ]
);

Доступные параметры:

Каждая задача, помещенная в очередь, возвращает «идентификатор задачи», который вы можете использовать для отслеживания статуса задачи:

$jobId = $queue->put(
    [
        "processVideo" => 4871,
    ]
);

Извлечение сообщений

После помещения задачи в очередь, эти сообщения могут быть обработаны фоновым рабочим процессом, у которого будет достаточно времени для выполнения задачи:

while (($job = $queue->peekReady()) !== false) {
    $message = $job->getBody();

    var_dump($message);

    $job->delete();
}

Задачи должны быть удалены из очереди, чтобы избежать двойной обработки. Если реализовано несколько фоновых рабочих процессов, задачи должны быть «зарезервированы», чтобы другие рабочие процессы не перерабатывали их, пока другие рабочие процессы их не зарезервируют:

while (($job = $queue->reserve()) !== false) {
    $message = $job->getBody();

    var_dump($message);

    $job->delete();
}

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