Node.js Backend Development Bootcamp · 课时

使用消息队列进行服务间通信

学习如何使用 RabbitMQ 等消息队列，让微服务异步通信，从而解耦服务并提升弹性

使用消息队列进行服务间通信 是 CoddyKit 上的免费 Node.js Backend Development Bootcamp 课时。这是第 4 节课，共 4 节。你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。这是 Node.js Backend Development Bootcamp 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Node.js Backend Development Bootcamp 课程共包含 4 节课。

本课时的部分内容尚未翻译，以英文显示。

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 with consume
Use ack to guarantee delivery
Fanout exchanges enable pub/sub; dead-letter queues handle failures

Messaging makes microservice systems resilient and scalable.

常见问题解答

「使用消息队列进行服务间通信」课时是免费的吗？

是的 — 「使用消息队列进行服务间通信」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Node.js Backend Development Bootcamp 课程的其余内容，请升级到 CoddyKit PRO。 Node.js Backend Development Bootcamp 课程共包含 4 节课。

「使用消息队列进行服务间通信」这节课中我会学到什么？

学习如何使用 RabbitMQ 等消息队列，让微服务异步通信，从而解耦服务并提升弹性你通过在浏览器中直接运行的动手代码来练习 Node.js Backend Development Bootcamp，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Node.js Backend Development Bootcamp 需要有经验吗？

无需任何先前经验。CoddyKit 上的 Node.js Backend Development Bootcamp 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。这是第 4 节课，共 4 节。

「使用消息队列进行服务间通信」课时需要多长时间？

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。

我能在这节 Node.js Backend Development Bootcamp 课中编写并运行代码吗？

能。每节 Node.js Backend Development Bootcamp 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

微服务架构简介
开发 Node.js 微服务
实现 API 网关
使用消息队列进行服务间通信

← 返回 Node.js Backend Development Bootcamp