Как в php заблокировать файл от других обращений?

Question

[V0VA]

Добрый день! Есть файл, который принимает POST от 1С и обновляет данные в базе данных.
Вопрос как сделать так, чтобы пока он не выполнил задание от текущего обращения блокировал его повторное выполнение другим следующим запросом. Подскажите, пожалуйста, кто знает, где копать ?

Answer 1

[AUser0]

Запускается скрипт -> из него проверяется файл-семафор -> если семафор есть - завершаем скрипт (с ошибкой?) -> если семафора нет - создаём и делаем остальные дела.

Но лучше - складировать все запросы в какую-нибудь очередь (те же файлы с уникальными именами, и параметрами запроса), а нужный скрипт запускается раз в секунду/минуту/сутки, и выполняет обработку одного файла.

А можно... да тут 100500 вариантов можно придумать!

Comments

[Adamos]

В данном случае - не лучше. Если 1С пытается синхронизироваться чаще, чем сайт успевает разобрать данные, очередь просто будет бесконечно расти. Это во-вторых. А во-первых, очередь для синхронизации всех данных просто бессмысленна. Не обработал запрос - да и хрен с ним, те же данные придут в следующем.

[AUser0]

Adamos,

Не обработал запрос - да и хрен с ним

А вот бы в продакшене такую логику замутить, ага?
"Что вы ко мне с запросами лезете, хрен вам, в другой раз обработаю... Может быть... Если вспомню... Ну и что, что у вас тут счёт потерялся, а дебет с кредитом в 2 раза различаются, хрен и с ними!"

Adamos, а во-вторых, уф, чуть не написал во-первых, таковы условия вопроса автора, а тут ещё и хрен-вам-а-не-запрос, так что легко справится, не переживайте.

P.S. Или это такой новый троллинг?

[Adamos]

AUser0, ТС четко написал, что запросы должны приниматься только после обработки предыдущего.
Значит, за необработку пропущенных не переживает.
Подозреваю, это всего лишь обновление остатков на складах - и никаких счетов, а тем более дебита с кредитом тут и не ночевало. Просто 1С-ник погорячился и сделал его чаще, чем следовало.

[V0VA]

Adamos, AUser0 Благодарю.
Действительно, в настоящее время это только остатки и новые цены.
Чтобы решить в текущей ситуации вопрос, можно и не переживать за обработку не пропущенных.
Но в перспективе это вырастит в более полный обмен. Вы оба правы. Спасибо большое, за то что не оставили мой вопрос открытым. Да данные прут сейчас один за другим и сервак не успевает обработать, как новый запрос приходит

[V0VA]

"из него проверяется файл-семафор"
вы имеете в виду через fopen()?

[AUser0]

V0VA, нет, в PHP вам и file_exists(), и flock() доступны, выбирай - не хочу!

[rPman]

V0VA, в таких ситуациях НАСТОЯТЕЛЬНО РЕКОМЕНДУЕТСЯ при получении данных не запускать их обработку, а складировать в хранилище fifo, даже на основе файлов, кода 5-6 строчек.

А саму обработку делать отдельным приложением, читающим эти файлы

[AUser0]

V0VA, вот, rPman со знанием дела говорит, с большим опытом, почитайте его ответы здесь.

Отдельное приложение ещё и цикле может это делать, с кешированием, как демон - а это ускорение за счёт экономии ресурсов на запуск и т.д.

Answer 2

[rPman]

POST это http?
Тебе нужен свой http сервер, реализующий нужную логику. Инструментов миллион, попробуй swoole
.
Если его реализовать без многопоточности и асинхоронщины, то пока он будет обрабатывать один запрос, никакой другой не будет получен, другие будут ждать в очереди сетевого стека и отваливаться с ошибкой по таймауту.

Интересно что встроенный отладочный http сервер php -S xxx:port какраз однопоточный, и хотя его не рекомендуют для продакшн, можешь попробовать.

Comments

[V0VA]

rPman, Спасибо. Да, http

[V0VA]

rPman, "Интересно что встроенный отладочный http сервер php -S xxx:port какраз однопоточный, и хотя его не рекомендуют для продакшн, можешь попробовать."
А можно тут по подробнее немного

[rPman]

https://www.php.net/manual/ru/features.commandline...

[V0VA]

Спасибо большое

Answer 3

[pantsarny]

Блокировал это как? Чтобы ждали или получали ошибку?

Создавай эксклюзивную блокировку файла
И проверяй ее наличие

Или открывай сокет, это тоже эксклюзив

Ну или старый добрый семафор
if ($theSemaphore = sem_get("123456",1)) { // this "1" ensures that there is nothing parallel
if (sem_acquire($theSemaphore)) { // this blocks the execution until other processes or threads are finished

sem_release($theSemaphore); // This should be called only if sem_acquire() succeeds
}
}