节点js中的可读异步代码流

Question

我是 node js 中的异步编程的新手，想知道如何将我以前的（同步）编程转换为 node js 中的可读异步编程。尤其是这个例子：

function getDefaultValue1() {
    return getDefaultValue1FromDB();
};
function getDefaultValue2() {
    return getDefaultValue2FromDB();
};

function doSomething(var optionalValue1, var optionalValue2){
    try {
        if(optionalValue1===null){
            optionalValue1 = getDefaultValue1();
        }
        if(optionalValue2===null){
            optionalValue2 = getDefaultValue2();
        }
        var resultList = [];
        for(var i = 0; i < optionalValue2; i++) {
            resultList.push(functionWithDbCall(optionalValue1, i));
        }
        return doSomeCalculations(resultList);
    }catch(var e){
        //log exception
        return null
    }
};

请注意，节点 js 中的所有 DB-Calls 都是异步的（getDefaultValue1FromDB(var callback)、functionWithDbCall(var optionalValue1, var i, var callback)）。

我的想法是： 将回调参数添加到 getDefaultValue => 需要在回调中和 if 之后使用相同的代码。 For 循环在回调被调用之前退出，并且回调需要处理它们被调用的频率并检查以正确的顺序推送项目。将函数更改为使用异步方法需要在调用它的任何地方更改代码，例如将 getDefaultValue 从返回 const int 更改为 DB 调用。

我被困在这里，我发现在为某些库或不可读代码做广告的地方比 asm 或 regex 更糟糕（只写一次，再也不会读/触摸）。我是否错过了我的 node js 学习资料中的一些基本内容，或者这是该语言的设计失败？

所以我希望有人可以告诉我如何用异步节点js编写这个简单的可读函数。

Answer 1

我建议使用 Bluebird：

var Promise = require('bluebird');

/**
 * Lets assume getDefaultValue1FromDB() passes a callback fn;
 * @return {Promise}
 */
function getDefaultValue1() {
    return new Promise(function(resolve, reject){
        return getDefaultValue1FromDB(function(err, value){
            if (err) return reject(err);
            return resolve(value);
        });
    });
}

/**
 * Lets assume getDefaultValue2FromDB() passes a callback fn;
 * @return {Promise}
 */
function getDefaultValue2() {
    return new Promise(function(resolve, reject){
        return getDefaultValue2FromDB(function(err, value){
            if (err) return reject(err);
            return resolve(value);
        });
    });
}

/**
 * @param  {Promise|int} optionalValue1
 * @param  {Prommise|int} optionalValue2
 * @return {Promise}
 */
function doSomething(optionalValue1, optionalValue2){

    if(optionalValue1 === null)
        optionalValue1 = getDefaultValue1;
    if(optionalValue2 === null)
        optionalValue2 = getDefaultValue2;

    return Promise
      .all([optionalValue1, optionalValue2])
      .spread(function(val1, val2){
          var resultList = [];
          for(var i = 0; i < val2; i++) {
              resultList.push(functionWithDbCall(val1, i));
          }
          return doSomeCalculationsAsync(resultList);
      }).catch(function(err){
          //Log any errors here.
      });

}

/**
 * Calls the db and returns a promise with the result.
 * @return {Promise}     [description]
 */
function functionWithDbCall(val, i) {
  Return new Promise();
}

/**
 * @param  {[Promise]} list Array of promises.
 * @return {Promise}
 */
function doSomeCalculationsAsync(list) {
    return Promise.all(list).then(doSomeCalculations);
}

请注意，doSomething 将返回一个承诺，因此您必须添加一个 .then() 来处理结果。还假设functionWithDbCall也返回了一个Promise，然后你可以将所有这些放在一个Promise.all()中，然后进行计算。

Answer 2

您可能希望使用 ES7 提案中的 async/await - JavaScript 的未来版本。请参阅this answer，了解如何从回调迁移到 Promise 到 async/await。

要在今天实际运行未来的代码，您需要使用Babel 将其编译为当前支持的功能。另外它可以做a lot more而不是异步/等待。