Clustering Websockets Tyrus Java

Question

Я реализовал кластер на сервере Payara с 3 узлами (A, B & C) в качестве автономных экземпляров. Я использую HAproxy в качестве балансировки нагрузки, и все работает нормально.

Я добавил WebSockets в свой проект, и HAProxy автоматически переключается с HTTP на туннельный режим, когда клиент запрашивает websocket.

Моя проблема заключается в следующем: Мне нужно получить сеанс websocket независимо от подключенного узла. Например: «У меня есть 3 пользователя, подключенных к приложению. Пользователь 1 и Пользователь 2 подключены к узлу А. Пользователь 3 - , подключенный к узлу B. Событие возникает на узле C, для которого пользователю 1 и 3 требуется но я не участвую в сеансах Node C User 1 и User 2 ».

Я попытался использовать распределенный список Hazelcast для хранения сеансов в пользовательском соединении (метод OnOpen). Но когда я назвал метод «добавить» в списке, это исключает исключение HazelcastSerializationException, поскольку объект сеанса Tyrus не является Serializable.

Как я могу решить свою проблему?

Благодаря

Answer 1

Я сомневаюсь, что передача сеансов WebSocket поможет вам, так как вам необходимо уведомить пользователей об узле, к которому они подключены.

Возможно, вы хотите уведомить узлы A и B из узла C, чтобы обновить пользователей, подключенных к ним. Для этого вы можете использовать Hazelcast Topic, чтобы отправить сообщение всем узлам кластера и получить сообщение узлом, который имеет сеанс WebSocket (, отредактированный). Вам нужно получить информацию от узла C до других узлов, у которых есть сеанс, а не наоборот. Передача сеанса другому узлу была бы бесполезной, поскольку сеанс применим только к открытому соединению WebSocket.

(под редакцией) Прежде чем я предложил использовать Hazelcast executor service вместо Topic, но это вызывает проблемы ClassLoader.

Answer 2

Пожалуйста, посмотрите на StreamSerializer, если вы не хотите к/не может добавить любой сериализации логики к классам.

http://docs.hazelcast.org/docs/3.7/manual/html-single/index.html#custom-serialization

Если вы можете добавить логику сериализации, пожалуйста, посмотрите на IdentifiedDataSerializable:

http://docs.hazelcast.org/docs/3.7/manual/html-single/index.html#identifieddataserializable

Есть полные примеры в справочном руководстве.

Вам необходимо убедиться, что объект действительно может быть сериализован. Некоторые объекты никогда не должны быть сериализованы.