ClientsModule și ClientProxy în Microservicii NestJS în NestJS

Pachetul @nestjs/microservices oferă o abstracție completă peste protocoalele distribuite de comunicare. Prin modulul ClientsModule, aplicația configurează clienți injectabili de tip ClientProxy.

Acesta suportă două modele principale:

• Request-Response (RPC): client.send('pattern', data) – trimite un mesaj și returnează un Observable cu răspunsul așteptat de la microserviciul destinație.
• Event-driven: client.emit('event_name', data) – transmite un eveniment asincron fără a aștepta un răspuns (fire-and-forget).

import { Injectable, Inject } from '@nestjs/common';
import { ClientProxy } from '@nestjs/microservices';
import { firstValueFrom } from 'rxjs';

@Injectable()
export class BillingClientService {
  constructor(
    @Inject('BILLING_SERVICE') private readonly client: ClientProxy,
  ) {}

  async createInvoice(orderId: number) {
    // Apel RPC către microserviciul de facturare:
    return firstValueFrom(
      this.client.send({ cmd: 'generate_invoice' }, { orderId }),
    );
  }
}