在Node.js中如何在JSON数组迭代内实现等待响应的串行处理？

要实现逐个处理数组元素、等待前一个完成再执行下一个的需求，核心是利用Node.js的异步控制能力，下面给你两种实用的方案：

方案一：async/await + for...of 循环（推荐） #

这是最直观易读的方式，利用async/await的特性让异步代码看起来像同步代码，for...of循环会自动等待每个异步任务完成后再进入下一次迭代。

首先，我们需要一个处理单个视频元素的异步函数（这里模拟实际处理逻辑，你可以替换成自己的业务函数）：

// 模拟处理单个视频的异步函数，实际场景中可以是转码、上传等操作
async function processVideo(videoItem) {
  console.log(`开始处理: ${videoItem.filepath}`);
  // 模拟异步操作，比如等待3秒代表处理耗时
  await new Promise(resolve => setTimeout(resolve, 3000));
  console.log(`完成处理: ${videoItem.filepath}，输出路径：${videoItem.outputpath.Video}`);
  // 这里可以返回处理结果，根据需求调整
  return `处理完成: ${videoItem.filepath}`;
}

然后，编写主函数来串行遍历你的数组：

// 你的JSON数据
const queueData = {
  "queueDetails": [
    {
      "filepath":"video1.mp4",
      "format":{"Video":"mp4"},
      "formatpath":{"Video":"http://localhost/test"},
      "outputpath":{"Video":"D:/video/filename_video1.mp4"}
    },
    {
      "filepath":"video2.mp4",
      "format":{"Video":"mp4"},
      "formatpath":{"Video":"http://localhost/test"},
      "outputpath":{"Video":"D:/video/filename_video2.mp4"}
    }
  ]
};

// 串行处理函数
async function processQueue() {
  const queue = queueData.queueDetails;
  for (const item of queue) {
    // 等待当前元素处理完成后，再处理下一个
    await processVideo(item);
  }
  console.log("所有视频处理完成！");
}

// 执行串行处理
processQueue().catch(err => console.error("处理出错:", err));

为什么这个方案有效？ #

for...of循环会在每次迭代时等待await processVideo(item)完成，只有当这个Promise被resolve后，才会进入下一次循环，完美实现逐个处理的需求。

方案二：Promise链式调用（适合低版本Node.js） #

如果你的Node.js版本不支持async/await（不过现在几乎没人用这么老的版本了），可以用数组的reduce方法手动构建Promise链：

function processVideo(videoItem) {
  return new Promise((resolve) => {
    console.log(`开始处理: ${videoItem.filepath}`);
    setTimeout(() => {
      console.log(`完成处理: ${videoItem.filepath}，输出路径：${videoItem.outputpath.Video}`);
      resolve(`处理完成: ${videoItem.filepath}`);
    }, 3000);
  });
}

const queue = queueData.queueDetails;

// 用reduce构建Promise链
queue.reduce((prevPromise, currentItem) => {
  return prevPromise.then(() => processVideo(currentItem));
}, Promise.resolve()) // 初始Promise，启动链式调用
.then(() => console.log("所有视频处理完成！"))
.catch(err => console.error("处理出错:", err));

原理说明 #

reduce会把前一个Promise的then结果作为下一个Promise的起点，确保每个processVideo都在前一个完成后才执行，最终形成一个串行的任务链。

注意事项 #

• 你的实际处理函数（比如转码、上传）必须返回一个Promise，这样才能被await或者链式调用等待。
• 记得添加错误处理，用try/catch（在async函数里）或者.catch()（Promise链里）捕获处理过程中的异常，避免整个任务链中断。

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