Как собрать логику и работу websockets?

Question

[highw]

Добрый день.

Задача стоит следующая, есть N клиентов, которые работают на вебсокетах с сервером.
Есть сервер который принимает и отвечает клиентам.

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

Смотрел примеры php серверов. там в основном есть методы onMessage который дергаются когда есть коннект, а как вот сделать чтобы сервер принимал соединения но слал инфо независимо от клиентов.

Сейчас в голове крутится следующая картина:
1) скрипт демон который делает что-то и складывает результаты в какой-нить amqp, rabbit. оттуда же читает
2) Скрипт сервер сокетов, который в цикле помимо прослушки еще прослушивает очередь.. если что-то там есть - слать всем.

есть ли более разумные варианты?

Answer 1

[index0h]

Можете посмотреть в направлении систем типа centrifugo

Answer 2

[BoShurik]

Пример второго варианта
В данном случае onMessage имеет место быть, но он дергается не во время сообщения от клиента, а по кастомному событию