Как обновлять данные через webSocket?

Question

[Александр]

Здравствуйте, уважаемые программисты!
Второй день пытаюсь понять и изучить принцип работы webSocket.
Пока только удалось создать сокет на сервере и подключаться как клиент, с тестовой отправкой сообщения.
Я использовал Библиотеку

Пока я из данного проекта могу отправлять и получать сообщения, в одном и том же окне браузера.
А хотелось бы понять, а как написав сообщение в одном браузере, я бы смог узнать что появилось новое сообщение в другом браузере и вывести его пользователю?

И основной вопрос. Если использовать webSocket для обновления различных данных на сайте, в режиме реального времени, означает ли это, что нужно постоянно сыпать кучу запросов в БД, чтобы проверять изменения? Или тут можно "перехватывать изменения" еще до попадания их в БД и сразу отправлять пользователю?

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

Comments

[Максим Федоров]

Или тут можно "перехватывать изменения" еще до попадания их в БД и сразу отправлять пользователю?

Можно при сохранении в БД кидать событие, которое класть в очередь к примеру или редис
От туда демон сервер вычитывать и слать по WS сообщения

[Александр]

Максим Федоров, а есть вообще какой-то пример взаимодействия файла php?, к примеру вставка сообщения в БД и отправка события, а потом обработка события и возврать данных клиентам подключенным?

[Slava Rozhnev]

Для такого рода проектов идеально подходит NodeJS вместо PHP

[Vitsliputsli]

Slava Rozhnev, чем NodeJS идеальнее PHP в этом случае?

[Slava Rozhnev]

Vitsliputsli, NodeJS создает процесс который поддерживает постояннное соединение по WebSocket в отличие от РНР который расчитан на то чтобы получить запрос ветнуть ответ и умереть.
Конечно в РНР уже напридумывали всяких костылей для сокетов, но это не является нативным поведением в отличии от ноды

[Александр]

Slava Rozhnev, ну вот я файл php запускаю через sh по крону. А сам php вроде бы как в цикле поддерживает соединение, если я правильно понял. Разве это не работает?

[Slava Rozhnev]

Александр, Я Вас не уговариваю, хотите РНР - используйте на здоровье. Каждый программист пишет свой велосипед на костылях

[Vitsliputsli]

Slava Rozhnev,

NodeJS создает процесс который поддерживает постояннное соединение по WebSocket в отличие от РНР который расчитан на то чтобы получить запрос ветнуть ответ и умереть.
Конечно в РНР уже напридумывали всяких костылей для сокетов, но это не является нативным поведением в отличии от ноды

Вот так задаешь вопрос, думаешь что-то интересное узнать, ну или как минимум услышать что-то старое... получаешь какую-то дичь. Уж простите, но вы чушь пишите.
Демоны на php прекрасно работают и широко применяются, в том числе в highload - это факт. Работа с WebSocket в принципе подразумевает постоянное поддержание соединения, это не http, поэтому не понятно о чем вы пишите. В PHP есть решения для WebSocket, которые нормально работают. Что такое "нативное поведение для сокетов" вообще неизвестно и тем более что за костыли в PHP для этого, можете рассказать что конкретно имеете ввиду?

[Vitsliputsli]

tommy-vercetti, для WebSocket много решений, одно из неплохих Ratchet, асинхронность через ReactPHP. Он не плох, но я не говорю что PHP лучшее решение. В PHP IO блокирующий, хотя по-факту это не имеет большого значения при нормальной работе, когда есть ws- сервер и есть воркеры обслуживающие задачи, а при таком подходе отдельный сервис можно на чем угодно написать, и по-моему Go отличный вариант (ведь все что нужно это держать ws-сервер и обмениваться сообщениями с брокером, и чуть логики на аутентификацию, в Go это не сложно сделать). Можно еще заморочиться с потоками, но это будет сложнее и проблематичнее. У PHP есть ограничение на кол-во подключений в сокетах, но когда у тебя больше 1000 подключений, уже стоит думать о масштабировании.
Т.е. неидеально, но вполне нормально.

Answer 1

[Виктор П.]

Привет, из комментов я узнал, что вы пишете на пхп, поэтому с кодом помочь не могу. Но, тем не менее, смутило, что вы не смогли найти примеров в гугле. Забейте php chat websoket пример - результатов море.
Обычно библиотеки по ним реализуют паттерн издатель-подписчик.
Когда клиент устанавливает подключение с сервером по вебсокету, ему выдаётся некий идентификатор.

Соответственно, на сервере хранится список установленных подключений.
Далее с сервера вы можете отправлять сообщения либо по идентификатору какому-то конкретному клиенту, либо есть команда "отправить всем" - не важно сколько клиентов у вас подключено.
У отправляемого сообщения есть тип сообщения (можно использовать один тип, отправляя json и далее его разбирать на клиенте) а клиенты в браузере подписываются на рассылку.

Следующий вопрос, допустим, у вас у клиента1 открыт на экране список пользователей. Установлено соединение по вебсокету и вы подписаны на событие "изменение пользователя". Когда пользователь2 редактирует свой профиль или регистрируется в системе, до того, как запись попадёт в базу данных, вы эту запись отправляете в библиотеку с вебсокетами. Там делаете мгновенную рассылку на всех подключённых клиентов, событие "изменение пользователя" и либо айдишник пользователя, либо всю модель пользователя можно упаковать в json и отправить целиком.
Далее на клиенте вы получаете это сообщение и обновляете данные на странице.
Под такую логику подходят spa-решения, например, реакт или ангуляр, где можно держать один сервис пользователей, который будет выполнять роль прокси, либо забирать первым запросом доступные данные, либо отслеживать изменения по вебсокетам

Comments

[Александр]

Спасибо за развернутый ответ. Очень познавательно. Но.. По поводу чатов, то я видел и про ID пользователей тоже... Проблема только в том, что эти чаты написаны на чисто js без взаимодействия с БД, а мне бы хотелось именно посмотреть как происходит общение php+WebSocket+js

[Виктор П.]

Александр, к сожалению, с php не подскажу. к вам на сервер с одного клиента приходит сообщение в обработчик вебсокетов. Далее вы это сообщение через этот же обработчик можете отправить остальным подписчикам. И одновременно с этим выполнить сохранение в свою базу как вы это привыкли делать. Это две разные независимые операции - примеров должно быть много, базовая вещь