fullstack.org.ua

TCP-транспорт у NestJS · fullstack.org.ua

Початковий12 хв· Fullstack Team

TCP-транспорт у NestJS

Налаштуєте TCP-транспорт для обміну повідомленнями між NestJS-сервісами.

Що таке TCP-транспорт у NestJS

NestJS підтримує мікросервісну архітектуру. Окремі NestJS-застосунки можуть обмінюватися повідомленнями через різні транспорти, зокрема через TCP.

TCP-транспорт підходить для обміну повідомленнями між сервісами, які працюють:

на одному комп’ютері;
у різних контейнерах;
на різних серверах у локальній мережі або хмарній інфраструктурі.

На відміну від HTTP, TCP-транспорт у NestJS використовує шаблони повідомлень:

клієнт надсилає повідомлення з певним шаблоном;
сервер знаходить обробник із таким самим шаблоном;
сервер повертає результат клієнту.

Встановлення залежностей

Для роботи з мікросервісами встановіть пакет @nestjs/microservices у кожному застосунку, який бере участь в обміні повідомленнями:

bash

npm install @nestjs/microservices

typescript

import { NestFactory } from '@nestjs/core';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
    AppModule,
    {
      transport: Transport.TCP,
      options: {
        host: '127.0.0.1',
        port: 8877,
      },
    },
  );

  await app.listen();
}

bootstrap();

typescript

import { Controller } from '@nestjs/common';
import { MessagePattern } from '@nestjs/microservices';

@Controller()
export class AppController {
  @MessagePattern({ cmd: 'sum' })
  calculateSum(numbers: number[]): number {
    return numbers.reduce((total, number) => total + number, 0);
  }
}

typescript

import { Module } from '@nestjs/common';
import { ClientsModule, Transport } from '@nestjs/microservices';
import { AppController } from './app.controller';

@Module({
  imports: [
    ClientsModule.register([
      {
        name: 'CALCULATION_SERVICE',
        transport: Transport.TCP,
        options: {
          host: '127.0.0.1',
          port: 8877,
        },
      },
    ]),
  ],
  controllers: [AppController],
})
export class AppModule {}

typescript

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

@Controller()
export class AppController {
  constructor(
    @Inject('CALCULATION_SERVICE')
    private readonly calculationClient: ClientProxy,
  ) {}

  @Get('sum')
  async getSum(): Promise<number> {
    const result = await firstValueFrom(
      this.calculationClient.send<number>(
        { cmd: 'sum' },
        [10, 20, 30],
      ),
    );

    return result;
  }
}

typescript

import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);

  await app.listen(3000);
}

bootstrap();

typescript

import { Controller } from '@nestjs/common';
import { EventPattern } from '@nestjs/microservices';

@Controller()
export class AppController {
  @EventPattern('order.created')
  handleOrderCreated(order: { id: number }): void {
    console.log(`Створено замовлення ${order.id}`);
  }
}

typescript

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

@Controller()
export class AppController {
  constructor(
    @Inject('CALCULATION_SERVICE')
    private readonly calculationClient: ClientProxy,
  ) {}

  @Get('sum')
  async getSum(): Promise<number> {
    try {
      return await firstValueFrom(
        this.calculationClient.send<number>(
          { cmd: 'sum' },
          [10, 20, 30],
        ),
      );
    } catch {
      throw new ServiceUnavailableException(
        'Сервіс обчислень недоступний',
      );
    }
  }
}