JavaScript (Node.js) 中的任务队列：初学者完整指南

面向初学者的在线Python训练器

轻松学习Python，无需理论负担。在浏览器中直接解决带自动检查的实践任务，无需安装任何东西。

开始课程

引言：为什么需要 JavaScript 中的任务队列？

在现代 Web 开发中，应用程序经常面临无法在单个 HTTP 请求中即时完成的任务。发送电子邮件、处理图像、生成 PDF 报告或与外部 API 同步——所有这些都需要时间，如果同步执行，可能会导致服务器“挂起”。

任务队列 (Task Queues) 解决了这个问题。它们允许延迟执行资源密集型操作，并在后台异步处理它们。在本文中，我们将探讨如何使用流行的库在 Node.js 环境中创建和管理任务队列。

\n\n

1. Node.js 中队列操作的基础知识

任务队列是一种遵循 FIFO（先进先出）原则的数据结构。任务被添加到队列的末尾，并从队列的开头进行处理。在 Node.js 的上下文中，这意味着您的服务器可以快速响应用户（“任务已接受处理”），而任务本身将在稍后执行。

在 Node.js 中处理队列需要使用依赖外部存储（通常是 Redis）的专用库。我们来看看最流行的两个：

Bull — 一个基于 Redis 的现代、快速且稳定的库。
Kue — 一个较旧但仍然流行的库，带有内置的 Web 界面。

我们将重点介绍 Bull，因为它已成为新项目的事实标准。

\n\n

1.1 安装和引入 Bull

首先，安装必要的依赖项：

npm install bull ioredis

现在，让我们创建一个简单的队列：

const Queue = require('bull');\nconst myQueue = new Queue('emailQueue', {\n  redis: {\n    host: '127.0.0.1',\n    port: 6379\n  }\n});\n\n// 向队列添加任务\nmyQueue.add({\n  to: 'user@example.com',\n  subject: '欢迎邮件',\n  body: '欢迎来到我们的网站！'\n});\n\nconsole.log('任务已添加到队列');

在此示例中，我们创建了一个名为 emailQueue 的队列，并向其中添加了一个任务——发送一封电子邮件。该任务尚未执行，它只是在等待其处理程序。

\n\n

2. 处理队列中的任务

要开始执行任务，我们需要一个处理程序（consumer）。它将“监听”队列并从中取出任务来执行。

创建一个名为 worker.js 的文件：

const Queue = require('bull');\nconst emailQueue = new Queue('emailQueue', {\n  redis: { host: '127.0.0.1', port: 6379 }\n});\n\n// 处理函数\nemailQueue.process(async (job) => {\n  const { to, subject, body } = job.data;\n  console.log(`正在向 ${to} 发送邮件...`);\n  \n  // 模拟发送邮件（在实际项目中，这里会使用 nodemailer）\n  await new Promise(resolve => setTimeout(resolve, 2000));\n  \n  console.log(`邮件 "${subject}" 已发送至 ${to}`);\n  return { status: 'sent', email: to };\n});\n\nconsole.log('处理程序已启动，正在等待任务...');

运行此脚本，然后从第一个示例中添加一个任务。您将看到任务被处理。

\n\n

2.1 错误处理和重试

在实际项目中，任务可能会失败（例如，SMTP 服务器不可用）。Bull 提供了内置的重试机制：

emailQueue.add(\n  { to: 'user@example.com', subject: '重要邮件' },\n  { \n    attempts: 5,          // 尝试次数\n    backoff: { type: 'exponential', delay: 2000 } // 指数级延迟\n  }\n);\n\n// 在处理程序中可以处理失败情况\nemailQueue.on('failed', (job, err) => {\n  console.error(`任务 ${job.id} 失败：${err.message}`);\n});

\n\n