Node.js中父Promise内嵌入子Promise的实现问题

嘿，别担心，新手刚开始接触Promise和Node.js异步操作的时候踩点坑太正常啦！我看你现在的问题应该是forEach循环里的子Promise没有被正确等待，导致父Promise可能在所有子操作完成前就resolve了，对吧？

咱们先来看问题出在哪：forEach本身是同步遍历的，它不会等待每个循环里的Promise执行完成，所以你的父Promise会直接往下走，根本等不及所有子查询做完。

那怎么改呢？核心思路是用map把每个子项转换成Promise，然后用Promise.all来等待所有这些Promise都完成。下面给你两种修改方案：

方案一：基于你原代码的修改 #

return new Promise(function(resolve, reject) {
  var authorMapArray = []; // 用[]创建数组比new Array()更简洁哦
  db.sequelize.query(authorQuery, { replacements: queryParams })
    .spread(function(authorSitemap) {
      // 用map生成所有子Promise的数组，而不是forEach
      const childPromises = authorSitemap.map(function(obj) {
        return new Promise(function(resolveChild, rejectChild) {
          var thisQuery = "..."; // 你的子查询语句
          // 执行子查询
          db.sequelize.query(thisQuery, { /* 子查询的参数 */ })
            .spread(function(result) {
              // 把结果存入数组
              authorMapArray.push(result);
              resolveChild(); // 标记当前子Promise完成
            })
            .catch(rejectChild); // 捕获子查询的错误，传递给子Promise
        });
      });

      // 等待所有子Promise都完成后，再resolve父Promise
      Promise.all(childPromises)
        .then(function() {
          resolve(authorMapArray); // 返回最终收集的结果
        })
        .catch(reject); // 任何子Promise失败，父Promise直接reject
    })
    .catch(reject); // 捕获父查询的错误
});

方案二：更简洁的Promise链式调用（推荐） #

其实Sequelize的query方法本身就返回Promise，所以我们完全不用手动创建外层的Promise，直接链式调用更符合Promise的最佳实践：

return db.sequelize.query(authorQuery, { replacements: queryParams })
  .spread(function(authorSitemap) {
    // 遍历每个authorSitemap项，返回对应的子查询Promise
    return Promise.all(authorSitemap.map(function(obj) {
      var thisQuery = "..."; // 你的子查询语句
      return db.sequelize.query(thisQuery, { /* 子查询参数 */ })
        .spread(function(result) {
          // 这里可以直接返回处理后的结果，Promise.all会把所有结果收集成数组
          return result;
        });
    }));
  })
  // 这里的results就是所有子查询结果组成的数组，直接返回即可
  .then(function(results) {
    return results;
  });

关键知识点提醒： #

• forEach不支持异步等待：它只是同步遍历数组元素，不会理会循环里的异步操作什么时候完成，所以永远不要在需要等待异步任务的场景用forEach。
• Promise.all是处理批量异步的利器：它会接收一个Promise数组，等到所有Promise都resolve后，返回一个包含所有结果的数组；如果有任何一个Promise reject，它会立即reject，把错误抛出来。
• 错误处理要到位：不管是父查询还是子查询，都要记得捕获错误，避免出现未处理的Promise拒绝警告。

这样修改后，你的父Promise就会等到所有子Promise都执行完成后，再返回最终的结果啦！

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