NestJS中Bull处理器极少处理队列任务 报job stalled错误如何修复？

问题原因分析 #

job stalled more than allowable limit 错误本质是Bull检测到任务被标记为「处理中」后，超过锁有效期仍未更新执行状态，达到最大重试次数后触发的报错，你的代码核心问题有以下几点：

1. 队列实例未正确导出：你在QueueApiModule中注册了order-queue队列，但exports数组仅导出了OrderQueue服务，没有导出BullModule，导致导入QueueApiModule的OrderModule无法获取队列实例，OrderProcessor没法正确绑定到队列，任务派发后找不到处理器，一直占用锁就会变为stalled任务。
2. 缺少队列超时配置：你没有配置Bull的锁时长和stalled重试参数，默认lockDuration仅30秒，maxStalledCount默认仅1次，只要任务超过30秒没返回就会直接触发报错。
3. 不合理的重试配置：你将attempts设为Number.MAX_SAFE_INTEGER会导致失败任务无限重试，大量占用队列资源，反而加剧任务堆积和stalled问题。
4. 不必要的依赖注入：OrderProcessor中注入了OrderQueue，虽然不是直接报错原因，但无特殊需求的话会引入额外的依赖风险，甚至可能触发循环依赖。

修复方案 #

1. 修改queue-api.module.ts配置

// queue-api.module.ts
@Module({
  imports: [
    BullModule.registerQueue(
      {
        name: 'order-queue',
        // 新增队列锁和stalled配置，根据你的任务实际执行时长调整
        lockDuration: 60000, // 单任务锁时长改为60秒
        maxStalledCount: 3, // 最多允许3次stalled重试
        defaultJobOptions: {
          backoff: 10000,
          attempts: 5, // 改为业务合理的重试次数，不要用无限重试
          removeOnComplete: true, // 可选：执行完成自动删除任务节省Redis空间
          removeOnFail: 100, // 可选：失败任务最多保留100条方便排查
        },
      },
    ),
    ...
  ],
  providers: [OrderQueue],
  // 导出BullModule，让其他导入该模块的服务能获取队列实例
  exports: [OrderQueue, BullModule],
})
export class QueueApiModule {}

2. 简化OrderProcessor的依赖注入

// order-processor.ts
@Processor('order-queue')
export class OrderProcessor {
  @Process('send-submit-mail')
  async onProcessSubmitMail(job: Job<SendSubmitMailDto>): Promise<void> {
    console.log(`Processing of job ${job.id}`)
    // 注意：处理逻辑中的所有异步操作必须加await，避免函数提前返回
  }
}

额外排查点 #

如果修改后仍有问题，检查是否有多个应用实例连接同一个Redis实例，且共用了order-queue队列名，如果部分实例没有部署OrderProcessor，任务被无处理器的实例抢到后也会出现stalled问题。

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