Node js 中的多个承诺

Multiple promises in Node js

我是 nodejs 的新手,正在努力寻找以下代码的问题。

我想要实现的是,一个接一个地调用几个方法,如果所有调用都成功,则 return 成功,否则如果任何方法失败则抛出错误。

我遇到的问题是,在执行所有方法之前,即使 promise 尚未实现,main 方法也会终止。

主要方法

processRequest(neworder).then(function (done) {
    console.log('Successfully processed the order' + done);
    res.sendStatus(200);
}).fail(function (error) {
    res.status(404).send(error);
})

其他方法调用

module.exports.processRequest = function (Order) {
    var deferred = Q.defer();

    findX(Order)
        .then(findYBasedOnPrevOutput)
        .then(findZBasedOnPrevOutput)
        .then(deferred.resolve())
        .fail(function (err) {
            console.log('Failed to process request' + err);
            deferred.reject(err);
        });

    return deferred.promise;
}


var findX = function (order) {
    var deferred = Q.defer()

    db.list(order, function (address) {
        console.log('Query success');
        if (address == null)
            deferred.reject('Error');
        else {
            deferred.resolve(address);
        }
    })

    return deferred.promise;
};

我遇到的问题是,在调用 findX 方法后,我在控制台中看到成功。我期待 findZ 方法后的成功消息。

你能帮我找出上面代码的问题吗,感谢你在这方面的input/suggestions

为简单起见,我没有在这里分享其他模块,但它们与 findX 非常相似

我建议您只使用已有的 promise 而不是创建一个新的 promise,因为这样既更高效又可以避免 promise 反模式:

module.exports.processRequest = function (Order) {
  return findX(Order)
    .then(findYBasedOnPrevOutput)
    .then(findZBasedOnPrevOutput)
    .fail(function (err) {
      // log the error, then throw it again so it is returned as a rejected promise
      console.log('Failed to process request' + err);
      throw(err);
    });
}

而且,我建议更改 findX 以使用 Q 将标准异步调用转换为 returns 这样的承诺的能力:

var findX = function(order) {
  return Q.nfcall(db.list.bind(db), order);
};

或者,像这样将两者结合起来:

module.exports.processRequest = function (Order) {
  return Q.nfcall(db.list.bind(db), Order)
    .then(findYBasedOnPrevOutput)
    .then(findZBasedOnPrevOutput)
    .fail(function (err) {
      // log the error, the throw it again so it is returned as a rejected promise
      console.log('Failed to process request' + err);
      throw(err);
    });
}