javascript - Node.js，厄运的金字塔(即使有异步)，你能把它写得更好吗？

Question

我认为自己是一位非常有经验的 node.js 开发人员。

但我仍然想知道是否有更好的方法来编写以下代码，这样我就不会得到厄运金字塔......现在我对你很宽容，我有一些代码可以让我的金字塔高达 20地板，不开玩笑；这就是使用 async.js 的原因!!!

问题真的是我对预览变量有很多依赖，所以所有东西都必须嵌套。写“异步 Javascript，用更少的代码构建响应更快的应用程序”一书的人解释说，他会将函数放在根范围内，这当然会摆脱金字塔，但现在你会有一大堆高范围变量(甚至可能是全局的，取决于你声明它们的范围)并且这种污染会导致一些非常讨厌的错误(如果设置在全局空间，这可能会导致 var 与其他脚本冲突(确保你可以使用自调用函数，更多yachhh...甚至更糟，因为我们正在处理异步、变量重写...)。事实上，闭包的美感已经被忽略了。

他推荐的做法是:

function checkPassword(username, passwordGuess, callback) {
    var passwordHash;
    var queryStr = 'SELECT * FROM user WHERE username = ?';
    db.query(selectUser, username, queryCallback);
    function queryCallback(err, result) {
        if (err) throw err;
        passwordHash = result['password_hash'];
        hash(passwordGuess, hashCallback);
    }

    function hashCallback(passwordGuessHash) {
        callback(passwordHash === passwordGuessHash);
    }
}

再次强调，恕我直言，这不是一个干净的方法。

因此，如果您查看我的代码(同样，这只是一个片段，我在其他地方得到了更大的嵌套)，您会经常看到我的代码离左边越来越远；这就是使用 waterfall 和异步 forEach 之类的东西......

这是一个小例子:

ms.async.eachSeries(arrWords, function (key, asyncCallback) {
    pg.connect(pgconn.dbserver('galaxy'), function (err, pgClient, pgCB) {
        statement = "SELECT * FROM localization_strings WHERE local_id = 10 AND string_key = '" + key[0] + "'";
        pgClient.query(statement, function (err, result) {
            if (pgconn.handleError(err, pgCB, pgClient)) return;
            // if key doesn't exist go ahead and insert it
            if (result.rows.length == 0) {
                statement = "SELECT nextval('last_resource_bundle_string_id')";
                pgClient.query(statement, function (err, result) {
                    if (pgconn.handleError(err, pgCB, pgClient)) return;
                    var insertIdOffset = parseInt(result.rows[0].nextval);
                    statement = "INSERT INTO localization_strings (resource_bundle_string_id, string_key, string_revision, string_text,modified_date,local_id, bundle_id) VALUES ";
                    statement += "  (" + insertIdOffset + ",'" + key[0] + "'," + 0 + ",'" + englishDictionary[key[0]] + "'," + 0 + ",10,20)";
                    ms.log(statement);
                    pgClient.query(statement, function (err, result) {
                        if (pgconn.handleError(err, pgCB, pgClient)) return;
                        pgCB();
                        asyncCallback();
                    });
                });
            }
            pgCB();
            asyncCallback();
        });
    });
});

在我的深层脚本中，我数了超过 25 个右括号，太疯狂了，同时还记得在哪里调用我的最后一个 callBack，以便异步继续进行下一次迭代...

这个问题有解决办法吗？或者这只是野兽的本性？

Answer 1

正如 Mithon 在他的回答中所说， promise 可以使这段代码更加清晰，并有助于减少重复。假设您创建了两个返回 promise 的包装函数，对应于您正在执行的两个数据库操作，connectToDb 和 queryDb。然后你的代码可以写成这样:

ms.async.eachSeries(arrWords, function (key, asyncCallback) {
  var stepState = {};
  connectToDb('galaxy').then(function(connection) {
    // Store the connection objects in stepState
    stepState.pgClient = connection.pgClient;
    stepState.pgCB = connection.pgCB;

    // Send our first query across the connection
    var statement = "SELECT * FROM localization_strings WHERE local_id = 10 AND string_key = '" + key[0] + "'";
    return queryDb(stepState.pgClient, statement);
  }).then(function (result) {
    // If the result is empty, we need to send another 2-query sequence
    if (result.rows.length == 0) {
       var statement = "SELECT nextval('last_resource_bundle_string_id')";
       return queryDb(stepState.pgClient, statement).then(function(result) {
         var insertIdOffset = parseInt(result.rows[0].nextval);
         var statement = "INSERT INTO localization_strings (resource_bundle_string_id, string_key, string_revision, string_text,modified_date,local_id, bundle_id) VALUES ";
         statement += "  (" + insertIdOffset + ",'" + key[0] + "'," + 0 + ",'" + englishDictionary[key[0]] + "'," + 0 + ",10,20)";
         ms.log(statement);
         return queryDb(stepState.pgClient, statement);
       });
     }
  }).then(function (result) {
    // Continue to the next step
    stepState.pgCB();
    asyncCallback();
  }).fail(function (error) {
    // Handle a database error from any operation in this step...
  });
});

它仍然很复杂，但复杂性更易于管理。向每个“步骤”添加新的数据库操作不再需要新级别的缩进。另请注意，所有错误处理都在一个地方完成，而不是每次执行数据库操作时都必须添加 if (pgconn.handleError(...)) 行。

更新:根据要求，您可以按照以下方式定义两个包装器函数。我假设您使用的是 kriskowal/q作为你的 promise 库:

function connectToDb(dbName) {
  var deferred = Q.defer();
  pg.connect(pgconn.dbserver(dbName), function (err, pgClient, pgCB) {
    if (err) {
      deferred.reject(err)
    } else {
      deferred.resolve({pgClient: pgClient, pgCB: pgCB})
    }
  });
  return deferred.promise;
}

您可以使用此模式围绕任何接受一次性回调的函数创建包装器。

queryDb 更直接，因为它的回调给你一个单一的错误值或一个单一的结果值，这意味着你可以使用 q 的内置 makeNodeResolver解决或拒绝延迟的实用方法:

function queryDb(pgClient, statement) {
  var deferred = Q.defer();
  pgClient.query(statement, deferred.makeNodeResolver());
  return deferred.promise;
}

有关 promise 的更多信息，请查看我的书:Async JavaScript , 由 P​​ragProg 发布。