NestJSはどのようにしてマイクロサービスをサポートしていますか？

Question

Accepted Answer

NestJSは**組み込みマイクロサービスサポート**を備えており、HTTPの代わりにさまざまな**トランスポート**（TCP、Redis、NATS、RabbitMQ、Kafka、gRPC）を介して通信するマイクロサービスとして実行でき、一貫性のあるメッセージベースのプログラミングモデルを使用します。同じNestJS構造（モジュール、サービス、DI）が適用されます。変わるのはトランスポートとメッセージパターンだけです。

## マイクロサービスの作成

```ts
// a microservice listens on a transport instead of HTTP
const app = await NestFactory.createMicroservice(AppModule, {
  transport: Transport.TCP,             // or REDIS, NATS, RMQ, KAFKA, GRPC
  options: { host: "0.0.0.0", port: 3001 },
});
await app.listen();
```

## メッセージパターン対イベントパターン

```ts
@Controller()
export class MathController {
  // REQUEST-RESPONSE: respond to a message and RETURN a result (RPC-style)
  @MessagePattern({ cmd: "sum" })
  sum(data: number[]): number {
    return data.reduce((a, b) => a + b, 0);   // the caller awaits this result
  }

// EVENT-BASED: react to an event, NO response expected (fire-and-forget)
  @EventPattern("order_created")
  handleOrderCreated(data: OrderDto) {
    this.processOrder(data);                   // just react; nothing returned
  }
}
```

2つの通信スタイルがあります：**`@MessagePattern`**はリクエスト-レスポンス用（呼び出し側は結果を待つ、RPCのような）で、**`@EventPattern`**はイベント用（ファイア・アンド・フォーゲット、疎結合 — パブリッシャーは待たない）です。

## 別のマイクロサービスを呼び出す（クライアント側）

```ts
@Injectable()
export class AppService {
  constructor(@Inject("MATH_SERVICE") private client: ClientProxy) {}

async getSum() {
    // send() → request-response (returns an Observable of the result)
    return this.client.send({ cmd: "sum" }, [1, 2, 3]);
    // emit() → fire an event (no response)
    this.client.emit("order_created", orderData);
  }
}
```

`ClientProxy`（`ClientsModule`経由で設定）は他のサービスにメッセージ/イベントを送信します — リクエスト-レスポンスには`send()`、イベントには`emit()`を使用します。

## ハイブリッドアプリケーション

```ts
// an app can serve HTTP AND connect microservice transports simultaneously
const app = await NestFactory.create(AppModule);
app.connectMicroservice({ transport: Transport.RMQ, options: {...} });
await app.startAllMicroservices();
await app.listen(3000);   // HTTP too
```

## トランスポート選択の重要性

```text
TCP   → simple direct service-to-service
Redis/NATS → lightweight pub/sub messaging
RabbitMQ/Kafka → robust message queues/streams (durability, retries, decoupling)
gRPC  → high-performance, strongly-typed RPC (protobuf)
→ Async message brokers (RMQ/Kafka) give decoupling & resilience; gRPC gives speed+typing.
```

## なぜ重要なのか

NestJSの組み込みマイクロサービスサポートが重要なのは、HTTPをメッセージベーストランスポートに置き換えながら、同じ親しみやすいNestJS構造（モジュール、プロバイダー、DI、デコレーター）を使用して分散システムを構築できるからです — これは生産性と一貫性の大きな利点です。

それを理解することは、スケーラブルなシステムを設計するために重要です：**メッセージパターン（リクエスト-レスポンス）対イベントパターン（ファイア・アンド・フォーゲット）の違い**は、マイクロサービスの根本的な通信選択に直接マッピングされます — 同期的なRPCスタイルの呼び出しと比較して、非同期で疎結合なイベント（後者はメッセージブローカー経由で提供され、マイクロサービスをロバストにする弾力性と疎結合を提供します）。

マイクロサービスの作成方法、メッセージ/イベントハンドラーの定義方法、`ClientProxy`経由での他のサービスの呼び出し方法、HTTP+マイクロサービスハイブリッドアプリの構築方法、トランスポートの選択方法（軽量なパブ/サブ対KafkaやRabbitMQなどの永続的なキュー対高性能gRPC）を知ることは、分散バックエンドを設計するための価値のあるシニアレベルの知識です。

マイクロサービスは実際の複雑さを増す（モノリスより常に適切であるとは限らない）一方で、NestJSは実装をクリーンで一貫性のあるものにするため、これは大規模で分散されたNestJSシステムを構築するための重要なアーキテクチャトピックです。