NestJS BullMQ消费者未处理任务问题求助

我有两个基于BullMQ实现通信的Node.js服务，目前遇到核心问题：处理器函数完全未被调用，所有任务在队列中一直处于等待状态（已通过Bullboard确认）。我已将TestConsumer添加到AppModule的providers列表，但仍无法定位问题，甚至无法输出process函数的日志，求各位帮忙分析。

App模块代码 #

import { Module } from '@nestjs/common';
import { AppService } from './app.service';
import { BullModule, InjectQueue } from '@nestjs/bull';
import { TestConsumer } from './queue/test.consumer';
import { Queue } from 'bull';

@Module({
  imports: [
    BullModule.forRoot({
      redis: {
        host: 'localhost',
        port: 6379,
      },
    }),
    BullModule.registerQueue({
      name: 'test',
      url: 'redis://localhost:6379',
    }),
  ],
  providers: [TestConsumer, AppService],
})
export class AppModule {
  constructor(@InjectQueue('test') private testQueue: Queue) {
    this.testQueue.getJobCounts().then(console.log);
  }
}

消费者代码 #

import { OnQueueActive, Process, Processor } from '@nestjs/bull';
import { Job } from 'bull';

@Processor('test')
export class TestConsumer {
  @OnQueueActive()
  onActive(job: Job) {
    console.log(
      `Processing job ${job.id} of type ${job.name} with data ${job.data}...`,
    );
  }

  @Process()
  async process(job: Job): Promise<void> {
    console.log('Processing job');
    const jobData = job.data;
    console.log('Processing job', jobData);
  }
}

排查方向与解决方案 #

1. 依赖版本兼容性检查 #

注意@nestjs/bull早期依赖bull库而非bullmq，如果你的服务实际使用BullMQ，可能存在库不兼容的问题。执行以下命令确认依赖：

npm list bull bullmq @nestjs/bull

如果是新项目，建议直接使用@nestjs/bullmq适配BullMQ的官方包。

2. 统一Redis连接配置 #

当前BullModule.forRoot用host+port配置，而registerQueue用url，冗余配置可能引发隐式冲突。建议复用全局连接，简化队列注册：

// 修改后的registerQueue配置
BullModule.registerQueue({
  name: 'test',
  // 无需重复指定Redis，复用forRoot的全局配置
})

3. 确认消费者是否被实例化 #

在TestConsumer的构造函数中添加初始化日志，验证Nest是否正确加载了该消费者：

constructor() {
  console.log('[TestConsumer] 已完成初始化');
}

启动服务后如果未看到该日志，说明消费者未被正确注册，需检查模块导入路径或providers配置是否有误。

4. 验证任务入队逻辑 #

确保入队代码使用的队列名称是test，且入队过程无异常：

// 示例入队代码（需匹配你的服务实现）
async addTestJob(data: any) {
  try {
    const job = await this.testQueue.add(data);
    console.log('任务已入队:', job.id);
  } catch (err) {
    console.error('入队失败:', err);
  }
}

如果入队时抛出异常，任务可能并未真正进入队列。

5. 检查Redis服务状态 #

用redis-cli确认Redis服务正常运行：

redis-cli ping

若返回PONG则正常，否则需启动Redis服务或检查连接参数（如密码、端口、DB编号）。

6. 开启Bull日志排查 #

在BullModule.forRoot中启用日志，便于捕获连接或队列操作的异常：

BullModule.forRoot({
  redis: { host: 'localhost', port: 6379 },
  logger: true, // 开启基础日志
  logLevel: 'debug', // 可选，输出更详细的调试日志
})

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