BullMQ中Worker无法拾取Job问题排查求助

• Worker未正确启动或未监听对应队列
  确认Worker实例确实完成初始化并调用了worker.run()，且队列名称和生产者端完全一致（Redis对键名大小写敏感）。检查代码示例：

  const worker = new Worker('queue-name', async job => { /* 任务处理逻辑 */ }, { connection });
  // 必须调用run()才会开始监听任务
  await worker.run();
  

  若在Express启动流程中，确保Worker的初始化代码未被异步错误阻塞（比如未处理Promise rejection导致启动失败）。

• Job被标记为延迟或队列被暂停
  检查生产者添加Job时是否误设了delay参数，或队列被调用过pause()方法。可通过Redis命令查看状态：

  # 查看延迟队列中的任务数量
  redis-cli llen bull:queue-name:delayed
  # 检查队列是否处于暂停状态
  redis-cli get bull:queue-name:paused
  

  若存在延迟任务，可等待延迟时间到期，或手动将任务移至等待队列：

  await queue.moveToWaiting(jobId);
  

• Worker并发限制设置异常
  检查Worker配置的concurrency参数，若值为0或小于1，Worker将不会拾取任何任务。默认值为1，确保配置正确：

  const worker = new Worker('queue-name', handler, {
    connection,
    concurrency: 5 // 确保该值大于0
  });
  

• Redis键前缀不一致
  生产者与Worker的BullMQ配置若使用不同prefix，会导致双方操作的Redis键不匹配。检查两端配置：

  // 生产者端
  const queue = new Queue('queue-name', {
    connection,
    prefix: 'my-bull' // 必须与Worker端一致
  });
  // Worker端
  const worker = new Worker('queue-name', handler, {
    connection,
    prefix: 'my-bull' // 保持前缀相同
  });
  

• 任务处理函数存在未捕获错误
  若Worker处理Job时抛出未捕获错误，可能导致Worker崩溃或停止拾取新任务。确保处理函数有完善的错误捕获：

  const handler = async job => {
    try {
      // 任务逻辑
    } catch (err) {
      console.error('Job处理失败:', err);
      // 根据需求标记任务失败或触发重试
      throw err; // 交由BullMQ处理重试逻辑
    }
  };
  

  同时监听Worker的failed和error事件，排查错误输出：

  worker.on('failed', (job, err) => {
    console.log(`Job ${job.id} 失败:`, err.message);
  });
  worker.on('error', err => {
    console.log('Worker错误:', err.message);
  });
  

• BullMQ版本不兼容
  确保生产者与Worker使用的BullMQ版本一致，不同版本可能存在协议差异，导致任务无法被识别。可通过命令查看版本：

  npm list bullmq
  

• ioredis特殊配置冲突
  若ioredis配置了keyPrefix，会与BullMQ的prefix叠加，导致Redis键不符合预期。示例：

  // 错误示例：ioredis的keyPrefix会与BullMQ的prefix叠加
  const connection = new IORedis({
    host: 'localhost',
    keyPrefix: 'redis-prefix:'
  });
  // 此时BullMQ生成的键为 redis-prefix:bull:queue-name:...
  

  解决方式：移除ioredis的keyPrefix，或确保生产者与Worker的ioredis配置完全一致。

• Redis残留锁定键
  若之前的Worker异常退出，Redis中可能残留锁定键，导致新Worker无法拾取任务。可手动清理：

  redis-cli keys "bull:queue-name:locks:*" | xargs redis-cli del
  

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