Очередь сообщений PHP+Redis

composer require flc/php-queue

/**
 * Создание задачи
 */
require_once __DIR__ . '/bootstrap.php';

use Flc\Queue\Manager;
use Jobs\Demo;

// Создание работы
$demo = new Demo('Тестирование');

// Отправка в очередь
for ($i = 0; $i <= 100; $i ++) {
    Manager::instance()->push($demo);
}

echo Manager::instance()->count();

/**
 * Исполнитель задач (постоянный)
 */
require_once __DIR__ . '/bootstrap.php';

use Flc\Queue\Manager;
use Jobs\Demo;

if ('cli' !== php_sapi_name()) {
    die('Необходимо запускать в режиме командной строки');
}

while (true) {
    // Извлечение задачи из очереди
    $job = Manager::instance()->pull();

    // Если нет задачи, то пауза на 2 секунды
    if (! $job) {
        sleep(2);
        continue;
    }

    try {
        call_user_func_array([$job, 'handle'], []);
    } catch (Exception $e) {
        echo $e->getMessage();
    }
}