在NestJS中使用队列时，如何在独立进程中调用服务？

由于独立进程模式下无法使用NestJS的依赖注入（IoC容器），你需要手动处理服务的依赖实例化或抽离核心逻辑，以下是几种可行方案：

方案一：手动实例化服务及依赖 #

直接创建服务及其所有依赖的实例，适用于依赖较少的场景。

假设你的目标服务是MyService，依赖ConfigService，处理器代码可修改为：

import { Job } from 'bull'; 
import { Logger } from '@nestjs/common';
import { MyService } from '../modules/my/my.service';
import { ConfigService } from '@nestjs/config';

export default async function (job: Job) {
  const options = JSON.parse(job?.data['text']);  
  Logger.verbose(options.region); 

  // 手动实例化依赖（如果依赖有嵌套，需逐层创建）
  const configService = new ConfigService();
  // 若服务依赖数据库连接，需手动建立连接实例
  // const dbConn = await createDatabaseConnection(configService.get('DB_URL'));

  // 实例化目标服务并传入依赖
  const myService = new MyService(configService);

  // 调用服务函数
  await myService.handleJobTask(options);
}

方案二：抽离核心逻辑为纯函数 #

将服务中的业务逻辑抽成不依赖DI的纯函数，实现逻辑复用，同时避免实例化服务的麻烦。

第一步：在服务中抽离纯函数 #

// my.service.ts
import { Injectable } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';

@Injectable()
export class MyService {
  constructor(private configService: ConfigService) {}

  async handleJobTask(options: any) {
    // 调用抽离的纯函数，传入必要参数
    return processTask(options, this.configService.get('API_KEY'));
  }
}

// 核心业务逻辑抽离为纯函数，无DI依赖
export async function processTask(options: any, apiKey: string) {
  // 编写具体业务逻辑
  Logger.verbose(`Processing task for region: ${options.region}`);
  // 例如调用外部API、处理数据等操作
}

第二步：在处理器中直接调用纯函数 #

import { Job } from 'bull'; 
import { Logger } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
import { processTask } from '../modules/my/my.service';

export default async function (job: Job) {
  const options = JSON.parse(job?.data['text']);  
  Logger.verbose(options.region); 

  // 手动获取配置（或从job.data中直接传递必要参数）
  const configService = new ConfigService();
  const apiKey = configService.get('API_KEY');

  // 直接调用纯函数完成任务
  await processTask(options, apiKey);
}

方案三：手动初始化Nest应用上下文 #

若依赖关系复杂，可在独立进程中初始化Nest应用上下文，直接获取服务实例。注意此方式会有一定性能开销，适合复杂场景。

import { Job } from 'bull'; 
import { Logger } from '@nestjs/common';
import { NestFactory } from '@nestjs/core';
import { AppModule } from '../app.module';
import { MyService } from '../modules/my/my.service';

export default async function (job: Job) {
  const options = JSON.parse(job?.data['text']);  
  Logger.verbose(options.region); 

  // 创建Nest应用上下文（仅初始化容器，不启动HTTP服务）
  const appContext = await NestFactory.createApplicationContext(AppModule);
  
  // 获取服务实例（支持类引用或注入令牌）
  const myService = appContext.get(MyService);

  // 调用服务函数
  await myService.handleJobTask(options);

  // 关闭上下文释放资源
  await appContext.close();
}

注意事项 #

• 独立进程中需手动管理资源（如数据库连接、API客户端），使用后及时销毁避免内存泄漏
• 若依赖为单例，确保在进程中仅初始化一次
• 可将必要配置参数直接存入job.data，减少手动实例化依赖的工作量

内容的提问来源于stack exchange，提问作者code_optimizer