如果你在 Node.js 项目中处理过多个异步任务比如同时查询多个数据库、并发调用多个外部 API或者批量处理一批文件你可能会发现一个痛点如果按顺序执行总耗时是所有任务耗时的总和效率太低。今天要讨论的Promise.all就是解决这个问题的核心工具。它不是一个新的概念但却是 Node.js 异步编程中提升并发性能最直接、最有效的武器之一。这篇文章不讲复杂的理论直接聚焦于如何在真实的 Node.js 项目中用Promise.all实现并行查询从而显著缩短响应时间。我们将从一个简单的串行查询示例开始逐步重构为并行模式并深入探讨Promise.all的核心特性、错误处理策略、性能边界以及在实际项目中必须注意的陷阱。无论你是刚接触异步编程还是希望优化现有代码的性能这篇文章都能提供一套可立即上手的实战方案。1. 核心能力速览在深入代码之前我们先快速了解Promise.all的核心特性和它在 Node.js 项目中的定位。能力项说明核心功能接收一个 Promise 对象数组或任何可迭代对象返回一个新的 Promise。当所有输入的 Promise 都成功完成fulfilled时它才成功并返回一个结果数组如果其中任何一个 Promise 失败rejected它会立即失败。性能提升将多个独立的异步任务从串行改为并行执行总耗时从各任务耗时之和变为最慢的那个任务的耗时是优化 I/O 密集型操作如网络请求、数据库查询的关键手段。错误处理具有“快速失败”fail-fast特性。任何一个任务失败整个Promise.all会立即拒绝并返回第一个失败的原因。适用场景批量获取互不依赖的数据如用户信息、商品详情、配置项、并发调用多个第三方 API、同时读写多个文件等。不适用场景任务之间有严格的先后依赖关系需要收集所有任务的结果无论成功失败此时应使用Promise.allSettled。环境要求Node.js 原生支持无需额外安装。它是 ES2015 (ES6) 标准的一部分在现代 Node.js 版本包括 LTS 版本中均可直接使用。简单来说Promise.all就像是一个项目经理它同时派发多个任务给下属并等待所有人完成后才进行下一步汇总。如果有人中途失败整个项目就立即宣告失败。2. 适用场景与使用边界理解Promise.all的适用场景和边界能帮助你在正确的时机使用它避免误用带来的问题。最适合的使用场景聚合独立数据源这是最经典的场景。例如一个电商商品详情页需要展示商品基本信息、库存数量、用户评论和推荐列表。这四项数据来自不同的服务或数据库表彼此没有依赖完全可以使用Promise.all并行获取。批量处理任务需要对一个列表中的每个元素执行相同的异步操作比如给一批用户发送通知邮件、对多张图片进行压缩处理、验证多个 API 令牌的有效性。这些任务相互独立并行处理能极大提升吞吐量。初始化或预加载在应用启动时需要并行加载多个配置文件、建立多个数据库连接池或预热多个缓存。使用Promise.all可以加速启动过程。需要谨慎或避免使用的场景任务间有依赖关系如果任务 B 需要任务 A 的结果作为输入那么它们不能并行。强行使用Promise.all会导致逻辑错误或数据不一致。需要容忍部分失败在某些业务场景下即使部分子任务失败我们仍然希望继续处理并收集其他成功任务的结果。例如批量查询用户信息即使个别用户查询失败也应返回其他成功查询的结果。这时Promise.all的“快速失败”特性就成了阻碍应改用Promise.allSettled。资源竞争与限流无限制地并行大量任务例如同时发起成千上万个网络请求可能会导致服务器过载、数据库连接池耗尽或被目标 API 限流。在这种情况下需要结合并发控制库如p-limit,async或使用队列来管理并行度。顺序性操作对于文件写入、数据库事务等需要严格顺序执行的操作不应使用并行。使用边界与注意事项内存消耗Promise.all会等待所有任务完成如果任务数量巨大且每个任务都返回大量数据最终的结果数组可能会消耗大量内存。对于海量任务应考虑分批次处理或使用流式处理。错误处理必须到位由于其“快速失败”的特性必须用.catch()或try...catch配合await妥善处理错误避免未捕获的 Promise 拒绝导致进程崩溃。3. 环境准备与前置条件开始实战之前确保你的开发环境已经就绪。由于Promise.all是 JavaScript 语言标准的一部分所以环境准备非常简单。Node.js 版本确保你安装了 Node.js。Promise.all在 Node.js 4.0.0 及以上版本就已得到稳定支持。建议使用最新的 LTS长期支持版本如 Node.js 18.x 或 20.x以获得最佳的性能和安全性。你可以通过以下命令检查版本node --version代码编辑器或 IDE任何你熟悉的编辑器即可如 VS Code、WebStorm、Sublime Text 等。项目初始化可选如果你是从零开始测试可以创建一个新的目录并初始化一个 Node.js 项目。mkdir promise-all-demo cd promise-all-demo npm init -y这将生成一个package.json文件。模拟异步任务的依赖可选为了更真实地模拟网络请求或数据库查询我们可以安装一个用于延迟的库比如delay或者使用 Node.js 内置的setTimeout。本文示例将使用内置方法。一个用于测试的 API 或数据源可选为了演示真实的网络请求你可以使用一个免费的公共 API如 JSONPlaceholder 来模拟后端服务。我们将用它作为示例。环境准备的核心就是 Node.js 本身。只要 Node.js 安装正确你就可以运行本文中的所有代码示例。4. 从串行到并行一个实战案例让我们通过一个具体的场景来感受Promise.all带来的性能飞跃。假设我们需要从一个公共 API 获取多个用户的信息。4.1 串行查询低效的起点首先我们看看不使用Promise.all的串行方式。我们定义一个模拟的异步函数fetchUser它接受一个用户 ID模拟一个网络请求并返回用户数据。// utils/simulateFetch.js /** * 模拟一个异步获取用户信息的函数 * param {number} userId - 用户ID * returns {Promiseobject} 用户信息 */ const fetchUser (userId) { return new Promise((resolve) { // 模拟网络延迟每个请求耗时 1 秒 setTimeout(() { resolve({ id: userId, name: User ${userId}, email: user${userId}example.com }); }, 1000); }); }; module.exports { fetchUser };现在我们串行地获取三个用户的信息// serial.js const { fetchUser } require(./utils/simulateFetch); async function fetchUsersSerial(userIds) { const results []; console.time(串行查询耗时); for (const id of userIds) { console.log(开始查询用户 ${id}...); const user await fetchUser(id); // 关键这里使用了 await会阻塞循环 results.push(user); console.log(用户 ${id} 查询完成。); } console.timeEnd(串行查询耗时); return results; } // 执行 (async () { const userIds [1, 2, 3]; const users await fetchUsersSerial(userIds); console.log(最终结果:, users); })();运行这段代码 (node serial.js)你会看到类似以下的输出开始查询用户 1... 用户 1 查询完成。 开始查询用户 2... 用户 2 查询完成。 开始查询用户 3... 用户 3 查询完成。 串行查询耗时: 3.012s 最终结果: [ { id: 1, name: User 1, email: user1example.com }, { id: 2, name: User 2, email: user2example.com }, { id: 3, name: User 3, email: user3example.com } ]关键问题总耗时约 3 秒等于三个 1 秒任务的简单相加。每个任务都必须等待前一个完成才能开始效率低下。4.2 并行查询使用 Promise.all 重构现在我们用Promise.all来改造上面的函数。核心思路是先启动所有异步任务然后再用Promise.all等待它们全部完成。// parallel.js const { fetchUser } require(./utils/simulateFetch); async function fetchUsersParallel(userIds) { console.time(并行查询耗时); // 关键步骤立即启动所有异步任务将返回的 Promise 存入数组 const userPromises userIds.map(id { console.log(启动查询用户 ${id}...); return fetchUser(id); // 注意这里没有 await直接返回 Promise }); console.log(所有查询任务已启动等待全部完成...); // 使用 Promise.all 等待所有 Promise 完成 const results await Promise.all(userPromises); console.timeEnd(并行查询耗时); return results; } // 执行 (async () { const userIds [1, 2, 3]; const users await fetchUsersParallel(userIds); console.log(最终结果:, users); })();运行这段代码 (node parallel.js)输出如下启动查询用户 1... 启动查询用户 2... 启动查询用户 3... 所有查询任务已启动等待全部完成... 并行查询耗时: 1.005s 最终结果: [ { id: 1, name: User 1, email: user1example.com }, { id: 2, name: User 2, email: user2example.com }, { id: 3, name: User 3, email: user3example.com } ]性能对比总耗时从3 秒降低到了约 1 秒三个任务几乎是同时开始的总耗时取决于最慢的那个任务这里都是 1 秒。这就是并行化的威力。4.3 代码解析与核心要点map与立即执行userIds.map(id fetchUser(id))这行代码至关重要。map函数会同步、立即地遍历数组并对每个id调用fetchUser函数。fetchUser函数被调用后会立即返回一个Promise对象并开始执行其内部的异步操作本例中的setTimeout。所以在map执行完的瞬间三个异步定时器都已经启动了。Promise.all的等待Promise.all(userPromises)接收一个包含三个进行中Promise的数组。它返回一个新的Promise。这个新的Promise会在数组中的所有Promise都成功解决resolve后才将自己标记为成功并将所有结果按原数组顺序组合成一个新数组返回。结果的顺序Promise.all返回的结果数组顺序与输入的Promise数组顺序严格一致无论各个Promise完成的先后顺序如何。这保证了数据的有序性非常方便。5. 功能测试与效果验证理解了基础用法后我们需要进行更全面的测试以确保代码的健壮性。我们将测试正常情况、错误处理情况以及使用真实网络 API 的情况。5.1 测试一基础功能与顺序保证我们修改模拟函数让每个任务的耗时不同以验证Promise.all是否真的并行执行以及结果顺序是否正确。// test-order.js const fetchUserWithRandomDelay (userId) { const delay Math.floor(Math.random() * 2000) 500; // 随机延迟 500ms 到 2500ms return new Promise((resolve) { setTimeout(() { console.log(用户 ${userId} 的请求完成耗时 ${delay}ms); resolve({ id: userId, delay }); }, delay); }); }; async function test() { const userIds [1, 2, 3, 4, 5]; console.log(启动所有查询...); const promises userIds.map(id fetchUserWithRandomDelay(id)); console.log(等待所有结果...); const results await Promise.all(promises); console.log(\n最终结果数组按输入顺序排列:); console.log(results.map(r 用户 ${r.id}: ${r.delay}ms).join(\n)); } test();运行后你可能会看到类似输出启动所有查询... 等待所有结果... 用户 3 的请求完成耗时 567ms 用户 1 的请求完成耗时 1234ms 用户 5 的请求完成耗时 1567ms 用户 2 的请求完成耗时 1890ms 用户 4 的请求完成耗时 2456ms 最终结果数组按输入顺序排列: 用户 1: 1234ms 用户 2: 1890ms 用户 3: 567ms 用户 4: 2456ms 用户 5: 1567ms验证结论并行性控制台日志显示任务完成顺序是乱序的3, 1, 5, 2, 4证明它们是同时开始的。顺序保证最终results数组的顺序依然是[1, 2, 3, 4, 5]与输入userIds的顺序一致尽管用户3最先完成。这是Promise.all的一个重要特性。5.2 测试二错误处理与“快速失败”现在我们来测试当其中一个任务失败时会发生什么。// test-error.js const { fetchUser } require(./utils/simulateFetch); const fetchUserWithError (userId) { if (userId 2) { // 模拟用户2查询失败 return new Promise((resolve, reject) { setTimeout(() reject(new Error(用户 ${userId} 不存在)), 800); }); } return fetchUser(userId); // 其他用户正常 }; async function fetchUsersWithErrorHandling(userIds) { try { const promises userIds.map(id fetchUserWithError(id)); const results await Promise.all(promises); console.log(所有查询成功:, results); return results; } catch (error) { // Promise.all 中任何一个 Promise reject都会直接跳到这里 console.error(查询过程中发生错误:, error.message); // 在实际项目中这里可能需要根据错误类型进行重试、记录日志或返回部分结果 throw error; // 或者返回一个兜底值 } } (async () { const userIds [1, 2, 3]; console.log(开始并行查询包含一个失败任务...); await fetchUsersWithErrorHandling(userIds); })();运行结果开始并行查询包含一个失败任务... 查询过程中发生错误: 用户 2 不存在关键观察快速失败用户1和用户3的查询可能已经启动但当用户2的 Promise 拒绝reject时整个Promise.all立即拒绝不会等待用户1和用户3完成。错误捕获必须使用try...catch或.catch()来捕获Promise.all可能抛出的错误否则会导致未处理的 Promise 拒绝在 Node.js 中可能触发unhandledRejection事件。结果丢失由于快速失败即使其他任务成功我们也无法获取它们的结果。如果业务上需要容忍部分失败这就是使用Promise.allSettled的信号。5.3 测试三集成真实网络请求让我们用一个真实的公共 API 来替换模拟函数体验更真实的场景。我们将使用node-fetch或axios库。这里以axios为例需先安装npm install axios。// test-real-api.js const axios require(axios); // 确保已安装 axios async function fetchPost(postId) { const url https://jsonplaceholder.typicode.com/posts/${postId}; console.log(开始请求: ${url}); // axios.get 返回一个 Promise const response await axios.get(url); return response.data; } async function fetchMultiplePosts(postIds) { console.time(获取多篇文章耗时); // 创建 Promise 数组 const postPromises postIds.map(id fetchPost(id)); try { const posts await Promise.all(postPromises); console.timeEnd(获取多篇文章耗时); console.log(成功获取 ${posts.length} 篇文章); // 简单打印标题 posts.forEach(post { console.log(- ${post.id}: ${post.title.substring(0, 30)}...); }); return posts; } catch (error) { console.error(获取文章失败:, error.message); console.timeEnd(获取多篇文章耗时); throw error; } } (async () { const postIds [1, 2, 3, 4, 5]; await fetchMultiplePosts(postIds); })();运行这段代码你将看到类似输出开始请求: https://jsonplaceholder.typicode.com/posts/1 开始请求: https://jsonplaceholder.typicode.com/posts/2 开始请求: https://jsonplaceholder.typicode.com/posts/3 开始请求: https://jsonplaceholder.typicode.com/posts/4 开始请求: https://jsonplaceholder.typicode.com/posts/5 获取多篇文章耗时: 623.456ms 成功获取 5 篇文章 - 1: sunt aut facere repellat provident... - 2: qui est esse... - 3: ea molestias quasi exercitationem... - 4: eum et est occaecati... - 5: nesciunt quas odio...这个例子清晰地展示了在真实的网络 I/O 场景下Promise.all如何将多个 HTTP 请求并行化从而大幅减少总耗时。6. 接口 API 与批量任务实战在实际的 Node.js 后端服务中Promise.all经常被用在控制器Controller或服务层Service中用于聚合数据。下面我们构建一个简单的 Express 服务来演示。6.1 构建一个聚合数据的 API 接口假设我们有一个用户详情接口需要从三个不同的微服务获取数据用户基本信息、用户订单列表、用户积分。// server.js const express require(express); const axios require(axios); // 模拟调用外部服务 const app express(); const PORT 3000; // 模拟的三个微服务函数 const getUserInfo async (userId) { await new Promise(resolve setTimeout(resolve, 100)); // 模拟延迟 return { userId, name: 用户${userId}, age: 20 userId }; }; const getUserOrders async (userId) { await new Promise(resolve setTimeout(resolve, 150)); return { userId, orders: [订单${userId}A, 订单${userId}B] }; }; const getUserPoints async (userId) { await new Promise(resolve setTimeout(resolve, 200)); return { userId, points: 100 * userId }; }; // 传统的串行接口 app.get(/api/user/:id/serial, async (req, res) { const userId parseInt(req.params.id); console.time(串行查询用户${userId}); try { const info await getUserInfo(userId); const orders await getUserOrders(userId); const points await getUserPoints(userId); console.timeEnd(串行查询用户${userId}); res.json({ success: true, data: { info, orders, points } }); } catch (error) { res.status(500).json({ success: false, message: error.message }); } }); // 使用 Promise.all 的并行接口 app.get(/api/user/:id/parallel, async (req, res) { const userId parseInt(req.params.id); console.time(并行查询用户${userId}); try { // 关键并行发起三个请求 const [info, orders, points] await Promise.all([ getUserInfo(userId), getUserOrders(userId), getUserPoints(userId) ]); console.timeEnd(并行查询用户${userId}); res.json({ success: true, data: { info, orders, points } }); } catch (error) { console.timeEnd(并行查询用户${userId}); res.status(500).json({ success: false, message: error.message }); } }); app.listen(PORT, () { console.log(服务运行在 http://localhost:${PORT}); console.log(测试串行接口: GET /api/user/1/serial); console.log(测试并行接口: GET /api/user/1/parallel); });启动服务 (node server.js)然后分别用浏览器或curl命令访问两个接口。你会发现/parallel接口的响应速度明显快于/serial接口因为三个模拟的微服务调用是同时进行的。6.2 处理批量任务队列当需要处理的任务数量非常大时直接使用Promise.all可能会引发问题如内存溢出、连接数超限。常见的解决方案是进行“分页”或“分批次”处理。// batch-process.js /** * 批量处理函数控制并发数 * param {Array} items - 要处理的项目数组 * param {Function} processor - 处理每个项目的异步函数 * param {number} concurrency - 最大并发数 */ async function processInBatches(items, processor, concurrency 5) { const results []; for (let i 0; i items.length; i concurrency) { // 取出当前批次的任务 const batch items.slice(i, i concurrency); console.log(处理批次 ${i / concurrency 1}:, batch); // 使用 Promise.all 并行处理当前批次 const batchPromises batch.map(item processor(item)); const batchResults await Promise.all(batchPromises); results.push(...batchResults); // 可选批次间添加微小延迟避免对下游服务造成冲击 // await new Promise(resolve setTimeout(resolve, 100)); } return results; } // 模拟一个处理单个项目的异步任务 const mockProcessor async (item) { const delay Math.random() * 500; await new Promise(resolve setTimeout(resolve, delay)); console.log(已处理: ${item}); return 结果_${item}; }; // 测试 (async () { const largeArray Array.from({ length: 23 }, (_, i) 任务-${i 1}); console.log(开始处理 ${largeArray.length} 个任务并发数 5); console.time(批量处理总耗时); const allResults await processInBatches(largeArray, mockProcessor, 5); console.timeEnd(批量处理总耗时); console.log(处理完成共 ${allResults.length} 个结果); })();这个模式结合了Promise.all的并行能力和循环的分批控制是处理大规模异步任务的实用策略。7. 资源占用与性能观察虽然Promise.all本身不直接消耗大量 CPU 或内存但它管理的并发异步任务会。在 Node.js 中性能观察主要集中在事件循环、内存和外部资源如 HTTP 连接、数据库连接上。事件循环Event LoopPromise.all启动的异步任务如定时器、网络 I/O、文件 I/O会被交给 Node.js 底层的线程池或系统内核执行不会阻塞主线程。主线程在发出这些任务后就可以继续处理其他事情直到Promise.all等待的结果返回。这充分利用了 Node.js 非阻塞 I/O 的优势。内存占用Promise.all会保留所有任务的结果直到全部完成。如果每个任务返回的数据量都很大例如大文件内容或庞大的 JSON 对象并且任务数量很多那么最终的结果数组可能会消耗大量内存。对于这种情况需要考虑流式处理Stream或分批次处理而不是一次性处理所有任务。外部资源限制HTTP 连接数浏览器和 Node.js 都对同一域名的并发 HTTP 连接数有限制。无限制地使用Promise.all发起大量请求可能会被目标服务器拒绝或限流。数据库连接池如果并行任务都是数据库查询可能会迅速耗尽数据库连接池导致新的查询等待或失败。文件描述符大量并行文件操作可能耗尽系统的文件描述符。性能观察建议对于 CPU 密集型任务并行化带来的收益有限因为 Node.js 是单线程的。真正的并行需要依靠 Worker Threads 或子进程。对于 I/O 密集型任务网络、磁盘Promise.all能显著提升性能。使用 Node.js 内置的process.memoryUsage()或console.time()/console.timeEnd()来监控内存和耗时。在生产环境中使用 APM应用性能监控工具来观察接口的响应时间和并发请求数。8. 常见问题与排查方法在使用Promise.all时你可能会遇到一些典型问题。下表列出了常见现象、原因和解决方案。问题现象可能原因排查方式解决方案接口超时或无响应并发任务过多导致数据库连接池耗尽、外部 API 限流或服务器资源不足。观察服务器监控CPU、内存、连接数、日志中是否有大量错误如ECONNRESET,ETIMEDOUT。实施并发控制使用p-limit、async库的parallelLimit或如第6.2节所示的分批处理。内存使用量飙升一次性使用Promise.all处理海量任务所有结果同时保存在内存中。使用process.memoryUsage()监控内存观察任务数量和每个任务返回数据的大小。改用流式处理或分批次处理每批处理完后及时释放资源。错误被“吞掉”程序静默失败没有对Promise.all进行错误捕获.catch或try...catch。检查代码中是否对await Promise.all(...)或Promise.all(...).then()进行了错误处理。务必添加错误处理逻辑。可以使用Promise.allSettled来收集所有任务的结果和错误状态。“快速失败”导致部分成功数据丢失业务逻辑需要容忍部分失败但使用了Promise.all。分析业务需求是否需要所有任务都成功是否允许部分失败并继续处理改用Promise.allSettled它会等待所有 Promise 完成并返回一个包含状态fulfilled/rejected和结果/原因的对象数组。结果顺序不符合预期误以为Promise.all的结果顺序与任务完成顺序一致。回顾Promise.all的规范它按输入 Promise 的顺序输出结果。这是正常行为。如果需要对结果按完成时间或其他规则排序需要在Promise.all完成后手动处理结果数组。任务根本没有并行执行在创建 Promise 数组时错误地使用了await导致任务串行启动。检查map函数内的调用。应该是tasks.map(task asyncFunction(task))而不是tasks.map(async task await asyncFunction(task))。后者虽然可能并行但await在map的回调中会导致微妙的问题。最安全的做法是在回调中只调用函数不await。确保传递给Promise.all的是 Promise 对象数组而不是已经 resolve 的值。正确示例const promises list.map(item doAsyncWork(item));9. 最佳实践与使用建议根据前面的分析和实战总结出以下在 Node.js 项目中使用Promise.all的最佳实践始终进行错误处理这是最重要的原则。使用try...catch包裹await Promise.all(...)或为Promise.all(...).then()链式调用添加.catch()。评估任务独立性使用前明确确认要并行的任务之间没有数据依赖。如果任务 B 需要任务 A 的输出则不能使用Promise.all。控制并发量对于数量不确定或可能很大的任务列表不要直接Promise.all(list.map(...))。实现一个带有并发限制的批处理函数如第6.2节所示或使用可靠的第三方库如p-limit。考虑使用Promise.allSettled当你的业务逻辑需要知道每个任务的成功与否而不是“一票否决”时Promise.allSettled是更好的选择。它返回一个对象数组描述每个 Promise 的最终状态。const results await Promise.allSettled(promises); const successful results.filter(r r.status fulfilled).map(r r.value); const errors results.filter(r r.status rejected).map(r r.reason);注意内存和资源对于返回大数据量的任务要有内存意识。分批处理是避免内存问题的有效手段。与async/await优雅结合使用数组解构可以让代码更清晰。// 清晰明了 const [user, orders, logs] await Promise.all([ fetchUser(id), fetchOrders(id), fetchLogs(id) ]);用于初始化在应用启动时并行初始化多个模块如连接数据库、加载配置、预热缓存可以加快启动速度。编写可测试的代码将使用Promise.all的逻辑封装到独立的函数或类方法中便于编写单元测试。你可以通过模拟Mock单个的异步函数来测试并发逻辑和错误处理。10. 总结与下一步Promise.all是 Node.js 异步编程工具箱中一把锋利且实用的“瑞士军刀”。它通过将独立的异步任务并行化能够直接将 I/O 密集型操作的耗时降至单个最慢任务的耗时对于提升后端接口性能和用户体验有立竿见影的效果。最值得尝试的点立即检查你项目中的那些顺序执行的、独立的异步调用比如循环里的await看看是否能用Promise.all进行改造。一个简单的改动可能带来数倍的性能提升。最先应该验证的功能从一个简单的、模拟网络延迟的例子开始对比串行和并行的耗时差异直观感受其威力。然后将其应用到你的一个真实业务接口中例如聚合用户信息的接口。最容易踩的坑忘记错误处理导致进程崩溃。误用于有依赖关系的任务引发逻辑错误。无限制并发压垮自身或下游服务。后续扩展方向深入学习其他 Promise 并发方法掌握Promise.race()竞赛取第一个完成的结果、Promise.any()取第一个成功的结果、Promise.allSettled()等待所有任务结束无论成功失败。它们适用于不同的并发场景。探索更高级的并发控制模式学习使用async库的parallelLimit、queue或者p-limit、bottleneck等库以应对更复杂的流量控制和资源管理需求。结合现代 JavaScript 特性例如使用for...of循环与await在异步迭代器中实现复杂的控制流或者利用AbortController与Promise.all结合来实现任务的超时取消。将Promise.all加入到你的开发习惯中它将成为你构建高性能 Node.js 应用不可或缺的基础能力。建议将本文中的示例代码保存下来作为日后的参考模板。
