Laravel Artisan CLI безопасно останавливает рабочие очереди демонов

Мы реализовали что-то подобное в нашем приложении, но это не было встроено в сам Laravel. Вам нужно будет отредактировать этот файл. , добавив еще одно условие в блок if, чтобы он вызывал функцию stop. Вы можете сделать это, либо установив статическую переменную в классе Worker, которая будет изменяться всякий раз, когда вы запускаете пользовательскую команду, которую вам нужно будет сделать (например, php artisan queue:pause), либо проверив атомарное значение где-нибудь (т.е. установите его в каком-то кеше, таком как redis , memcached, APC или даже MySQL, хотя это будет означать, что у вас будет один запрос MySQL для каждого цикла этого цикла while), который вы устанавливаете с помощью одной и той же пользовательской команды.

При использовании флага --daemon рабочие не должны уходить, когда очередь пуста.

Я думаю, что вы ищете в документации по очередям.

Команда php artisan queue:restart предложит воркерам перезапуститься после того, как они закончат свою текущую работу.

Начиная с Laravel 5.5 существует событие Illuminate\Queue\Events\Looping, которое запускается из вызова daemonShouldRun() внутри основного рабочего цикла Illuminate\Queue\Worker. Таким образом, если вы настроите прослушиватель для проверки следует обрабатывать задания и вернете false, то обработчики очереди остановятся до тех пор, пока проверка не вернет значение true. Между следующей проверкой есть пауза, которую вы можете настроить, передав --sleep <seconds> в команду queue:work.

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

мой Laravel 5.6. вы можете (убить свой pid) не волнуйтесь, потеряете свою работу, просто загрузите pcntl (расширение) Laravel может прослушать сигнал и безопасно выйти

показать исходный код ниже (в ./vendor/laravel/framework/src/Illuminate/Queue/Worker.php):

protected function listenForSignals()
{
    pcntl_async_signals(true);

    pcntl_signal(SIGTERM, function () {
        $this->shouldQuit = true;
    });

    pcntl_signal(SIGUSR2, function () {
        $this->paused = true;
    });

    pcntl_signal(SIGCONT, function () {
        $this->paused = false;
    });
}

И мой тест ниже:

for($i=0; $i<100; $i++){
        pcntl_async_signals(true);

    pcntl_signal(SIGTERM, function () {
        echo 'SIGTERM';
    });

    pcntl_signal(SIGUSR2, function () {
        echo 'SIGUSR2';
    });

    pcntl_signal(SIGCONT, function () {
        echo 'SIGCONT';
    });
echo $i; 
sleep(1);
 }

можешь попробовать убить