Message brokers w architekturze EDA — przegląd podejść

Rola brokera w systemie rozproszonym

Broker komunikatów działa jako pośrednik między systemami publikującymi zdarzenia a systemami je odbierającymi. Odbiera zdarzenie od producenta, zapisuje je w sposób trwały i udostępnia zarejestrowanym konsumentom, niezależnie od tego, czy są oni w danym momencie aktywni.

Model kolejki a model publikuj-subskrybuj

W modelu kolejki każdy komunikat trafia do dokładnie jednego konsumenta z grupy odbiorców, co sprawdza się przy rozdzielaniu obciążenia między wiele instancji tego samego procesu. W modelu publikuj-subskrybuj ten sam komunikat trafia do wszystkich zarejestrowanych subskrybentów niezależnie, co odpowiada scenariuszom, w których kilka odrębnych systemów musi zareagować na to samo zdarzenie.

Tematy i partycje

Wiele platform brokerów organizuje komunikaty w tematy, które mogą być dodatkowo dzielone na partycje w celu zrównoleglenia przetwarzania oraz zachowania kolejności komunikatów w obrębie pojedynczej partycji.

Trwałość komunikatów i retencja

Broker komunikatów przechowuje zdarzenia przez określony czas lub do momentu potwierdzenia odbioru przez konsumenta, w zależności od konfiguracji retencji. Trwałość ta pozwala na odtworzenie przetwarzania w przypadku awarii konsumenta, bez utraty zdarzeń opublikowanych w międzyczasie.

Kryteria wyboru brokera

Wybór konkretnej platformy brokera zależy od wymaganej przepustowości, oczekiwanej trwałości danych, złożoności modelu dostarczania (co najmniej raz, dokładnie raz) oraz istniejącego ekosystemu narzędzi w organizacji. Kryteria te bywają analizowane odrębnie dla każdego projektu integracyjnego.