Как ответить сразу и продолжить выполнять скрипт?

Question

[accountnujen]

Телеграмм даёт минуту на выполнение скрипта. Если ответ не поступил - телеграм снова сделает запрос. Я не хочу заморачиваться с rabbitMQ, поэтому хочу просто наколхозить ответ.
Я погуглил и увидел вот это:

ignore_user_abort(true);
set_time_limit(0);
ob_start();
header('Connection: close');
header('Content-Length: '.ob_get_length());
ob_end_flush();
ob_flush();
flush();

только оно у меня почему-то не работает. Телеграм всё равно продолжает долбить. Подскажите, что я делаю не так?

Answer 1

[Immortal_pony]

Не хочешь использовать rabbitmq, используй хотя бы крон.
Если у тебя задачи выполняются дольше минуты, то надо принять это и реализовать функционал по-человечески:
1. Принимаем запрос из внешней системы, складываем в очередь, отвечаем внешней системе
2. В фоновом режиме находим все необработанные задачи и обрабатываем их, тратя на это столько времени, сколько потребуется.

PS А если тебе важно предоставить результат работы твоего скрипта внешней системе, то надо разобраться что у тебя там целую минуту делается.
Минута - это очень много. У меня ОС в 3 раза быстрее грузится, а там 100% больше функционала чем в твоём скрипте.

Comments

[vitaly_74]

мил человек какое у вас железо и ос?)

[accountnujen]

Не хочешь использовать rabbitmq, используй хотя бы крон.

то есть хочешь сказать, что вообще невозможно средствами php скинуть ответ и дальше работать?

что у тебя там целую минуту делается.

идёт запрос на другой мой сервер, достаются файлы, конвертируются и по одному отправляются в телеграм.

[Immortal_pony]

vitaly_74 средненькое (но ОС на SSD)

[vitaly_74]

Immortal_pony, и таки прям за секунд 20 грузится?

[accountnujen]

vitaly_74, у меня i3 на windows 8.1 грузился за 14 секунд.
На windows 10 за 25 почему-то

обычный ssd samsung

[Immortal_pony]

vitaly_74, Ага. А в чём проблема-то?

accountnujen,

то есть хочешь сказать, что вообще невозможно средствами php скинуть ответ и дальше работать?

По идее можно и ты даже делаешь всё для этого верно. Ну разве что fastcgi_finish_request надо добавить если у тебя php-fpm
Я просто считаю что этот путь - гниль и натягивание совы на глобус. Расписать подробнее, почему?

[Immortal_pony]

идёт запрос на другой мой сервер, достаются файлы, конвертируются и по одному отправляются в телеграм.

По такому описанию всё должно уложиться в 3 секунды.
Ну если файлы не огромные какие-то

[accountnujen]

Immortal_pony, файлы не огромные, но камера (сервер) любит подумать. Я достаю видосы со своей камеры и гружу в телеграм. Видосы могут быть по 5-7 минут. Их я перевожу из одного формата в другой. В итоге операция может длиться 3-4 минуты. Это очень редко (к примеру, когда нужно восстановить потерянный день), но возможно.

я читаю про rabbitMQ на russeller и там вопросов больше, чем ответов. Про cron (systemd) тоже есть вопросы, потому что непонятно, как не начинать выполнение, пока предыдущий не завершил работу, чтобы потом не наложились запросы и мне по 2 видео не приходило. Опять же, какой таймер я могу поставить? Каждую секунду можно базу но проверку новых тикетов долбать?

По идее можно и ты даже делаешь всё для этого верно.

вот у меня сейчас как:

<?php 
ignore_user_abort(true);
set_time_limit(0);
ob_start();
function tlgrm($method, $data) {
#функция отправки сообщения
}
header('Connection: close');
header('Content-Length: '.ob_get_length());
ob_end_flush();
flush();
tlgrm('sendMessage', ['text'=> "ответ 1"]);
sleep(100);
tlgrm('sendMessage', ['text'=> "ответ 2"]);

я отправляю в чат телеграмма сообщение и получаю "ответ 1" через 60 секунд снова "ответ 1", затем через 40 секунд "ответ 2" и снова "ответ 1" и так до бесконечности...

[Immortal_pony]

accountnujen, А, камера думает долго. Я снимаю свой вопрос так как был он про рояль©

потому что непонятно, как не начинать выполнение, пока предыдущий не завершил работу, чтобы потом не наложились запросы и мне по 2 видео не приходило

Вопрос правильный. И текущим твоим кодом никак не решается, кстати :)
А решается всё просто:
1. При запуске скрипта проверяем, есть ли у нас в очереди задачи в статусе processing. Если есть, завершаем работу скрипта.
2. Если запросов в статусе processing не нашлось, то ищем запросы в статусе new. Найденные запросы сортируем по дате.
3. Хватаем самый старый запрос, переводим его в статус processing и начинаем работать. Важно - всю логику оборачиваем в try...catch. В случае успеха переводим задачу в статус done (ну или вообще выкидываем из очереди). В случае неудачи переводим задачу в статусе failed (чтоб можно было её скинуть в new и переобработать в будущем, например)

Максимально частый cron обычно запускается раз в минуту, но можно поставить и раз в 5 секунд и чаще, если вам оно надо.
Никакой ощутимой нагрузки это не должно создать

[Immortal_pony]

PS очередь можно хоть в файле queue.json хранить если мы говорим о десятках или сотнях задач (если 1000+, то уже как минимум БД)

[accountnujen]

Immortal_pony, я только что создал 2 файла и из одного делал запрос на другой по curl. Во втором прописал ob_start(); и др. Так вот у меня сработал преждевременный ответ между двумя файлами. Видимо телеграмму нужен какой-то определённый header отправлять. По сути, я могу просто поиск видео вывести в другой файл и в нём прописать ob_start, потому что моим файлам достаточно этого.

И спасибо за пояснение с тем, как собрать свой обработчик тикетов. Всё очень доступно объяснил!