Berichtenconcepten

Met asynchrone berichtenuitwisseling kunnen services communiceren zonder elkaar rechtstreeks aan te roepen. Een producent plaatst een bericht; een consument haalt het later op. Hierdoor zijn services losgekoppeld, worden pieken in de belasting afgevlakt en blijft het systeem veerkrachtig wanneer een consument tijdelijk niet beschikbaar is.

MassTransit is een .NET-raamwerk dat boven op message brokers zoals RabbitMQ of Azure Service Bus werkt. Het handelt serialisatie, routering, nieuwe pogingen en meer af, zodat je je kunt richten op berichten en verwerkers in plaats van op de technische details van de broker.

Er zijn twee belangrijke bedoelingen van berichten. Een opdracht vertelt een specifieke service dat die iets moet doen ("ChargePayment"). Een gebeurtenis kondigt aan dat er iets is gebeurd ("OrderPlaced") aan iedereen die daarin geïnteresseerd is. Opdrachten hebben één verwerker; gebeurtenissen kunnen er veel hebben.

Een opdracht is een eenvoudig berichttype met een gebiedende naam. Stuur het naar één consument.

Een gebeurtenis krijgt een naam in de verleden tijd en wordt gepubliceerd naar alle geïnteresseerde abonnees.

Een wachtrij bewaart berichten totdat een consument ze verwerkt. Dit werkt van punt tot punt: elk bericht wordt aan precies één consument afgeleverd, zodat de belasting over meerdere instanties van consumenten kan worden verdeeld (concurrerende consumenten).

Brokers zoals RabbitMQ routeren via exchanges. Een producent publiceert naar een exchange, die het bericht doorstuurt naar alle gekoppelde wachtrijen. Zo bereikt één gebeurtenis meerdere abonnees.

MassTransit koppelt je berichttypen automatisch aan exchanges en wachtrijen. Send richt zich op een wachtrij (opdracht); Publish richt zich op een exchange, zodat de wachtrij van elke geabonneerde consument een kopie ontvangt (gebeurtenis).

De orderservice publiceert OrderPlaced en gaat verder. Onafhankelijk daarvan verwerken een e-mailservice en een analyseservice de gebeurtenis elk afzonderlijk. Voor het toevoegen van een nieuwe abonnee hoeft de producent niet te worden gewijzigd.

Brokers bieden doorgaans at-least-once-levering: na een fout kan een bericht opnieuw worden afgeleverd. Consumenten moeten daarom idempotent zijn, zodat het veilig is om hetzelfde bericht twee keer te verwerken.

Kies voor berichtenuitwisseling wanneer werk asynchroon kan worden uitgevoerd, wanneer je services wilt ontkoppelen of wanneer je pieken wilt opvangen. Voor een onmiddellijk antwoord op een aanvraag kan een rechtstreekse API-aanroep nog steeds eenvoudiger zijn.

Asynchrone berichtenuitwisseling ontkoppelt services via een broker. MassTransit schermt brokers zoals RabbitMQ af. Opdrachten (gebiedend, één verwerker) worden verzonden naar een wachtrij; gebeurtenissen (verleden tijd, meerdere verwerkers) worden gepubliceerd naar een exchange, die ze doorstuurt naar abonnees. Ga uit van at-least-once-levering en maak consumenten daarom idempotent.