Очереди

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

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

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

Добавление задач в очередь

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

//Connect to the queue
$queue = new Phalcon\Queue\Beanstalk(array(
    'host' => '192.168.0.21'
));

//Insert the job in the queue
$queue->put(array('processVideo' => 4871));

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

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

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

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

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

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

$jobId = $queue->put(array('processVideo' => 4871));

Получение сообщений

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

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

    $message = $job->getBody();

    var_dump($message);

    $job->delete();
}

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

while ($queue->peekReady() !== false) {

    $job = $queue->reserve();

    $message = $job->getBody();

    var_dump($message);

    $job->delete();
}

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