Eventgestuurde architecturen

Gebeurtenisgestuurde architectuur (EDA) is een ontwerppatroon waarbij componenten communiceren door gebeurtenissen te verzenden en erop te reageren. In plaats van functies rechtstreeks aan te roepen, publiceren onderdelen van je systeem gebeurtenissen wanneer er iets interessants gebeurt.

Deze aanpak helpt bij het maken van systemen die:

• Ontkoppeld: componenten hoeven niets van elkaar te weten.
• Schaalbaar: je kunt eenvoudig meer consumenten toevoegen zonder producenten te wijzigen.
• Veerkrachtig: fouten in één onderdeel zullen minder snel het hele systeem platleggen.

Een gebeurtenis is een registratie van iets dat is gebeurd. Het is meestal een klein, onveranderlijk bericht met gegevens over de gebeurtenis, maar niet de opdracht om een actie uit te voeren.

Zie het als een krantenkop: "Gebruiker heeft zich aangemeld" of "Bestelling geplaatst".

Belangrijke kenmerken:

• Feit: de gebeurtenis beschrijft iets dat heeft plaatsgevonden.
• Onveranderlijk: zodra een gebeurtenis is gepubliceerd, verandert deze niet meer.
• Informatief: bevat relevante gegevens (bijvoorbeeld gebruikers-ID en tijdstempel).

In een EDA zijn er twee hoofdrollen:

• Producenten: dit zijn componenten die gebeurtenissen maken en publiceren. Wanneer een gebruiker zich aanmeldt, kan de "User Service" een gebeurtenis "User Signed Up" produceren.
• Consumenten: dit zijn componenten die zich abonneren op gebeurtenissen en erop reageren. Een "Welcome Email Service" kan gebeurtenissen "User Signed Up" consumeren om een welkomstmail te versturen.

De producent hoeft niet te weten wie de gebeurtenis consumeert, en consumenten hoeven niet te weten wie deze heeft geproduceerd. Dit maakt krachtige ontkoppeling mogelijk!

Hoe vinden producenten en consumenten elkaar? Daar komt een berichtenmakelaar van pas. Een broker fungeert als tussenpersoon: hij ontvangt gebeurtenissen van producenten en bezorgt ze aan geïnteresseerde consumenten.

De broker biedt:

• Ontkoppeling: producenten en consumenten communiceren niet rechtstreeks.
• Duurzaamheid: gebeurtenissen kunnen worden opgeslagen totdat consumenten klaar zijn.
• Routering: gebeurtenissen worden op basis van regels naar de juiste consumenten gestuurd.

Veelgebruikte voorbeelden zijn RabbitMQ, Apache Kafka en AWS SQS.

Clojure is door de focus op onveranderlijkheid en concurrency zeer geschikt voor gebeurtenisgestuurde systemen. We gebruiken vaak speciale clientbibliotheken om met berichtenmakelaars te communiceren.

Voor RabbitMQ is langohr een populaire keuze in Clojure. Deze bibliotheek biedt een eenvoudige API om verbinding te maken, berichten te publiceren en berichten te consumeren.

Laten we bekijken hoe je een basisverbinding instelt en een gebeurtenis publiceert met langohr (conceptueel, omdat een volledige configuratie te uitgebreid is voor een klein fragment).

Om een gebeurtenis te publiceren, maken we verbinding met de berichtenmakelaar en sturen we onze gebeurtenisgegevens naar een specifieke exchange. Een exchange kun je zien als een postkantoor dat berichten routeert.

Hier volgt een vereenvoudigd voorbeeld waarin een gebeurtenis "user.signed-up" wordt gepubliceerd naar een topic-exchange met de naam "events":

Consumenten maken verbinding met de broker en declareren een queue. Vervolgens koppelen ze deze wachtrij aan een exchange met een routing key om specifieke soorten gebeurtenissen te ontvangen. Wanneer er een gebeurtenis binnenkomt, verwerkt een handlerfunctie deze.

Dit voorbeeld toont een consument die luistert naar gebeurtenissen van het type "user.signed-up":

Naast eenvoudige ontkoppeling biedt EDA aanzienlijke voordelen voor complexe systemen:

• Schaalbaarheid: voeg eenvoudig meer consumenten toe om gebeurtenissen parallel te verwerken, of schaal producenten onafhankelijk op.
• Veerkracht: als een consument uitvalt, houdt de berichtenmakelaar gebeurtenissen vast totdat de consument is hersteld, zodat er geen gegevens verloren gaan.
• Controleerbaarheid: gebeurtenissen kunnen worden gelogd en bieden zo een duidelijk controlespoor van systeemactiviteiten.
• Realtimeverwerking: reageer direct op wijzigingen in verschillende services.

Het is een fundamenteel patroon voor microservices en gedistribueerde systemen.

Een krachtig verwant concept is Event Sourcing. In plaats van de huidige toestand van een toepassing op te slaan, sla je alle wijzigingen op als een reeks onveranderlijke gebeurtenissen.

De toestand van de toepassing kan vervolgens worden gereconstrueerd door deze gebeurtenissen opnieuw af te spelen. Dit levert een volledige historische registratie op en vereenvoudigt in sommige situaties het beheer van complexe toestanden.

Hoewel de concepten verwant zijn, richt EDA zich op communicatie tussen services, terwijl Event Sourcing zich richt op de manier waarop één service zijn eigen toestand beheert.

Goed gedaan! Je hebt de basisprincipes van gebeurtenisgestuurde architecturen verkend.

• We hebben geleerd dat gebeurtenissen onveranderlijke feiten zijn over dingen die zijn gebeurd.
• Producenten publiceren gebeurtenissen en consumenten reageren daarop.
• Een berichtenbroker maakt deze communicatie mogelijk en zorgt voor ontkoppeling en veerkracht.
• Clojure-bibliotheken zoals langohr maken het eenvoudig om te integreren met brokers zoals RabbitMQ.

EDA is een cruciaal patroon voor het bouwen van schaalbare, veerkrachtige en ontkoppelde backendsystemen. Blijf oefenen met berichtensystemen om je begrip te verdiepen!