Ratchet PHP WAMP – React / ZeroMQ – Конкретная передача пользователей

Примечание. Мой ответ здесь не содержит ссылок на ZeroMQ, поскольку я больше его не использую. Тем не менее, я уверен, что вы сможете выяснить, как использовать ZeroMQ с этим ответом, если вам нужно.

Использовать JSON

Прежде всего, Websocket RFC и WAMP Spec указывают, что тема для подписки должна быть строкой . Я немного обманываю здесь, но я все еще придерживаюсь спецификации: вместо этого я пропускаю JSON.

 { "topic": "subject here", "userId": "1", "token": "dsah9273bui3f92h3r83f82h3" } 

JSON по-прежнему является строкой, но он позволяет мне передавать больше данных вместо «темы», и для PHP просто сделать json_decode() на другом конце. Конечно, вы должны подтвердить, что вы действительно получаете JSON, но это зависит от вашей реализации.

Итак, что я здесь прохожу и почему?

• тема

Тема – тема, на которую подписывается пользователь. Вы используете это, чтобы решить, какие данные вы передадите пользователю.

• Идентификатор пользователя

Очевидно, идентификатор пользователя. Вы должны убедиться, что этот пользователь существует и ему разрешено подписываться, используя следующую часть:

• знак

Это должен быть один случайный сгенерированный токен, сгенерированный в вашем PHP, и переданный переменной JavaScript. Когда я говорю «одно использование», я имею в виду, что каждый раз, когда вы перезагружаете страницу (и, соответственно, каждый HTTP-запрос), ваша переменная JavaScript должна иметь новый токен. Этот токен должен храниться в базе данных по идентификатору пользователя.

Затем, как только запрос websocket выполняется, вы сопоставляете токены и идентификатор пользователя с данными в базе данных, чтобы убедиться, что пользователь действительно является тем, кем они себя называют, и они не возились с переменными JS.

Примечание. В обработчике событий вы можете использовать $conn->remoteAddress чтобы получить IP-адрес соединения, поэтому, если кто-то пытается подключиться злонамеренно, вы можете заблокировать их (зарегистрировать их или что-то еще).

Почему это работает?

Это работает, потому что каждый раз, когда приходит новое соединение, уникальный токен гарантирует, что ни у кого не будет доступа к данным подписки кого-либо еще.

Сервер

Вот что я использую для запуска цикла и обработчика событий. Я создаю цикл, делая все создание объекта стиля декоратора и передавая в свой EventHandler (который я скоро приду) с петлей там тоже.

 $loop = Factory::create(); new IoServer( new WsServer( new WampServer( new EventHandler($loop) // This is my class. Pass in the loop! ) ), $webSock ); $loop->run(); 

Обработчик событий

 class EventHandler implements WampServerInterface, MessageComponentInterface { /** * @var \React\EventLoop\LoopInterface */ private $loop; /** * @var array List of connected clients */ private $clients; /** * Pass in the react event loop here */ public function __construct(LoopInterface $loop) { $this->loop = $loop; } /** * A user connects, we store the connection by the unique resource id */ public function onOpen(ConnectionInterface $conn) { $this->clients[$conn->resourceId]['conn'] = $conn; } /** * A user subscribes. The JSON is in $subscription->getId() */ public function onSubscribe(ConnectionInterface $conn, $subscription) { // This is the JSON passed in from your JavaScript // Obviously you need to validate it's JSON and expected data etc... $data = json_decode(subscription->getId()); // Validate the users id and token together against the db values // Now, let's subscribe this user only // 5 = the interval, in seconds $timer = $this->loop->addPeriodicTimer(5, function() use ($subscription) { $data = "whatever data you want to broadcast"; return $subscription->broadcast(json_encode($data)); }); // Store the timer against that user's connection resource Id $this->clients[$conn->resourceId]['timer'] = $timer; } public function onClose(ConnectionInterface $conn) { // There might be a connection without a timer // So make sure there is one before trying to cancel it! if (isset($this->clients[$conn->resourceId]['timer'])) { if ($this->clients[$conn->resourceId]['timer'] instanceof TimerInterface) { $this->loop->cancelTimer($this->clients[$conn->resourceId]['timer']); } } unset($this->clients[$conn->resourceId]); } /** Implement all the extra methods the interfaces say that you must use **/ } не class EventHandler implements WampServerInterface, MessageComponentInterface { /** * @var \React\EventLoop\LoopInterface */ private $loop; /** * @var array List of connected clients */ private $clients; /** * Pass in the react event loop here */ public function __construct(LoopInterface $loop) { $this->loop = $loop; } /** * A user connects, we store the connection by the unique resource id */ public function onOpen(ConnectionInterface $conn) { $this->clients[$conn->resourceId]['conn'] = $conn; } /** * A user subscribes. The JSON is in $subscription->getId() */ public function onSubscribe(ConnectionInterface $conn, $subscription) { // This is the JSON passed in from your JavaScript // Obviously you need to validate it's JSON and expected data etc... $data = json_decode(subscription->getId()); // Validate the users id and token together against the db values // Now, let's subscribe this user only // 5 = the interval, in seconds $timer = $this->loop->addPeriodicTimer(5, function() use ($subscription) { $data = "whatever data you want to broadcast"; return $subscription->broadcast(json_encode($data)); }); // Store the timer against that user's connection resource Id $this->clients[$conn->resourceId]['timer'] = $timer; } public function onClose(ConnectionInterface $conn) { // There might be a connection without a timer // So make sure there is one before trying to cancel it! if (isset($this->clients[$conn->resourceId]['timer'])) { if ($this->clients[$conn->resourceId]['timer'] instanceof TimerInterface) { $this->loop->cancelTimer($this->clients[$conn->resourceId]['timer']); } } unset($this->clients[$conn->resourceId]); } /** Implement all the extra methods the interfaces say that you must use **/ } 

Это в основном это. Основные моменты здесь:

• Уникальный токен, идентификатор пользователя и идентификатор соединения обеспечивают уникальную комбинацию, необходимую для обеспечения того, чтобы один пользователь не мог видеть данные другого пользователя.
• Уникальный токен означает, что, если один и тот же пользователь открывает другую страницу и запрашивает подписку, у них будет своя комбинация id + токенов, так что у одного и того же пользователя не будет двойной подписки на той же странице (в основном, каждое соединение имеет свои собственные отдельные данные).

расширение

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

Точки закрытия

• Подтвердите все . Я не могу это подчеркнуть. Ваш уникальный токен, который изменяется по каждому запросу, важен .
• Помните, что если вы повторно генерируете токен в каждом HTTP-запросе и вы делаете запрос POST перед попыткой подключения через веб-сайты, вам нужно будет передать повторно сгенерированный токен на ваш JavaScript, прежде чем пытаться подключиться (иначе ваш токен будет недействительным).
• Записывайте все . Ведите учет всех, кто подключается, спрашивает, какую тему, и отключается. Монолог отлично подходит для этого.

Чтобы отправить конкретным пользователям, вам понадобится шаблон ROUTER-DEALER вместо PUB-SUB. Это объясняется в Руководстве в главе 3. Безопасность, если вы используете ZMQ v4.0, обрабатывается на уровне проводов, поэтому вы не видите ее в приложении. Это по-прежнему требует некоторой работы, если вы не используете привязку CZMQ, которая обеспечивает структуру аутентификации (zauth).

В принципе, для аутентификации вы устанавливаете обработчик inproc: //zeromq.zap.01 и отвечаете на запросы по этому сокету. ZeroMQ ZAP для RFC; есть также тестовый пример в основной программе libzmq / tests / test_security_curve.cpp.