Как правильно настроить Server-Sent Events в PHP?

Question

[Prtoy]

Здравствуйте.

Пишу небольшое приложение, которое отображает некоторую информацию из БД. Так как информация должна обновляться часто, а клиентов много, то дёргать БД с каждого клиента не очень хорошо. Случайно узнал про Server-Sent Events и EventSource в JS, и решил попробовать.

PHP:

if ($_GET['get'] === 'data') {
	header("Content-Type: text/event-stream");
	header("Cache-Control: No-Store");
	
	while (true) {
		$data = file_get_contents("...", true);  // обращение к файлу который дёргает БД и возвращает данные в JSON
		echo "event: sendData\n\n";
		echo 'data: ' . $data . "\n\n";

		ob_end_flush();
		flush();
		if (connection_aborted()) {
			break;
		};
		
		sleep(5);
	}
}

JS React:

const eventSource = new EventSource('sse.php?get=data');
      eventSource.onmessage = (event) => {
        const data = JSON.parse(event.data);
        setData(data);
      };

И всё вроде работает, но если я правильно понимаю, то всё равно каждый клиент подключается к sse.php - и хоть и с клиента запрос только один, но sse.php всё рвано дёргает информацию для каждого клиента отдельно...

Вопрос - как правильно сделать так, чтобы запросы к БД происходили один раз и результат отдавался клиентам?

Comments

[iljaGolubev]

https://www.php.net/manual/en/class.swoole-websock...
https://qna.habr.com/search?q=swoole

[ThunderCat]

iljaGolubev, чисто из любопытства - как вебсокет может решить вышеозвученную проблему?

[Stalker_RED]

Что это такое?

$data = file_get_contents ... обращение к файлу который дёргает БД и возвращает данные в JSON

Про демоны вы слышали что - нибудь? Брокеры сообщений?

[iljaGolubev]

ThunderCat, в чистом виде, очевидно, никак. Но это и не ответ). Конечно именно пхп должен понять когда именно нужно отправить клиенту данные и тольео перед этим запроситьих из бд... Если нужно.

[Prtoy]

Stalker_RED, нет, если честно, не слышал про брокеры сообщений. Я на фронтендера учусь) Про демоны слышал отдалённо, но использовать не приходилось.
iljaGolubev, нет, задача немного иная. Не запросить данные когда клиент подключится, а подключившемуся клиенту отдать уже запрошенные заранее данные. И другим клиентам те же данные - а не запрашивать их из БД ещё раз для каждого клиента отдельно.

[iljaGolubev]

Prtoy, клиент устанавливает новое соединение - отдать данные. Произошло какое-то событие на сервере - отдать данные всем ранее подключившимся клиентам. Даже если данные получать из БД, менее нагружено чем у вас. Для этого web socket.
Или брокер сообщений - тогда измените свой код примерно так -

$data = brockerGetMessage(); if ($data) echo $data;

Суть в том, что при изменении данных в БД (а только при этом имеет смысл посылать что-то клиенту если от него не было запроса) вы добавляете сообщение в очередь (в брокер). В сообщении могут быть ровно те данные, которые нужно отправлять клиентам. Демон забирает сообщение из очереди и отправляет клиентам.

Впрочем, зачем вам если вы на фронтендера)

[Prtoy]

iljaGolubev, данные изменяются каждую секунду, соответственно отдавать их надо, ну, не реже чем раз в 3 секунды.

Впрочем, зачем вам если вы на фронтендера)

Так сложилось) Это пет-проект для текущей работы. Бэка нет и писать его кроме меня некому...
Получается, что данный способ с SSE в принципе неприменим в данной ситуации? Каждый клиент провоцирует новые запросы к БД...

Можно, например, взять какой-нибудь Workerman для php, запустить его и принимать сообщения. А второй скрипт будет дёргать БД и отправлять воркерману результат запросов. А клиенты уже будут получать через WS. Верно размышляю?) Ни на что более умное я пока не способен))

[iljaGolubev]

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