NestJS使用forwardRef()仍因循环依赖导致onModuleInit未执行

循环依赖确实会干扰NestJS的生命周期钩子执行顺序，导致onModuleInit被跳过或延迟触发，以下是几种可行的解决办法：

1. 替换为OnApplicationBootstrap钩子 #

OnApplicationBootstrap是在所有模块和服务都完全初始化完成后才执行的钩子，比OnModuleInit的执行时机更晚，此时循环依赖的服务已经完全实例化，不会存在未就绪的问题。

修改JobsService代码：

import { Injectable, OnApplicationBootstrap } from '@nestjs/common';

@Injectable()
export class JobsService implements OnApplicationBootstrap {
  // 构造函数保持不变

  async onApplicationBootstrap(): Promise<void> {
    try {
      console.log("Initializing JobsService...");
      const jobs: Job[] = await this.getPendingJobs();
      // 恢复待处理任务的逻辑
    } catch (err: any) {
      this.logger.error(`Error restoring pending jobs: ${err.message || err}`);
    }
  }

  // 其他方法保持不变
}

2. 使用Injector延迟获取循环依赖服务 #

如果必须使用OnModuleInit，可以通过Injector手动延迟获取依赖的服务，避免在构造函数阶段就触发循环依赖解析：

修改JobsService代码：

import { Injectable, OnModuleInit, Injector } from '@nestjs/common';

@Injectable()
export class JobsService implements OnModuleInit {
  // 先声明服务变量，不直接注入
  private serviceAppointmentsService: ServiceAppointmentsService;

  constructor(
    @InjectRepository(Job)
    private readonly jobRepo: Repository<Job>,

    @Inject(WINSTON_MODULE_PROVIDER)
    private readonly logger: Logger,

    private readonly schedulerRegistry: SchedulerRegistry,

    private readonly injector: Injector, // 注入Injector
  ) {}

  async onModuleInit(): Promise<void> {
    // 在钩子中延迟获取服务
    this.serviceAppointmentsService = this.injector.get(ServiceAppointmentsService);
    
    try {
      console.log("Initializing JobsService...");
      const jobs: Job[] = await this.getPendingJobs();
      // 恢复待处理任务的逻辑
    } catch (err: any) {
      this.logger.error(`Error restoring pending jobs: ${err.message || err}`);
    }
  }

  // 其他方法保持不变
}

3. 重构代码消除循环依赖（推荐） #

循环依赖通常是代码设计上的信号，最好的解决方式是抽离公共逻辑到独立服务，打破循环：

比如创建一个SharedJobAppointmentService，把两个服务之间互相调用的逻辑移到这里：

@Injectable()
export class SharedJobAppointmentService {
  constructor(
    @InjectRepository(Job)
    private readonly jobRepo: Repository<Job>,
    // 注入其他需要的依赖
  ) {}

  // 抽离原循环调用的逻辑
  async createAppointmentWithJob(appointmentData: any) {
    // 处理创建预约和关联Job的逻辑
  }

  async getPendingJobs() {
    return this.jobRepo.find({ where: { status: 'pending' } });
  }
}

然后修改两个服务，都依赖这个新服务，不再互相依赖：

// JobsService
@Injectable()
export class JobsService implements OnModuleInit {
  constructor(
    private readonly sharedService: SharedJobAppointmentService,
    // 其他依赖
  ) {}

  async onModuleInit(): Promise<void> {
    console.log("Initializing JobsService...");
    const jobs = await this.sharedService.getPendingJobs();
    // 恢复任务逻辑
  }
}

// ServiceAppointmentsService
@Injectable()
export class ServiceAppointmentsService {
  constructor(
    private readonly sharedService: SharedJobAppointmentService,
    // 其他依赖
  ) {}

  async createAppointment() {
    await this.sharedService.createAppointmentWithJob(/* 数据 */);
  }
}

问题根源说明 #

NestJS处理循环依赖时会采用“部分实例化”的方式，先创建其中一个服务的实例，但此时另一个服务还未完全初始化，这可能导致onModuleInit钩子被跳过（NestJS认为服务未完全就绪），或者执行时依赖服务状态异常。上面的方法要么避开了这个时机，要么彻底解决了循环依赖问题。

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