BullMQ 批量任务延迟执行技术解析

批量任务添加与延迟执行

BullMQ 是一个强大的 Node.js 消息队列库，在处理批量任务时提供了 addBulk 方法。该方法允许开发者一次性添加多个任务到队列中，提高任务添加效率。

基本批量任务添加

最基本的批量任务添加方式如下：

const name = 'jobName';
const jobs = await queue.addBulk([
  { name, data: { paint: 'car' } },
  { name, data: { paint: 'house' } },
  { name, data: { paint: 'boat' } },
]);

这种方式会立即将三个任务添加到队列中，并准备执行。

为批量任务添加延迟

在实际应用中，我们经常需要为任务设置延迟执行时间。BullMQ 通过 opts 参数支持这一功能：

const name = 'jobName';
const jobs = await queue.addBulk([
  { 
    name, 
    data: { paint: 'car' }, 
    opts: { delay: 1000 } // 延迟1秒执行
  },
  { 
    name, 
    data: { paint: 'house' }, 
    opts: { delay: 2000 } // 延迟2秒执行
  },
  { 
    name, 
    data: { paint: 'boat' }, 
    opts: { delay: 3000 } // 延迟3秒执行
  },
]);

技术细节解析

1. 延迟参数的单位：delay 参数以毫秒为单位，1000 表示1秒延迟

2. 选项继承关系：BullMQ 的选项参数采用继承结构：

   • BulkJobOptions → JobOptions → BaseJobOptions
   • delay 参数定义在 BaseJobOptions 中

3. 类型安全：使用 TypeScript 开发时，可以获得完整的类型提示和编译时检查

最佳实践建议

1. 合理设置延迟时间：根据业务需求设置适当的延迟，避免过长或过短的延迟

2. 批量任务分组：可以将具有相同延迟的任务分组处理，减少代码重复

3. 错误处理：为批量任务添加适当的错误处理机制

4. 性能考量：大量延迟任务可能会影响队列性能，需根据实际情况评估

通过这种方式，开发者可以灵活控制批量任务的执行时间，满足各种定时任务和延迟处理的需求场景。