Node.js Backend Development Bootcamp · レッスン

メッセージキューによるサービス間通信

RabbitMQなどのメッセージキューを使って、マイクロサービスが非同期に通信する仕組みを学びます。サービスを疎結合にし、耐障害性を高めます。

「メッセージキューによるサービス間通信」はCoddyKit上の無料Node.js Backend Development Bootcampレッスンです。これはレッスン4/4です。下記で完全なレッスンを無料で読むことができます。その後、ブラウザ内の組み込みコードエディタと24時間対応の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.

よくある質問

「メッセージキューによるサービス間通信」レッスンは無料ですか？

はい。「メッセージキューによるサービス間通信」の完全なテキストはこのウェブで無料で読めます。インタラクティブに演習し（組み込みコードエディタと24時間対応のAIチューター）、Node.js Backend Development Bootcampコースの残りをアンロックするには、CoddyKit PROにアップグレードしてください。 Node.js Backend Development Bootcampコースには全4レッスンが含まれています。

「メッセージキューによるサービス間通信」で何を学びますか？

RabbitMQなどのメッセージキューを使って、マイクロサービスが非同期に通信する仕組みを学びます。サービスを疎結合にし、耐障害性を高めます。ブラウザで直接実行するハンズオンコードでNode.js Backend Development Bootcampを演習し、24時間対応の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 Backend Development Bootcampに戻る