如何在NestJS中为BullMQ设置maxStalledCount参数？

我有一个处理最长耗时24小时任务的服务，当服务重启时，活跃任务会进入stalled状态并自动恢复。考虑到24小时内可能多次重启，需要增大默认值为1的maxStalledCount参数。该参数属于WorkerOptions，但我不清楚在NestJS中该在哪里配置：我的Worker继承自WorkerHost，它内部会创建Worker实例，但我找不到传递WorkerOptions的方式。相关代码如下：

get worker(): T {
  if (!this._worker) {
    throw new Error(
      '"Worker" has not yet been initialized. Make sure to interact with worker instances after the "onModuleInit" lifecycle hook is triggered for example, in the "onApplicationBootstrap" hook, or if "manualRegistration" is set to true make sure to call "BullRegistrar.register()"',
    );
  }
  return this._worker;
}

我已查阅NestJS队列文档和BullMQ的WorkerOptions文档，但未找到相关配置方法，请问如何在NestJS的BullMQ实现中增大maxStalledCount？

可以通过以下两种方式配置maxStalledCount参数：

1. 全局队列注册时配置 #

在导入BullModule注册队列时，直接通过workerOptions字段传入自定义配置：

import { BullModule } from '@nestjs/bullmq';

@Module({
  imports: [
    BullModule.registerQueue({
      name: '你的队列名称',
      workerOptions: {
        maxStalledCount: 5, // 设置你需要的重试次数
      },
    }),
  ],
})
export class YourModule {}

2. 自定义WorkerHost类中重写配置 #

如果需要针对单个Worker做个性化配置，在继承WorkerHost的自定义类里，重写getWorkerOptions方法传入参数：

import { WorkerHost } from '@nestjs/bullmq';
import { Injectable } from '@nestjs/common';
import { Job } from 'bullmq';

@Injectable()
export class YourWorker extends WorkerHost {
  constructor() {
    super('你的队列名称');
  }

  protected getWorkerOptions() {
    return {
      maxStalledCount: 5, // 自定义stalled任务的最大恢复次数
    };
  }

  async process(job: Job<any>) {
    // 你的任务处理逻辑
  }
}

WorkerHost内部会调用这个重写后的方法获取配置，合并后创建Worker实例，以此覆盖默认的maxStalledCount值。

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