Koncepcje komunikacji

Komunikacja asynchroniczna za pomocą komunikatów pozwala usługom komunikować się bez bezpośredniego wywoływania siebie nawzajem. Producent umieszcza komunikat, a konsument odbiera go później. Rozdziela to usługi, łagodzi skoki obciążenia i zwiększa odporność systemu, gdy konsument jest chwilowo niedostępny.

MassTransit to platforma .NET działająca na brokerach komunikatów, takich jak RabbitMQ lub Azure Service Bus. Obsługuje serializację, routing, ponawianie prób i inne zadania, dzięki czemu mogą się Państwo skupić na komunikatach i handlerach, zamiast zajmować się konfiguracją brokera.

Istotne są dwa rodzaje intencji komunikatów. Polecenie nakazuje konkretnej usłudze wykonanie działania („ChargePayment”). Zdarzenie informuje zainteresowanych odbiorców, że coś się wydarzyło („OrderPlaced”). Polecenie ma jeden handler, a zdarzenie może mieć ich wiele.

Polecenie jest zwykłym typem komunikatu o nazwie wyrażającej działanie. Należy wysłać je do jednego konsumenta.

Zdarzenie nosi nazwę w czasie przeszłym i jest publikowane wszystkim zainteresowanym subskrybentom.

Kolejka przechowuje komunikaty do czasu ich przetworzenia przez konsumenta. Jest mechanizmem punkt-punkt: każdy komunikat jest dostarczany dokładnie jednemu konsumentowi, co umożliwia równoważenie obciążenia między instancjami konsumentów (konkurującymi konsumentami).

Brokerzy tacy jak RabbitMQ kierują komunikaty za pośrednictwem elementów exchange. Producent publikuje komunikat w exchange, który rozsyła go do wszystkich powiązanych kolejek. W ten sposób jedno zdarzenie dociera do wielu subskrybentów.

MassTransit automatycznie mapuje typy komunikatów na exchange i kolejki. Send kieruje komunikat do kolejki (polecenie), a Publish do exchange, dzięki czemu kolejka każdego subskrybującego konsumenta otrzymuje kopię (zdarzenie).

Usługa zamówień publikuje OrderPlaced i przechodzi do dalszej pracy. Niezależnie od niej usługa pocztowa i usługa analityczna odbierają ten komunikat. Dodanie nowego subskrybenta nie wymaga zmiany w producencie.

Brokerzy zazwyczaj oferują dostarczanie co najmniej raz: po błędzie komunikat może zostać dostarczony ponownie. Konsumenci powinni zatem być idempotentni, aby wielokrotne przetworzenie tego samego komunikatu było bezpieczne.

Warto użyć komunikacji za pomocą komunikatów, gdy praca może odbywać się asynchronicznie, gdy potrzebują Państwo rozdzielić usługi lub gdy trzeba absorbować nagłe wzrosty obciążenia. W przypadku natychmiastowej odpowiedzi w modelu żądanie–odpowiedź prostsze może być bezpośrednie wywołanie API.

Proszę sprawdzić znajomość koncepcji komunikacji za pomocą komunikatów.

Komunikacja asynchroniczna za pomocą komunikatów rozdziela usługi za pośrednictwem brokera. MassTransit abstrahuje brokerów takich jak RabbitMQ. Polecenia (wyrażające działanie, z jednym handlerem) są wysyłane do kolejki, a zdarzenia (w czasie przeszłym, z wieloma handlerami) są publikowane w exchange, który rozsyła je do subskrybentów. Należy oczekiwać dostarczania co najmniej raz, dlatego konsumenci powinni być idempotentni.