如何在将 Node 异步函数转换为 Promise 时使用 Q 库？

Question

如何在下面的代码中使用 Promises？

function async_f1(callback) {
    setTimeout(function() {
        callback("Async function 1...");
    }, 1000);
}

function async_f2(callback) {
    setTimeout(function() {
        callback("Async function 2!...");
    }, 1000);
}

function async_f3(callback) {
    setTimeout(function() {
        callback("Second async function 3!...");
    }, 1000);
}

function doAll() {
    async_f1(function(result1) {
        async_f2(function(result2) {
            async_f3(function(result3) {
                console.log("Final result:", result1 + " " + result2 + " " + result3);
            })
        })
    });

}

doAll();

谢谢

Answer 1

请参阅documentation。

例如：

var promise = Q.nfcall(someAsyncFunction, arg1, ...);

Answer 2

这里正在使用 Q.nfcall 使用承诺的 sn-p：

var Q = require('q');


var a = Q.nfcall(function async_f1(callback) {
    setTimeout(function() {
        callback(null, "Async function 1...");
    }, 1000);
});

var b = Q.nfcall(function async_f2(callback) {
    setTimeout(function() {
        callback(null, "Async function 2!...");
    }, 1000);
});

var c = Q.nfcall(function async_f3(callback) {
    setTimeout(function() {
        callback(null, "Second async function 3!...");
    }, 1000);
});

function doAll() {
    Q.all([a, b, c]).then(function(result) {
        console.log(result);
    }).fail(function(err) {
        console.log(err);
    })

}

doAll();

这里是Q.denodeify版本：

var Q = require('q');


var a = function async_f1(callback) {
    setTimeout(function() {
        callback(null, "Async function 1...");
    }, 1000);
};

var b = function async_f2(callback) {
    setTimeout(function() {
        callback(null, "Async function 2!...");
    }, 1000);
};

var c = function async_f3(callback) {
    setTimeout(function() {
        callback(null, "Second async function 3!...");
    }, 1000);
};

var a_promise = Q.denodeify(a);
var b_promise = Q.denodeify(b);
var c_promise = Q.denodeify(c);

function doAll() {
    Q.all([a_promise(), b_promise(), c_promise()]).then(function(result) {
        console.log(result);
    }).fail(function(err) {
        console.log(err);
    })

}

doAll();

我之前的尝试失败了，因为我错过了一个重要的点：

为了Q.nfcall 工作，您的回调必须使用 callback(error, data) 模式。以前我没有添加错误参数，所以我没有收到任何错误，但也没有任何输出。一旦我将它修复为callback(null, "Async function 1")，它就开始工作了。

Answer 3

首先，您需要promisify your functions。对于interfacing with nodeback functions，您通常使用Q.denodeify，但您的示例函数总是将它们的结果传回第一个参数。所以我们需要编写自己的函数：

function promisify(fn) {
    return function() {
        var args = Array.prototype.slice.call(arguments), ctx = this;
        return Q.Promise(function(resolve) {
            fn.apply(ctx, args.concat([resolve]);
        });
    };
}

并像使用它一样

var f1 = promisify(async_f1),
    f2 = promisify(async_f2),
    f3 = promisify(async_f3);

有了这些，你就可以使用 Promise 风格编写你的 doAll 函数：

function doAll() {
    return f1().then(function(result1) {
        return f2().then(function(result2) {
            return f3().then(function(result3) {
                return "Final result:", result1 + " " + result2 + " " + result3;
            });
        });
    }).then(function(res) {
        console.log(res);
    });
}
doAll();

如果你觉得这个回调金字塔看起来很奇怪，请查看How do I access previous promise results in a .then() chain?。

但由于您的函数实际上并不依赖于其他函数的结果，因此您可以轻松地并行运行它们：

function doAll() {
    return Q.all([f1(), f2(), f3()]).then(function(result) {
        console.log("Final result:", result1 + " " + result2 + " " + result3);
    });
}