NestJs无法解析依赖：集成bullmq时的队列注入错误排查

问题根源 #

你遇到的错误核心是CustomerSubscriptionPaymentsService依赖的BullQueue_invoice队列在当前模块上下文不可用，同时存在两个额外问题：

• AppModule中重复声明了CustomerSubscriptionPaymentsService，导致Nest尝试在AppModule上下文实例化该服务，但AppModule未导入包含队列的模块
• InvoiceModule未将队列处理器InvoiceProcessor注册为提供者，处理器无法正常工作

修复步骤 #

1. 清理AppModule的重复服务声明 #

CustomerSubscriptionPaymentsService已经在CustomerSubscriptionPaymentsModule中定义并导出，无需在AppModule中重复提供。同时导入InvoiceModule确保队列配置能被正确加载：

修改app.module.ts：

import { Module } from '@nestjs/common';
import { BullModule } from '@nestjs/bullmq';
import { AppController } from './app.controller';
import { CustomerSubscriptionPaymentsModule } from '../customerSubscriptionPayments/customerSubscriptionPayments.module';
import { InvoiceModule } from '../invoice/invoice.module';

@Module({
  imports: [
    BullModule.forRoot({
      connection: {
        host: 'localhost',
        port: 6379,
      },
    }),
    CustomerSubscriptionPaymentsModule,
    InvoiceModule,
  ],
  controllers: [AppController],
})
export class AppModule {}

2. 让CustomerSubscriptionPaymentsModule访问Invoice队列 #

通过导入InvoiceModule，让CustomerSubscriptionPaymentsModule能访问到其中注册的invoice队列：

修改customerSubscriptionPayments.module.ts：

import { Module } from '@nestjs/common';
import { CustomerSubscriptionPaymentsController } from './customerSubscriptionPayments.controller';
import { CustomerSubscriptionPaymentsRepo } from './customerSubscriptionPayments.repo';
import { CustomerSubscriptionPaymentsService } from './customerSubscriptionPayments.service';
import { InvoiceModule } from '../invoice/invoice.module';

@Module({
  imports: [InvoiceModule],
  controllers: [CustomerSubscriptionPaymentsController],
  providers: [
    CustomerSubscriptionPaymentsService,
    CustomerSubscriptionPaymentsRepo,
  ],
  exports: [
    CustomerSubscriptionPaymentsService,
    CustomerSubscriptionPaymentsRepo,
  ],
})
export class CustomerSubscriptionPaymentsModule {}

3. 注册Invoice处理器 #

将InvoiceProcessor添加到InvoiceModule的提供者列表中，确保Nest能识别并启动队列处理器：

修改invoice.module.ts：

import { Module } from '@nestjs/common';
import { BullModule } from '@nestjs/bullmq';
import { InvoiceController } from './invoice.controller';
import { InvoiceService } from './invoice.service';
import { InvoiceRepo } from './invoice.repo';
import { RedisQueues } from 'src/constants';
import { InvoiceProcessor } from './invoice.processor';

@Module({
  imports: [
    BullModule.registerQueue({
      name: 'invoice',
    }),
  ],
  controllers: [InvoiceController],
  providers: [InvoiceService, InvoiceRepo, InvoiceProcessor],
  exports: [InvoiceService, InvoiceRepo],
})
export class InvoiceModule {}

额外说明 #

• 模块间共享队列时，推荐将队列注册在对应业务模块（如这里的InvoiceModule），其他需要使用队列的模块通过导入该模块来获取队列实例
• 避免在根模块或无关模块重复注册相同队列，防止出现实例冲突

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