Piszę prostą, jednorodną aplikację klastrową przy użyciu Akka 2.2.3 i Scala; algorytm filtrowania cząstek, w którym każdy węzeł dzieli dane z innymi członkami klastra w losowych punktach w czasie. Obecnie jest to aplikacja badawcza, a nie system krytyczny dla biznesu.

Obecnie każdy węzeł wysyła wiadomość o stałym rozmiarze do losowo wybranego węzła co sekundę. To działa, ale mam obawy dotyczące wydajności podczas skalowania (np. Chmura w porównaniu z lokalnym)

Węzły mogą zostać przeciążone wysyłając daneWęzły mogą zostać przeciążone przychodzącymi wiadomościami od innych członków klastraSieć może stać się wąskim gardłem

Chciałbym uruchomić aplikację z klastrami wielkości w różnych sieciach i osiągnąć dobrą wydajność bez ręcznego strojenia / monitorowania.Jakie proste podejścia mogę zastosować do dostrajania rozmiaru i częstotliwości wiadomości, aby złagodzić powyższe obawy?