Введение

WebSocket, как мы полагаем, всем знаком по использованию. Он широко применяется в таких областях, как обмен мгновенными сообщениями (IM), пересылка сообщений, игры и прямые трансляции. Как же организовать пересылку сообщений между разными пользователями в среде кластера с несколькими серверами WebSocket?

Идея

1. Сначала мы реализуем API-сервер, который будет поддерживать постоянное соединение с главным сервером WebSocket через пул соединений:

API-сервер <-> Кластер серверов WebSocket

2. Когда пользователь подключается к кластеру серверов WebSocket, информация о подключении этого пользователя записывается. В неё входит информация о том, какой сервер WebSocket используется, и его fd (файловый дескриптор):

Клиент пользователя <-> Кластер серверов WebSocket

3. Пересылка сообщений между пользователями:

Сообщение пользователя <-> API-сервер <-> Кластер серверов WebSocket <-> Клиент пользователя

Пользователи могут обмениваться сообщениями через API-сервер и главный сервер WebSocket.

Преимущества

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

Демонстрация реализации

• Добавьте Group\Async\Pool\WebSocketPoolServiceProvider в onWorkStartServices в файле app.php.
• Запустите сервер WebSocket: php webscoket.php.
• Запустите API-сервис: php server.php.
• Откройте страницу клиента WebSocket: http://localhost:9778/websocket. Не забудьте открыть инструменты разработчика браузера.
• Реализуйте групповую отправку и пересылку сообщений, вызвав API: http://localhost:9778/sendMsg?msg=hello. Проверьте ответ на странице клиента.

Для более сложных бизнес-логик потребуется изменить взаимодействие кода API и главного сервера WebSocket.