Node.js 任务队列库深度对比：Agenda、Bee-Queue、Bull、BullMQ、Kue 与 node-resque

在构建现代 Web 应用时，我们常常需要将耗时操作（如发送邮件、生成报表、处理上传文件）从主请求流程中剥离出来，交给后台任务队列异步处理。Node.js 生态中有多个成熟的任务队列库，它们都基于 Redis 或 MongoDB 等存储后端，但在 API 设计、功能特性、维护状态和适用场景上存在显著差异。本文将从实际工程角度出发，深入比较 Agenda、Bee-Queue、Bull、BullMQ、Kue 和 node-resque，帮助你做出明智的技术选型。

⚠️ 首要提醒：部分库已不再维护

在深入技术细节前，必须明确一点：Kue 已被官方标记为废弃（deprecated）。其 GitHub 仓库 README 明确写道：“Kue is no longer maintained. We recommend using Bull instead.” 因此，任何新项目都不应再选用 Kue。同样，虽然 node-resque 仍在更新，但其社区活跃度和文档完整性远不如 Bull 系列，需谨慎评估。

🗄️ 存储后端：Redis 还是 MongoDB？

任务队列库的底层存储直接影响部署架构和运维复杂度。

• Agenda 是唯一使用 MongoDB 的主流选项。如果你的应用已经重度依赖 MongoDB 且希望避免引入 Redis，Agenda 是自然选择。

// Agenda: 使用 MongoDB
const agenda = new Agenda({ db: { address: 'mongodb://127.0.0.1:27017/agenda' } });
agenda.define('send email', async (job) => {
  await sendEmail(job.attrs.data.to);
});

• Bee-Queue、Bull、BullMQ、Kue、node-resque 均基于 Redis。Redis 的高性能和原子操作使其成为任务队列的理想存储。

// Bull: 使用 Redis
const queue = new Queue('send email', { redis: { port: 6379, host: '127.0.0.1' } });
queue.process('send email', async (job) => {
  await sendEmail(job.data.to);
});

// BullMQ: 使用 Redis（新版 API）
const worker = new Worker('send email', async (job) => {
  await sendEmail(job.data.to);
}, { connection: { host: '127.0.0.1', port: 6379 } });

// Bee-Queue: 使用 Redis
const queue = new Queue('send email', { redis: { host: '127.0.0.1', port: 6379 } });
queue.process(async (job) => {
  await sendEmail(job.data.to);
});

// node-resque: 使用 Redis
const queue = new Queue({ connection: { host: '127.0.0.1', port: 6379 } });
queue.enqueue('send email', 'sendEmail', [to]);

💡 建议：除非已有 MongoDB 技术栈，否则优先选择 Redis 方案 —— 它更轻量、更快，且专为这类场景优化。

🔧 API 设计哲学：面向对象 vs 函数式 vs 声明式

不同库对“如何定义和处理任务”有截然不同的抽象方式。

Agenda：面向 Job 实例

Agenda 将任务视为可调度的对象，支持复杂的重复计划（类似 cron）。

// Agenda: 定义任务并立即或定时执行
agenda.define('delete old users', async (job) => {
  await User.remove({ lastLoginAt: { $lt: twoDaysAgo } });
});

// 每天凌晨 2 点运行
await agenda.every('2 hours', 'delete old users');
// 或立即运行一次
await agenda.now('delete old users');

Bull / BullMQ：声明式队列与处理器分离

Bull 系列强调“队列”作为核心实体，任务（Job）通过名称提交，由独立的处理器消费。

// Bull: 提交任务
const job = await queue.add('send email', { to: 'user@example.com' });

// BullMQ: 更清晰的分离
const job = await queue.add('send email', { to: 'user@example.com' });
// 处理器在另一处定义（可能在不同进程）
const worker = new Worker('send email', async (job) => { /* ... */ });

Bee-Queue：简洁的链式 API

Bee-Queue 采用更函数式的风格，任务处理逻辑直接绑定到队列实例。

// Bee-Queue: 定义处理逻辑并提交任务
const emailQueue = new Queue('email');
emailQueue.process(async (job) => {
  return sendEmail(job.data.to);
});

// 提交任务
const job = await emailQueue.createJob({ to: 'user@example.com' }).save();

node-resque：仿 Ruby Resque 的命令式风格

node-resque 的 API 较为底层，需手动管理队列、任务注册和工作进程。

// node-resque: 注册任务函数
const jobs = {
  sendEmail: {
    perform: async (to) => await sendEmail(to)
  }
};

// 提交任务
await queue.enqueue('default', 'sendEmail', ['user@example.com']);

// 启动工作进程
const worker = new Worker({ connection: {}, queues: ['default'] }, jobs);
worker.start();

💡 建议：BullMQ 的 API 最符合现代工程实践 —— 清晰分离生产者与消费者，类型安全更好，适合大型项目。

⏱️ 任务调度与重试机制

可靠的任务队列必须处理失败重试和延迟执行。

延迟任务（Delayed Jobs）

// Agenda: 内置延迟支持
await agenda.schedule('in 10 minutes', 'send email', { to: 'user@example.com' });

// Bull: 通过 delay 选项
await queue.add('send email', { to: 'user@example.com' }, { delay: 10 * 60 * 1000 });

// BullMQ: 同 Bull
await queue.add('send email', { to: 'user@example.com' }, { delay: 600000 });

// Bee-Queue: 通过 delay() 方法
await emailQueue.createJob({ to: 'user@example.com' }).delay(600000).save();

// node-resque: 不直接支持延迟任务，需自行实现

重试策略（Retry Strategies）

// Bull: 内置重试，支持 backoff
await queue.add('send email', data, {
  attempts: 3,
  backoff: { type: 'exponential', delay: 1000 }
});

// BullMQ: 更强大的重试配置
await queue.add('send email', data, {
  attempts: 5,
  backoff: { type: 'custom', delay: (attemptsMade) => Math.pow(2, attemptsMade) * 1000 }
});

// Bee-Queue: 通过 retries 选项
await emailQueue.createJob(data).retries(3).save();

// Agenda: 通过 fail event 手动重试
agenda.on('fail', async (err, job) => {
  if (job.attrs.failures < 3) {
    await job.repeatEvery('5 minutes').save();
  }
});

💡 建议：BullMQ 提供最灵活的重试和退避策略，适合对可靠性要求高的场景。

📊 监控与可观测性

生产环境必须能监控队列状态、任务积压和失败率。

• Bull / BullMQ 提供内置的 Web UI（通过 bull-board 或 @bull-board/ui），可实时查看队列、任务状态、重试情况。
• Agenda 无官方 UI，但可通过查询 MongoDB 监控任务。
• Bee-Queue 和 node-resque 需自行实现监控逻辑，或依赖 Redis 监控工具。

// BullMQ + bull-board 示例
import { createBullBoard } from '@bull-board/api';
import { BullMQAdapter } from '@bull-board/api/bullMQAdapter';
import { ExpressAdapter } from '@bull-board/express';

const serverAdapter = new ExpressAdapter();
createBullBoard({
  queues: [new BullMQAdapter(myQueue)],
  serverAdapter
});
app.use('/admin/queues', serverAdapter.getRouter());

💡 建议：若需开箱即用的监控能力，BullMQ 是最佳选择。

🔄 迁移路径与未来演进

• BullMQ 是 Bull 的现代化继任者，使用 TypeScript 重写，修复了 Bull 的许多设计缺陷（如内存泄漏、类型不安全）。官方推荐新项目直接使用 BullMQ。
• Agenda 仍在维护，但更新较慢，适合 MongoDB 技术栈项目。
• Bee-Queue 轻量简洁，适合小型项目或对依赖大小敏感的场景。
• node-resque 适合已有 Ruby Resque 经验的团队，但学习曲线较陡。
• Kue 已废弃，切勿用于新项目。

📌 总结：如何选择？

最终，任务队列库的选择应基于你的技术栈现状、团队熟悉度和长期维护成本。对于绝大多数新项目，BullMQ 是最平衡、最面向未来的选择。