Hybrid application (application lai) — Tài liệu NestJS tiếng Việt

Hybrid application là application lắng nghe request từ hai hoặc nhiều nguồn khác nhau. Điều này có thể kết hợp một HTTP server với một microservice listener, hoặc thậm chí chỉ là nhiều microservice listener khác nhau. Phương thức createMicroservice mặc định không hỗ trợ nhiều server, nên trong trường hợp này mỗi microservice phải được tạo và khởi động thủ công. Để làm điều đó, instance INestApplication có thể được kết nối với các instance INestMicroservice thông qua phương thức connectMicroservice().

const app = await NestFactory.create(AppModule);
const microservice = app.connectMicroservice<MicroserviceOptions>({
  transport: Transport.TCP,
});

await app.startAllMicroservices();
await app.listen(3001);

Gợi ý phương thức app.listen(port) khởi động một HTTP server tại địa chỉ được chỉ định. Nếu application của bạn không xử lý HTTP request thì nên dùng phương thức app.init() thay thế.

Chú ý Thứ tự các lời gọi này rất quan trọng. Với await app.startAllMicroservices() được gọi trước (như trên), các microservice bắt đầu tiêu thụ message trước khi các lifecycle hook của application (như onModuleInit và onApplicationBootstrap) hoàn tất. Hãy gọi app.listen() (hoặc app.init()) trước startAllMicroservices() nếu handler của bạn không được phép nhận message cho đến khi mọi module đã khởi tạo xong hoàn toàn.

Ghi chú người dịch Đây là cạm bẫy thực tế hay gặp: nếu handler message của microservice phụ thuộc vào một provider được setup trong onModuleInit (ví dụ kết nối DB), mà startAllMicroservices() chạy trước, message đến sớm có thể bị xử lý khi provider đó chưa sẵn sàng, gây lỗi khó tái hiện lúc chạy thử nhưng dễ gặp khi traffic thật đến ngay sau khi app khởi động.

Để kết nối nhiều instance microservice, gọi connectMicroservice() cho từng microservice:

const app = await NestFactory.create(AppModule);
// microservice #1
const microserviceTcp = app.connectMicroservice<MicroserviceOptions>({
  transport: Transport.TCP,
  options: {
    port: 3001,
  },
});
// microservice #2
const microserviceRedis = app.connectMicroservice<MicroserviceOptions>({
  transport: Transport.REDIS,
  options: {
    host: 'localhost',
    port: 6379,
  },
});

await app.startAllMicroservices();
await app.listen(3001);

Để gắn @MessagePattern() chỉ cho một transport strategy duy nhất (ví dụ: MQTT) trong một hybrid application có nhiều microservice, ta có thể truyền thêm tham số thứ hai để xác định transport. Với các strategy có sẵn, đây là một giá trị của enum Transport; còn với custom transporter, đó là symbol transportId của class server tương ứng.

@MessagePattern('time.us.*', Transport.NATS)
getDate(@Payload() data: number[], @Ctx() context: NatsContext) {
  console.log(`Subject: ${context.getSubject()}`); // ví dụ: "time.us.east"
  return new Date().toLocaleTimeString(...);
}
@MessagePattern({ cmd: 'time.us' }, Transport.TCP)
getTCPDate(@Payload() data: number[]) {
  return new Date().toLocaleTimeString(...);
}
@MessagePattern('topic.time.us', XYZServer.Transport) // XYZServer là một custom transporter
getXYZDate(@Payload() data: number[]) {
  return new Date().toLocaleTimeString(...);
}

@Bind(Payload(), Ctx())
@MessagePattern('time.us.*', Transport.NATS)
getDate(data, context) {
  console.log(`Subject: ${context.getSubject()}`); // ví dụ: "time.us.east"
  return new Date().toLocaleTimeString(...);
}
@Bind(Payload(), Ctx())
@MessagePattern({ cmd: 'time.us' }, Transport.TCP)
getTCPDate(data, context) {
  return new Date().toLocaleTimeString(...);
}

@Bind(Payload())
@MessagePattern('topic.time.us', XYZServer.Transport)
getXYZDate(data) {
  return new Date().toLocaleTimeString(...);
}

Gợi ý @Payload(), @Ctx(), Transport và NatsContext được import từ @nestjs/microservices. XYZServer.Transport ở đây là symbol transportId mà custom transporter expose ra.

Chia sẻ cấu hình

Mặc định, một hybrid application sẽ không kế thừa các global pipe, interceptor, guard và filter đã cấu hình cho application chính (dựa trên HTTP). Để kế thừa các thuộc tính cấu hình này từ application chính, đặt thuộc tính inheritAppConfig trong tham số thứ hai (một options object tùy chọn) của lời gọi connectMicroservice(), như sau:

Ghi chú người dịch Mỗi microservice được connectMicroservice() tạo ra về bản chất là một INestMicroservice riêng, có “ngữ cảnh thực thi” (execution context) và pipeline enhancer (guard/pipe/interceptor/filter) tách biệt với app HTTP chính — giống việc bạn khởi tạo hai app Express độc lập rồi chạy chung process. inheritAppConfig: true chỉ đơn giản là copy lại config global đã set trên app chính sang, không phải cơ chế tự động ngầm.

const microservice = app.connectMicroservice<MicroserviceOptions>(
  {
    transport: Transport.TCP,
  },
  { inheritAppConfig: true },
);