NodeJS 异步。在正确形成对象之前发送的标头

Question

我在使用异步调用时遇到了麻烦。这是给我带来问题的代码sn-p

company.find({ managerID: req.session.manager.managerID })
        .exec((err, _companies) => {
            if(err)
                return res.status(500).send({ message: "Uh, oh! Something went wrong." });
            else {
                var data = [];
                var i = 0;
                _companies.forEach(c => {
                    user.find({ companyID: c._id, status: 0})
                    .then(_user => {
                            // console.log(_user);
                            var dummy = {
                                companyID: c._id,
                                companyName: c.companyName,
                                selectedCurrency: c.selectedCurrency,
                                metrics: c.metrics,
                                headAdmin: _user[0].email,
                                headName: _user[0].designer
                            };
                            console.log(dummy);
                            data.push(dummy);
                            console.log(data);
                            i++;
                    }).catch(err => {
                        return res.status(500).send({ message: "Uh, oh! Something went wrong." });
                    });
                });
                if(i == _companies.length)
                    return res.status(200).send({ data: data });
            }
        });

我的数据对象在对象正确形成之前被发送。

我尝试从 .exec 切换到 .then 承诺，希望它可以修复它，甚至尝试仅在循环完成后返回（甚至不返回空数组）。

每当我在return res.status(200).send({ data: data}) 之前调用console.log("hi") 时，它总是在console.log(dummy) 之前打印

等待解决这个问题，如果是，我应该如何使用它，因为我不熟悉如何使用它？

Answer 1

Array.prototype.forEach 同步工作，因此它不会等待其中的异步操作，例如user.find()。因此，i == _companies.length 在异步操作完成之前计算为true。

正如另一个答案中所建议的，您可以通过将所有待处理的 Promise 收集到一个数组中并将其传递给 Promise.all() 来解决此问题。在您的场景中，这可能如下所示：

company.find({ managerID: req.session.manager.managerID })
  .exec((err, _companies) => {
    if (err) {
      return res.status(500).send({ message: "Uh, oh! Something went wrong." });
    }
    const results = _companies.map(c =>
      user.find({ companyID: c._id, status: 0})
        .then(_user => ({
            companyID: c._id,
            companyName: c.companyName,
            selectedCurrency: c.selectedCurrency,
            metrics: c.metrics,
            headAdmin: _user[0].email,
            headName: _user[0].designer
        }))
    );
    return Promise.all(results)
      .then(data => res.status(200).send({ data: data }))
      .catch((err) => res.status(500).send({ message: "Uh, oh! Something went wrong." }));
  });

Answer 2

那是因为你的 forEach 在任何循环中都有异步指令。所以基本上 forEach 是同步的，但是你在这里插入了 Promise 并且你的下一条指令在 forEach 中的所有循环发生后执行

如果你使用 Bluebird 承诺（顺序执行）

Promise.mapSeries(_companies, c => /*generate data*/)
.then(res.status(200).send({ data: data }))

或者使用 Promise.all（并行执行）

Promise.all(_companies.map(c => /*generate data*/)
.then(res.status(200).send({ data: data }))