Bootcamp backendontwikkeling met Node.js · Les

Communicatie tussen services met message queues

Leer hoe microservices asynchroon met elkaar communiceren via message queues zoals RabbitMQ, zodat services ontkoppeld worden en de veerkracht verbetert.

Les 4 van 413 stappen

Communicatie tussen services met message queues is een gratis Bootcamp backendontwikkeling met Node.js-les op CoddyKit. Dit is les 4 van 4. Je kunt de volledige les hieronder gratis lezen en daarna in de browser praktisch oefenen met een ingebouwde code-editor en een AI-begeleider die 24/7 beschikbaar is. Deze les maakt deel uit van het leertraject Bootcamp backendontwikkeling met Node.js. Je voortgang wordt gesynchroniseerd op het web en in de CoddyKit-app. De cursus Bootcamp backendontwikkeling met Node.js bevat in totaal 4 lessen.

Synchrone versus asynchrone communicatie

Microservices kunnen op twee manieren met elkaar communiceren:

Synchroon (HTTP/gRPC): de aanroeper wacht op een antwoord
Asynchroon (berichten): de aanroeper verstuurt een bericht en gaat verder

Asynchrone communicatie ontkoppelt services, zodat een trage of niet-beschikbare consument de producent niet blokkeert.

Wat is een berichtenwachtrij?

Een berichtenwachtrij is een buffer waarin berichten worden bewaard totdat een consument klaar is om ze te verwerken. Producenten plaatsen berichten erin en consumenten halen ze eruit — meestal in FIFO-volgorde.

Populaire brokers zijn RabbitMQ, Kafka en Redis Streams.

Belangrijkste voordelen

Wachtrijen bieden belangrijke voordelen in een microservicesysteem:

Ontkoppeling: services hoeven niets over elkaar te weten
Veerkracht: berichten wachten als een consument niet beschikbaar is
Belastingsnivellering: pieken worden afgevlakt
Schaalbaarheid: voeg meer consumenten toe om sneller te verwerken

Kernbegrippen

Drie rollen bepalen dit patroon:

Producent: publiceert berichten
Wachtrij: slaat ze op
Consument: ontvangt en verwerkt ze

In RabbitMQ bevindt een exchange zich tussen de producent en de wachtrij en bepaalt deze de routering.

Verbinden vanuit Node.js

Het pakket amqplib verbindt Node.js met RabbitMQ. Je opent een verbinding en vervolgens een kanaal voor het verzenden en ontvangen.

const amqp = require('amqplib');
const conn = await amqp.connect('amqp://localhost');
const channel = await conn.createChannel();

Een wachtrij declareren

Declareer de wachtrij voordat je berichten verstuurt, zodat deze bestaat. De optie durable zorgt ervoor dat de wachtrij een herstart van de broker overleeft.

await channel.assertQueue('orders', { durable: true });

Een bericht publiceren

Verstuur een bericht met sendToQueue. Berichten zijn buffers, dus serialiseer objecten eerst naar JSON.

const order = { id: 7, total: 99 };
channel.sendToQueue('orders', Buffer.from(JSON.stringify(order)), {
  persistent: true
});

Berichten consumeren

Een consument abonneert zich met consume. Elk afgeleverd bericht wordt geparseerd en verwerkt.

channel.consume('orders', (msg) => {
  const order = JSON.parse(msg.content.toString());
  console.log('Processing order', order.id);
});

Bevestigingen

Om te voorkomen dat werk verloren gaat wanneer een consument vastloopt, wacht RabbitMQ op een bevestiging. Pas nadat je channel.ack(msg) aanroept, wordt het bericht uit de wachtrij verwijderd.

channel.consume('orders', (msg) => {
  handle(JSON.parse(msg.content.toString()));
  channel.ack(msg);
});

Publiceren/abonneren met fanout

Soms hebben meerdere services dezelfde gebeurtenis nodig, bijvoorbeeld wanneer een bestelling is geplaatst. Een fanout-exchange verspreidt een bericht naar elke gekoppelde wachtrij, waardoor het publiceer/abonneerpatroon mogelijk wordt.

await channel.assertExchange('events', 'fanout');
channel.publish('events', '', Buffer.from('order.created'));

Omgaan met fouten

Een robuuste berichtenarchitectuur voorziet in strategieën voor fouten:

Nieuwe pogingen voor tijdelijke fouten
Dead-letter-wachtrijen voor berichten die steeds blijven mislukken
Idempotentie, zodat het veilig is om hetzelfde bericht opnieuw te verwerken

Korte controle

Test je kennis over berichtenverwerking.

Beantwoord dit in de interactieve les

Herhaling

Je hebt asynchrone communicatie tussen services geleerd:

Berichtenwachtrijen ontkoppelen producenten van consumenten
Maak verbinding met amqplib en declareer duurzame wachtrijen
Publiceer met sendToQueue en consumeer met consume
Gebruik ack om aflevering te garanderen
Fanout-exchanges maken pub/sub mogelijk; dead-letter-wachtrijen handelen fouten af

Berichtenverwerking maakt microservicesystemen veerkrachtig en schaalbaar.

Gratis beginnen

Leer JavaScript met een AI-tutor — gratis

Schrijf echte code en voer die uit in je browser, krijg direct hulp van een AI-tutor die 24/7 beschikbaar is en ga verder waar je gebleven bent op het web of in de app.

Cursussen: 22
Lessen: 92

Gratis beginnen met leren Bekijk de volledige cursus

Veelgestelde vragen

Is de les “Communicatie tussen services met message queues” gratis?

Ja — de volledige tekst van “Communicatie tussen services met message queues” kun je hier gratis op het web lezen. Als je interactief wilt oefenen met een ingebouwde code-editor en een AI-begeleider die 24/7 beschikbaar is, en de rest van de cursus Bootcamp backendontwikkeling met Node.js wilt ontgrendelen, kun je upgraden naar CoddyKit PRO. De cursus Bootcamp backendontwikkeling met Node.js bevat in totaal 4 lessen.

Wat leer ik in “Communicatie tussen services met message queues”?

Leer hoe microservices asynchroon met elkaar communiceren via message queues zoals RabbitMQ, zodat services ontkoppeld worden en de veerkracht verbetert. Je oefent met Bootcamp backendontwikkeling met Node.js door code rechtstreeks in de browser uit te voeren. Een AI-begeleider die 24/7 beschikbaar is beantwoordt je vragen terwijl je de les doorwerkt.

Heb ik ervaring nodig om met Bootcamp backendontwikkeling met Node.js te beginnen?

Ervaring vooraf is niet nodig. Bootcamp backendontwikkeling met Node.js op CoddyKit is opgebouwd voor beginners tot gevorderden, zodat je hier of bij het begin kunt starten en in je eigen tempo kunt leren. Dit is les 4 van 4.

Hoe lang duurt de les “Communicatie tussen services met message queues”?

De meeste lessen van CoddyKit duren ongeveer 5–10 minuten. Elke les is kort en interactief, zodat je gestaag vooruitgaat en op het web en in de app precies verdergaat waar je was gebleven.

Kan ik code schrijven en uitvoeren in deze les over Bootcamp backendontwikkeling met Node.js?

Ja. Elke les over Bootcamp backendontwikkeling met Node.js bevat een ingebouwde code-editor, zodat je rechtstreeks in je browser echte code kunt schrijven en uitvoeren en direct feedback van AI krijgt — lokale installatie is niet nodig.

Alle lessen in deze cursus

Inleiding tot microservicesarchitectuur
Node.js-microservices ontwikkelen
Een API Gateway implementeren
Communicatie tussen services met message queues

← Terug naar Bootcamp backendontwikkeling met Node.js