PHP Websocket оповещение о новой записи в базе данных mysql, как реализовать?

Question

[Mr_Romanov]

Приветствую, пытаюсь уже с неделю разобраться с WEBSOCKET+PHP+MYSQL

Есть база:
id / text / date
2|текст|02.08.2016 12:00
1|блабла|02.08.2016 11:00
Например.

Есть PHP скрипт который показывает все записи из базы:
2|текст|02.08.2016 12:00
1|блабла|02.08.2016 11:00

Как сделать демона исключительно на PHP с WS который будет мониторить базу и говорить скрипту о том что появилась новая строка и её надо вывести?

Хочу чистый PHP без всяких демонпхп и прочего.

Весь интернет облазил а того элементарного примера нигде нет. Одни лонгпуллы.

Ещё раз суть того что я хочу:
client.php - опрашивает демона на изменения БД;
server.php - демон который опрашивает БД на наличие новых записей и при наличии новой записи отправляет её клиенту а на клиенте происходит что угодно оповещение/вывод этой записи, это уже вторичное, главное чтобы клиент был на постоянной связи с сервером по протоколу WS.

Comments

[OVK2015]

Не совсем понятен последний абзац.
"... а на клиенте происходит что угодно ..." Здесь под клиентом подразумеваете скрипт в client.php или клиентский js код в браузере?
+Сам WS сервер уже поднят/работает не зависимо от этого вопроса?

[Mr_Romanov]

OVK2015: JS код в браузере конечно, WS работае

[OVK2015]

Mr_Romanov: Т.е., нужен чистый ws client на php?

[Mr_Romanov]

OVK2015: ну будет здорово если пример будет сервер/клиент дабы структура была единая

[OVK2015]

Mr_Romanov: Так сервер же уже есть и работает. Или аппетит приходит во время еды?
https://github.com/psinetron/PHP_SocketIO_Client - Клиент
https://github.com/ghedipunk/PHP-Websockets - WS сервер, если все таки надо. На много проще Ratchet, но для такой задачи вполне пойдет

Answer 1

[xfg]

Хочу чистый PHP без всяких демонпхп и прочего.

Без каких-то готовых библиотек нужно самому реализовать протокол websocket описанный в rfc6455.

Это примерно тоже самое, как если бы прежде чем использовать протокол http вы бы самостоятельно написали свой веб сервер подобно nginx/apache и т.д. которые реализуют этот протокол.

Если так, то читать rfc и делать. Если нет, то брать например ratchet или любую другую библиотеку в которой уже реализован websocket протокол.

С mysql проблема в том, что она не умеет стримить данные в реалтайме и работает в режиме request-response, также как http протокол. Поэтому либо использовать старый-добрый поллинг базы раз в N время либо искать что-то похожее на mysql-live-select для php, но я не видел. Идея в том, что скрипт прикидывается как slave и слушает бинарный лог изменений.

Comments

[Mr_Romanov]

Какой же профит тогда в этом WS, лишний перегруз кода, выходит лонгпулинги с демоном вопрос/ответ для всех клиентов самый лучший? Особенно для тех кто не любит сторонние решения в своих приложениях?

[xfg]

Mr_Romanov: да ws устраняет проблему request-response на уровне браузера и приложения, но эта же проблема всё еще остается на уровне приложения и базы данных. Фактически переходит перекладывание poll-решений с уровня "браузер - приложение", на уровень "приложение - база данных". Заявленный как realtime фреймворк Meteor по сути так и работает, на поллинге базы и прослушивании лога репликации.

Но realtime db уже появляются, яркий представитель rethinkdb. Там сейчас конечно много еще чего нет, например транзакций или realtime join запросов, но разработчики обещают со временем всё добавить.

Еще как альтернатива поллингу, теоретически при insert/update/delete можно было бы руками посылать нужные данные по ws своим клиентам. На практике , если проект сложный то это становится трудно поддерживать, так как быстро выясняется, что от одного update запроса может зависеть куча различных событий и все эти события нужно послать клиенту.

В общем идеальных решений для realtime web пока нет.

[Mr_Romanov]

xfg: спасибо за столь интересный развернутый ответ!

Answer 2

[Александр Аксентьев]

ПХП не для этого, поэтому лучше не трогать его вообще, а сделать на nodejs несколько строк.

чистый PHP без всяких демонпхп и прочего.

Так как пхп не для этого он не умеет из коробки демонизироваться сам по себе.

Так что быстрее почитать про nodejs и написать на нем 50-100 строк кода.

-----

Еще не понятно клиент это тоже пхп что ли? Или все-таки браузер?

Comments

[Mr_Romanov]

Конечно браузер с jQuery например

[Night]

PHP прекрасно умеет работать как демон, как upstart / service в linux'e.
Достаточно написать пару магических строк:
while(true) { doSomething(); sleep(1); }
Начиная с последнего времени пых не ликает по памяти, не крэшится по желанию левой пятки, и просто не чудит, как мог ранее.
У меня некоторые демоны на пыхе запущены месяцами и не требуют перезапуска.

[Александр Аксентьев]

Night: уметь-то умеет, микроскопом тоже гвозди забивать можно знаете ли :)

[Mr_Romanov]

Александр Аксентьев: демоны на PHP отлично работают даже на винде где нет PID и не требуют перезапусков. Тут я полностью согласен. Поэтому решение - изучи новый язык отпадает само по себе.

[Night]

Александр Аксентьев: с удовольствием подискутирую на этому тему, если приведете значимые минусы пыха в роли демона :)

[Александр Аксентьев]

Night: запускал ratchet сокеты для теста(год два назад), процесс переставал отвечать при 50 подключенных клиентах. Со старымы(первые 50 клиентов) более менее общался, новым просто не отвечал, как-будто выключен.

Больше я даже не пытался.

[Александр Аксентьев]

Mr_Romanov: для такой задачи даже изучать не надо ничего.
Поднять сервер кодом из документации и добавить один вызов функции с интервалом для рассылки обновлений.
Это даже меньше чем 50 строк наверно.
Да и язык JS, а не какой-то новый. На JS то явно кодил человек раньше, хотя бы тот же клиент который он собирается подключить к серверу.

[Night]

Александр Аксентьев: Это уже больше вопрос к ратчет, чем к самому пхп... речь то шла про "демонизацию" приложения.

[Александр Аксентьев]

Night: Да неправильно выразился. Я тоже имел в виду именно запуска WS сервера на php идея так себе.

В целом-то с демонами проблем вроде нет.
А демоны попроще отлично работают, воркер для rabbitmq например или просто какой-нибудь обработчик данных.

[Mr_Romanov]

Александр Аксентьев: давайте пример в студию с 50 строками которые предполагают интеграцию с браузерным клиентом на PHP

[Александр Аксентьев]

Mr_Romanov:
> предполагают интеграцию с браузерным клиентом на PHP
щито?

Берете WS сервер: https://github.com/sitegui/nodejs-websocket
MySQL клиент: https://github.com/mysqljs/mysql

запускаете сервер, и делаете setInterval() в котором получаете из базы новые записи, затем broadcast всем клиентам.

Готовый код никто не даст) Его же писать надо

[Mr_Romanov]

Александр Аксентьев: Явно здесь не 50 строк с broadcast. Лонгпулл демон который так же будет вещать на PHP всем клиентам будет меньше 50 строк и не будет требовать дополнительных модулей.

[Александр Аксентьев]

Mr_Romanov:
запустить сервер ~10 строк
подключиться к базе ~10 строк
функция сделать запрос в базу и broadcast максимум строк 20-30
setINterval с вызовом функции 1 строка.

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

[Mr_Romanov]

Александр Аксентьев: вот на словах это у всех просто а реального примера из кода никто не может привести тк когда начинаешь писать понимаешь что не всё так гладко.

Поэтому в сети ходит 3.5 примера по использованию WS в связке с php и mysql + что угодно хоть тот же нод. И все они еле работают и дыр в них просто бесконечное количество.

[Александр Аксентьев]

Mr_Romanov: чтобы готовый код получить это на соседний сайт https://freelansim.ru/

Это и есть просто, вы бы уже написали всё, пока считали тут строки кода :)

[Mr_Romanov]

Александр Аксентьев: у меня есть примеры такого кода и в них куча проблем, поэтому 100 процессов на 100 человек это полная ерунда по сравнению с брешью в коде с WS и Node

[Александр Аксентьев]

Mr_Romanov: если кода почти нет, какие там могут быть проблемы?
Вы же только читаете данные и рассылаете.
Никаких проверок не надо, безопасности и т.д.

Тупо сделать один запрос в базу, получить данные и отправить клиентам.

[Александр Аксентьев]

Mr_Romanov: https://codeforgeek.com/2015/03/real-time-app-sock...
третья ссылка в гугле, почти готовый код.

[Mr_Romanov]

Александр Аксентьев: в этом примере есть огромная дыра в безопасности.

[Александр Аксентьев]

Mr_Romanov: в вашем случае вы не пишете в базу ничего, какая у вас там дыра в безопасности будет?

А пример для того и пример, а не готовый к продакшну проект.

Answer 3

[BoShurik]

Пример
В вашем случае:
php bin/message.php - опрашивает БД на наличие новых записей и при наличии новой записи отправляет её клиенту
php bin/server.php - WebSocket server, который обрабатывает соединения

client.php - опрашивает демона на изменения БД;

Если я правильно понял, в этом случае результат выхлопа используется в php bin/message.php

Comments

[Mr_Romanov]

В вашем примере есть Ratchet, я не хочу использовать подобные решения. Поэтому прошу чистый PHP + элементарный jQuery

[BoShurik]

Mr_Romanov: Ratchet же на PHP написан. Если не хочется использовать сторонние решения вообще, то Александр Аксентьев прав, ибо вам придется реализовать функциональность https://github.com/reactphp

P.S. В чем причина написания велосипеда, вместо использования сторонних компонентов? Надеюсь, академический интерес?

[xfg]

BoShurik: не обязательно, reactphp это просто асинхронная платформа. Этот тренд появился с момента появления nodejs. Но есть и другие варианты. Например в сетевых десктоп приложениях (игры например) очень развит подход с воркерами (дочерние процессы или треды), как в веб сервере apache, т.е. только master процесс является асинхронным и отвечает за коннект клиентов и прием запросов от этих клиентов, а далее отдает воркеру, который работает в обычном синхронном режиме. Если все воркеры сейчас заняты, то ставит запрос в очередь на обработку.

По большему счету все эти асинхронные платформы работают также, просто это скрыто от пользователя. Ибо магии не бывает, и на каком-то уровне все равно нужно создать дочерний процесс/тред для обработки запроса. Так что внутри какого-нибудь event loop те же дочерние процессы https://developer.gnome.org/glib/stable/glib-The-M...
Вот и всё. Но все относятся к nodejs, reactphp и т.д. как к какой-то магии :(

[xfg]

BoShurik: чтобы понять, что никакой true асинхронности не существует в компьютер сайнс, достаточно почитать как работает процессор компьютера :)

Answer 4

[Night]

А в чем собственно у Вас возникла сложность?
Хотите нативный пхп ws - берите пхп, спецификацию протокола WS - реализуете, а потом используете в своем няшном приложении без "PHP без всяких демонпхп и прочего".

Если вопрос в том, как понять появилась ли новая строка для разных клиентов, то то же довольно просто.
Сейвим в память ID последней строчки для каждого клиента, и раз в Х сек. проверяем, не появились ли новые записи (с ID выше чем запомнили для этого клиента), если нашлись - шлем данные по WS клиенту.

Answer 5

[Артемий]

А тут чего не хватает Делаем вебсокеты на PHP ?