Я пишу простое однородное кластерное приложение с использованием Akka 2.2.3 и Scala; алгоритм фильтрации частиц, в котором каждый узел обменивается данными с другими членами кластера в случайные моменты времени. В настоящее время это приложение для исследований, а не критическая для бизнеса система.

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

Узлы могут быть перегружены при отправке данныхУзлы могут быть перегружены входящими сообщениями от других участников кластераСеть может стать узким местом

Я хотел бы запустить приложение с кластерами размером в разные сети и добиться хорошей производительности без ручной настройки / мониторинга.Какие простые подходы я могу использовать для настройки размера и частоты сообщений, чтобы уменьшить вышеупомянутые проблемы?