В проекте, над которым я работаю, нам нужен способ реализовать трансляцию неструктурированной доставки сообщений на все физические узлы (серверы).Я ожидаю "звездную" архитектуру, например, все узлы подключены к мультиплексору сообщений через TCP, который отправляет сообщения всем подключенным узлам (кроме отправителя сообщения) при получении сообщения
Чтобы быть более точным, рассмотритеслучай:
- n физических машин (узлов) с запущенным экземпляром приложения.Каждое приложение имеет вид сбора данных, например, std :: map
- Каждый раз, когда происходят какие-либо изменения в сборе данных любого узла, приложение отправляет сообщение, которое содержит неструктурированные данные о том, что изменилось, в мультиплексор сообщений
- Мультиплексор сообщений отправляет полученное сообщение всем подключенным узлам, чтобы все узлы могли синхронизироваться со сборами данных, работающими в других службах
Не могли бы вы посоветовать бесплатный(в идеале с открытым исходным кодом) высокопроизводительный продукт (библиотека / фреймворк / и т. д.), который может помочь реализовать описанный выше случай?
Спасибо за вашу помощь!