运行不启动 HTTP 服务器的 NestJS 调度器

Question

我正在尝试为 NestJS 创建一个“worker”，它基本上聚合来自多个数据源的数据。由于我将这个 worker 部署到 Kubernetes 集群中，我不需要启动 NestJS 内部 HTTP 服务器，但是，调度程序不会运行没有 app.listen。

main.ts:

async function bootstrap() {
  const app = await NestFactory.create(WorkerModule);
  await app.listen(3030); // <-- I would like to delete this
}

bootstrap();

worker.module.ts

@Module({
  imports: [
    ScheduleModule.forRoot(),
  ],
  providers: [
    // Scrappers
    DataScrapper,
  ],
})
export class WorkerModule {}

data.scrapper.ts

@Injectable()
export class DataScrapper {
  @Interval(1000)
  async sync() {
    console.log('fetching...');
  }
}

Answer 1

NestJS 的核心是一个模块化框架，可为 node/TS 生态系统提供强大的 DI 功能。可以通过以下三种方式之一公开顶层模块：

HTTP 服务器
A microservice
An application context 例如。自举 DI 容器

您可以通过使用自定义策略将应用程序创建为微服务来完成您想要的。我很可能会将这种模式打包为 @golevelup/nestjs 生态系统的一部分（免责声明，我是作者），因为我最近遇到这种模式的频率越来越高。

import { CustomTransportStrategy } from '@nestjs/microservices';

class KeepAliveStrategy implements CustomTransportStrategy {
  private closing = false;

  wait() {
    if (!this.closing) {
      setTimeout(this.wait, 1000);
    }
  }

  listen(callback: () => void) {
    callback();
    this.wait();
  }

  close() {
    this.closing = true;
  }
}

async function bootstrap() {
  const workerApp = await NestFactory.createMicroservice(WorkerModule, {
    strategy: KeepAliveStrategy,
  });

  await workerApp.listen(() => console.log('listening'));
}
bootstrap();

这将使您的 worker 保持活动状态并允许它正确响应 NestJS 生命周期事件

运行不启动 HTTP 服务器的 NestJS 调度器

Run NestJS scheduler without starting the HTTP server

scheduler

typescript

nestjs

运行 不启动 HTTP 服务器的 NestJS 调度器

Run NestJS scheduler without starting the HTTP server

scheduler

typescript

nestjs

运行不启动 HTTP 服务器的 NestJS 调度器