Для реализации своего проекта решил использовать netty. Приложение должно действовать по такому алгоритму:
- Клиент подключается к серверу и все время посылает необходимые данные для обновления.
- Сервер обрабатывает эти данные и отсылает все изменения широковещательным сообщением для всех клиентов (что-то вроде UDP)
Проблема состоит в том, как такое реализовать? Если мы добавим новый Handler в наш PipeLine и унаследуем его от SimpleChannelInboundHandler, то у нас будут доступны только следующие методы:
- channelActive - при подключении пользователя делаем что-то
- channelRead0 - при получении сообщения делаем что-то
- exceptionCaught - закрываем соединение.
И все, мы сюда не можем вставить како-либо широковещание. Выходом будет, если клиент будет постоянно посылать сообщения с запросом об обновлении, тогда в channelRead0 мы сможем отсылать обновления для конкретного клиента, но такая реализация не подходит.
При поисках ответа наткнулся на этот вопрос, который подсказал, что необходимо использовать ChannelGroup.
Как реализовать что-то вроде myServer.sendBroadcast("message"); ?