Komunikacja między usługami za pomocą kolejek komunikatów
Poznaj asynchroniczną komunikację mikrousług za pomocą kolejek komunikatów, takich jak RabbitMQ, która rozdziela usługi i zwiększa odporność systemu.
Komunikacja między usługami za pomocą kolejek komunikatów to bezpłatna lekcja Node.js Backend Development Bootcamp na CoddyKit. To lekcja 4 z 4. Możesz przeczytać całą lekcję poniżej za darmo — a potem ćwiczyć ją interaktywnie w przeglądarce z wbudowanym edytorem kodu i tutorem AI dostępnym 24/7. To część ścieżki edukacyjnej Node.js Backend Development Bootcamp, a Twój postęp synchronizuje się między webem a aplikacją CoddyKit. Kurs Node.js Backend Development Bootcamp zawiera 4 lekcji w sumie.
Części tej lekcji nie zostały jeszcze przetłumaczone i są wyświetlane po angielsku.
Synchronous vs Asynchronous Communication
Microservices can talk in two ways:
- Synchronous (HTTP/gRPC): the caller waits for a reply
- Asynchronous (messaging): the caller sends a message and moves on
Async communication decouples services so a slow or down consumer does not block the producer.
What is a Message Queue?
A message queue is a buffer that holds messages until a consumer is ready to process them. Producers push messages in; consumers pull them out — usually in FIFO order.
Popular brokers include RabbitMQ, Kafka, and Redis Streams.
Key Benefits
Queues bring real advantages to a microservice system:
- Decoupling: services do not need to know about each other
- Resilience: messages wait if a consumer is down
- Load leveling: bursts are smoothed out
- Scalability: add more consumers to process faster
Core Concepts
Three roles define the pattern:
- Producer: publishes messages
- Queue: stores them
- Consumer: receives and processes them
In RabbitMQ an exchange sits between producer and queue, deciding routing.
Connecting from Node.js
The amqplib package connects Node.js to RabbitMQ. You open a connection, then a channel for sending and receiving.
const amqp = require('amqplib');
const conn = await amqp.connect('amqp://localhost');
const channel = await conn.createChannel();Declaring a Queue
Before sending, declare the queue so it exists. The durable option makes it survive a broker restart.
await channel.assertQueue('orders', { durable: true });Publishing a Message
Send a message with sendToQueue. Messages are buffers, so serialize objects to JSON first.
const order = { id: 7, total: 99 };
channel.sendToQueue('orders', Buffer.from(JSON.stringify(order)), {
persistent: true
});Consuming Messages
A consumer subscribes with consume. Each delivered message is parsed and processed.
channel.consume('orders', (msg) => {
const order = JSON.parse(msg.content.toString());
console.log('Processing order', order.id);
});Acknowledgements
To avoid losing work if a consumer crashes, RabbitMQ waits for an ack. Only after you call channel.ack(msg) is the message removed from the queue.
channel.consume('orders', (msg) => {
handle(JSON.parse(msg.content.toString()));
channel.ack(msg);
});Publish/Subscribe with Fanout
Sometimes many services need the same event (e.g. order placed). A fanout exchange broadcasts a message to every bound queue, enabling the publish/subscribe pattern.
await channel.assertExchange('events', 'fanout');
channel.publish('events', '', Buffer.from('order.created'));Handling Failures
Robust messaging plans for errors:
- Retries for transient failures
- Dead-letter queues for messages that keep failing
- Idempotency so reprocessing the same message is safe
Quick Check
Test your messaging knowledge.
Recap
You learned asynchronous inter-service communication:
- Message queues decouple producers from consumers
- Connect with
amqplib, declare durable queues - Publish with
sendToQueue, consume withconsume - Use
ackto guarantee delivery - Fanout exchanges enable pub/sub; dead-letter queues handle failures
Messaging makes microservice systems resilient and scalable.
Ucz się JavaScript dzięki korepetycjom AI — za darmo
Pisz i uruchamiaj kod w przeglądarce, otrzymuj natychmiastową pomoc od korepetytora AI dostępnego 24/7 i kontynuuj naukę w sieci lub w aplikacji.
- Kursy
- 22
- Lekcje
- 92
Często zadawane pytania
Czy lekcja „Komunikacja między usługami za pomocą kolejek komunikatów” jest bezpłatna?
Tak — pełny tekst „Komunikacja między usługami za pomocą kolejek komunikatów” jest dostępny za darmo tutaj w sieci. Aby ćwiczyć ją interaktywnie (wbudowany edytor kodu i tutor AI dostępny 24/7) i odblokować resztę kursu Node.js Backend Development Bootcamp, przejdź na CoddyKit PRO. Kurs Node.js Backend Development Bootcamp zawiera 4 lekcji w sumie.
Co nauczysz się w „Komunikacja między usługami za pomocą kolejek komunikatów”?
Poznaj asynchroniczną komunikację mikrousług za pomocą kolejek komunikatów, takich jak RabbitMQ, która rozdziela usługi i zwiększa odporność systemu. Ćwiczysz Node.js Backend Development Bootcamp z praktycznym kodem, który uruchamiasz bezpośrednio w przeglądarce, a tutor AI dostępny 24/7 odpowiada na Twoje pytania podczas pracy nad lekcją.
Czy potrzebuję doświadczenia, aby zacząć Node.js Backend Development Bootcamp?
Nie wymagamy żadnego doświadczenia. Node.js Backend Development Bootcamp w CoddyKit jest strukturyzowany dla początkujących i zaawansowanych użytkowników, więc możesz zacząć tutaj lub od początku i uczyć się w swoim tempie. To lekcja 4 z 4.
Ile czasu zajmuje lekcja „Komunikacja między usługami za pomocą kolejek komunikatów”?
Większość lekcji CoddyKit trwa około 5–10 minut. Każda lekcja to mały, interaktywny krok, dzięki czemu robisz systematyczne postępy i zawsze wracasz dokładnie do tego samego miejsca — na webie i w aplikacji.
Czy mogę pisać i uruchamiać kod w tej lekcji Node.js Backend Development Bootcamp?
Tak. Każda lekcja Node.js Backend Development Bootcamp zawiera wbudowany edytor kodu, więc piszesz i uruchamiasz prawdziwy kod bezpośrednio w przeglądarce i od razu otrzymujesz sprzężenie zwrotne od AI — bez konfiguracji na komputerze.
Wszystkie lekcje w tym kursie
- Wprowadzenie do architektury mikrousług
- Tworzenie mikrousług Node.js
- Implementowanie API Gateway
- Komunikacja między usługami za pomocą kolejek komunikatów