Bull/NestJS在Heroku上无法处理任务（本地连接也异常）

问题描述 #

使用NestJS搭配Bull处理队列任务，任务由定时Cron和服务端GET请求手动触发添加。本地Docker开发环境下队列运行完全正常，但本地NestJS连接Heroku上的Redis实例时，仅能处理部分任务；将项目部署到Heroku后，队列完全无法处理任何任务。已尝试使用REDIS_TLS_URL配置，问题依旧。

当前配置代码：

BullModule.forRootAsync({
  imports: [ConfigModule],
  inject: [ConfigService],
  async useFactory(configService: ConfigService) {
    return {
      redis: getRedisConfiguration(configService),
    };
  },
}),

export const getRedisConfiguration = (configService: ConfigService) => {
  const redisUrl = configService.get('REDIS_URL');

  if (redisUrl) {
    const parsedUrl = new URL(redisUrl);

    return {
      host: parsedUrl.hostname,
      password: parsedUrl.password,
      port: Number(parsedUrl.port),
    };
  }

  return {
    host: configService.get<string>('REDIS_HOST'),
    port: Number(configService.get<string>('REDIS_PORT')),
  };
};

解决方案 #

1. 强制开启Redis TLS连接配置 #

Heroku Redis实例要求强制使用TLS连接，原配置未启用TLS选项是核心问题之一。修改getRedisConfiguration函数，添加TLS相关配置：

export const getRedisConfiguration = (configService: ConfigService) => {
  const redisUrl = configService.get('REDIS_URL');

  if (redisUrl) {
    const parsedUrl = new URL(redisUrl);
    return {
      host: parsedUrl.hostname,
      password: parsedUrl.password,
      port: Number(parsedUrl.port),
      tls: {
        rejectUnauthorized: false // 适配Heroku Redis的证书验证逻辑
      }
    };
  }

  return {
    host: configService.get<string>('REDIS_HOST'),
    port: Number(configService.get<string>('REDIS_PORT')),
  };
};

2. 直接使用Redis URL自动解析，避免手动解析错误 #

Bull支持直接传入完整的Redis URL，无需手动解析参数，可减少配置错误：

BullModule.forRootAsync({
  imports: [ConfigModule],
  inject: [ConfigService],
  async useFactory(configService: ConfigService) {
    const redisUrl = configService.get('REDIS_URL');
    return {
      redis: redisUrl ? { url: redisUrl, tls: { rejectUnauthorized: false } } : {
        host: configService.get<string>('REDIS_HOST'),
        port: Number(configService.get<string>('REDIS_PORT')),
      },
    };
  },
}),

3. 优化Redis连接池与超时配置 #

Heroku Redis有连接数和超时限制，添加相关配置避免连接耗尽或超时：

redis: {
  url: redisUrl,
  tls: { rejectUnauthorized: false },
  maxRetriesPerRequest: 3, // 增加重试次数
  connectTimeout: 5000, // 设置连接超时
  enableReadyCheck: true, // 启用就绪检查
  maxClients: 10, // 根据Heroku Redis限额调整连接池大小
}

4. 开启日志排查具体错误 #

在Bull配置中开启日志，便于定位连接或任务处理失败的原因：

BullModule.forRootAsync({
  imports: [ConfigModule],
  inject: [ConfigService],
  async useFactory(configService: ConfigService) {
    return {
      redis: getRedisConfiguration(configService),
      logger: true, // 开启Bull日志输出
    };
  },
}),

部署到Heroku后，通过命令heroku logs --tail实时查看日志，确认是否存在Redis连接超时、认证失败等具体错误。

5. 确认队列处理器注册正确性 #

确保队列处理器通过@Processor()装饰器正确标记，且对应模块中已注册队列：

// 处理器示例
@Processor('your-queue-name')
export class YourQueueProcessor {
  @Process('your-job-name')
  handleJob(job: Job) {
    // 任务处理逻辑
  }
}

在模块中注册队列：

@Module({
  imports: [BullModule.registerQueue({ name: 'your-queue-name' })],
  providers: [YourQueueProcessor],
})
export class YourModule {}

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