Как лучше сделать HTTP SSE (Server Side Events) в PHP приложении?

Question

[tushev]

В классическом PHP приложении крутящемся на Apache возникла необходимость посылать данные клиентам в реальном времени при наступлении определенных событий. Если конкретно, к приложению через API подключаются внешние системы и добавляют в него некие данные, обработчик тут же обрабатывает их и должен в тот же момент уведомить всех пользователей, находящихся на сайте, о поступлении новых данных. Одновременно подключенных клиентов ожидается до 300. Хочется выбрать какой то простой и надежный способ реализации, причем желательно без установки дополнительного стека технологий.
Самый соблазнительный вариант это использовать HTTP SSE. Встроенная и простая поддержка браузерами, автоматическое восстановление коннектов при обрыве. И якобы серверную сторону можно сделать на том же PHP. В интернете много примеров типа этого:

header("Content-Type: text/event-stream");
while (1) {
    echo 'data: xxxxxxxxxxx';
    ob_end_flush();  flush();   sleep(1);
}

Но не понятно, как в таком скрипте лучше дожидаться наступление события в другом PHP скрипте? Циклическим поллингом заниматься точно не хочется. Нужны какие то семафоры или что то в этом духе. Да и не порвет ли Apache долго висящие HTTP соединения, все таки это не совсем стандартное его использование. Как завершать скрипт при отключении клиента?

Еще я смотрел в стороны других вариантов:
- Написать специальный сервер на Node.JS. Вроде он как раз хорошо подходит для подобных вещей. С одной стороны слушаешь API, по которому поступают данные, и раскидываешь поступившие данные по всем висящим SSE подключениям. Но у меня нет опыта работы с Node.JS.
- Использование WebSocket мне показалось избыточным для данной задачи. Мне нужно только рассылать уведомления в одностороннем порядке.
- На Laravel есть решение из коробки: Laravel + Redis + laravel-echo-server (на Node.JS) + Socket.IO + Laravel-Echo. Но как то не хочется тащить весь этот колхоз ради одной простой задачки. В качестве транспорта оно использует WebSocket, а почему то не SSE.

Какое решение лучше выбрать? Пытаться ли обойтись одним голым PHP+Apache и встроенной браузерной поддержкой SSE? Или это чревато подводными камнями и лучше тащить дополнительный стек технологий. Что выбрать?

Comments

[Сергей Кореневский]

Вы нашли как SSE рассылать из другого потока?
Я тут создал новый вопрос.
Как в PHP из одного потока(сессии) вызвать скрипт другого потока(сессии) скрипт другого клиента?

Answer 1

[profesor08]

Что мешает при поступлении новых данных, где-то в бд отмечать, "поступили данные"? А своим скриптом смотришь, есть ли новые данные, если есть, отправлять клиенту. В любом случае надо делать разные скрипты, один для приема данных от сервисов, второй для отправки данных клиенту. И они должны работать независимо. Еще можешь сделать один скрипт, но в нем сделать несколько потоков под задачи.

Явно задача не такая простая как кажется. Одним скриптом с while(true) sleep(1) не обойдешься.

Comments

[tushev]

Разумеется один скрипт отвечает за SSE подключения, а другой за API. Вопрос в том, как SSE скрипту "заснуть", а в момент поступления данных в API скрипт проснуться и выплюнуть новую порцию данных SSE клиенту? Т.е. API скрипт должен разбудить все висящие на данный момент SSE скрипты.
Решение в цикле проверять БД и если ничего не изменилось, то делать sleep(), а после проверять по новой, мне кажется кривоватым и неэффективным.

[profesor08]

tushev,

мне кажется кривоватым и неэффективным

Вот именно, что кажется.

Но, если упорно не хочется делать так, тогда пусть общаются по сокету.

[WayMax]

tushev,

Решение в цикле проверять БД и если ничего не изменилось, то делать sleep(), а после проверять по новой, мне кажется кривоватым и неэффективным.

Я сам когда столкнулся с похожей задачей не смог найти другого решения кроме как в цикле опрашивать произошли ли какие-то изменения за время слипа или нет.

[Сергей Кореневский]

Аналогично думаю что криво сохранять в Базу а потом. Искать в базе данные. И если они будут хранится в базе то причём тут SSE. Это получается JS на клиенте будут инициализировать новый GET запрос по которому скрипт PHP будет вынимать данные из базы. В Вашем предложении нет SSE вообще. А автор спрашивает об SSE. Я к нему присоединяюсь и хочу узнать как из одной сессии вызвать скрипт другой сессии подключенный к другому клиенту который сразу же будет рассылать по SSE