Node.js中如何等待所有异步递归函数执行完成？

从请求体获取站点列表后，希望异步解析所有链接，待全部任务完成后再返回响应，但当前响应始终为空，核心原因是异步任务还未执行完毕，主线程就已经返回了结果。

原代码如下：

var index = 0;
let items = [];

exports.feed = async (req, res) => {
    (async () => {
        await getSiteData(req.body.sites)
    })();

    if(typeof items !== 'undefined' && items.length > 0){
        res.status(200).json(items);
    } else {
        res.status(404).json({ error: "Something went wrong", success: false });
    }
}


async function getSiteData(list){
    try{
        if(index == list.length-1){
            return items;
        }
        
        await parser.parseURL(list[index], async function(err, feed){
            if(err != null){
                console.log(err);
                return false;
            }
    
            items.push(feed.items)
            index++
            await getSiteData(list);
        });
    } catch(err){
        console.log(err);
        return false;
    }
}

错误分析 #

1. 未等待异步任务完成：feed函数中，立即执行的异步函数没有被await，导致代码直接跳到判断items的逻辑，此时getSiteData还在执行，items为空。
2. 回调式API无法被await：parser.parseURL是回调风格的函数，不会返回Promise，所以await对它无效，递归调用的getSiteData也无法被正确等待。
3. 全局变量风险：使用全局的index和items，多请求并发时会相互干扰，且递归终止条件逻辑错误（最后一个站点不会被处理）。

修复方案 #

步骤1：将回调式API包装为Promise #

把parser.parseURL转换成Promise风格，让await能正确等待异步操作：

function parseURLPromise(url) {
  return new Promise((resolve, reject) => {
    parser.parseURL(url, (err, feed) => {
      if (err) reject(err);
      else resolve(feed.items);
    });
  });
}

步骤2：重写getSiteData，避免全局变量 #

用循环替代递归，函数内部维护结果集合，逻辑更清晰且安全：

async function getSiteData(sites) {
  const items = [];
  for (const site of sites) {
    try {
      const feedItems = await parseURLPromise(site);
      items.push(feedItems);
    } catch (err) {
      console.error(`解析站点 ${site} 失败:`, err);
      // 可选择跳过错误站点，继续处理其他站点
    }
  }
  return items;
}

步骤3：修改feed函数，等待异步任务完成 #

直接await getSiteData，确保所有解析任务完成后再返回响应：

exports.feed = async (req, res) => {
  try {
    const items = await getSiteData(req.body.sites);
    if (items.length > 0) {
      res.status(200).json(items);
    } else {
      res.status(404).json({ error: "未获取到有效数据", success: false });
    }
  } catch (err) {
    console.error("处理请求失败:", err);
    res.status(500).json({ error: "服务器内部错误", success: false });
  }
}

修复说明 #

• 用Promise包装回调API，让异步操作能被await正确等待，确保所有解析任务完成后再继续执行后续逻辑。
• 移除全局变量，改用函数内部变量存储结果，避免多请求并发时的状态冲突。
• 用for...of循环替代递归，逻辑更直观，错误处理也更灵活。

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