Node.js中Bull队列何时锁定及锁定问题解决方案

一、Bull队列会锁定的几种情况 #

• 任务正在执行时：Worker取出任务开始处理后，Bull会自动给该任务加锁，防止多个Worker重复处理同个任务。锁有默认有效期（30秒），正常完成任务后会自动释放。
• Worker异常退出：如果Worker进程崩溃、被强制杀死，或者任务处理时抛出未捕获的异常，会导致锁没有被正常释放，这是最容易出现队列卡住的原因，你遇到的大概率是这种情况。
• 手动锁定操作：调用queue.lock()方法会手动锁定整个队列，阻止Worker获取新任务。
• 队列维护操作：执行clean()、pause()这类队列维护命令时，会触发临时锁定，不过一般操作完成后会自动解锁。

你的Redis命令返回的UUID是该任务锁的唯一标识，说明这个任务的锁一直没被释放，导致任务无法被重新处理。

二、解决方法 #

1. 手动释放异常锁 #

直接在Redis中删除对应的锁键，就能解锁任务：

DEL "bull:myqueue queue:2524:lock"

2. 配置合理的锁超时与续期 #

创建Worker时，根据任务实际耗时调整锁的有效期和自动续期时间，避免正常任务还在执行就丢锁，同时也防止异常锁长时间存在：

const Worker = require('bull').Worker;

const worker = new Worker('myqueue', async (job) => {
  // 你的任务处理逻辑
}, {
  lockDuration: 60000, // 锁有效期60秒，按任务最长耗时设置
  lockRenewTime: 15000 // 每15秒自动续期锁，默认是lockDuration的1/4
});

3. 捕获异常确保锁释放 #

在任务处理代码里加上错误捕获，保证即使任务失败，锁也能正常释放：

worker.process(async (job) => {
  try {
    // 任务处理代码
  } catch (err) {
    console.error('任务处理失败:', err);
    // 抛出错误或标记任务失败，都会自动释放锁
    throw err;
  }
});

// 监听Worker异常和退出事件，及时排查问题
worker.on('error', (err) => console.error('Worker出错:', err));
worker.on('exit', (code) => console.log('Worker退出，代码:', code));

4. 升级Redis版本 #

你用的Redis 3.0.504版本较老，可能存在和Bull锁机制兼容的问题，建议升级到Redis 4.x及以上版本，减少潜在bug。

5. 监控队列状态 #

通过Bull的API查看队列中活跃任务的锁状态，方便及时发现异常：

const Queue = require('bull');
const queue = new Queue('myqueue');

// 查看所有活跃任务的锁状态
queue.getJobs(['active']).then(jobs => {
  jobs.forEach(job => {
    console.log(`任务ID: ${job.id}, 是否锁定: ${job.locked}`);
  });
});

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