我想我没有“得到”异步编程

Question

我已经使用 node.js 大约 6 个月了，时断时续。但是，我想我仍然没有完全理解围绕异步调用设计程序。

以我最近的程序为例，它需要读取一个配置，使用该配置连接到数据库，然后异步连接到数据库中的每个地址。​​

我正在使用模块 fnoc 和 node-mysql，但这只是伪代码。

// first, get the config
fnoc(function(err, confs){
   // code stuff in here

   //now check that there's a database config
   if (confs.hasOwnProperty("database"))
   {
      // set up db connection
      var mysql_conn = mysql.createConnection({
          host:   confs.database.host,
          user:   confs.database.user,
          password:       confs.database.password,
          database:       confs.database.database
      });
      // do some querying here.
      mysql_conn.query(query, function(err, records, fields){
          records.forEach(function(host){
              // four levels in, and just now starting the device connections
          });
      });


   }
});

每次我写这样的东西，回调里面的回调里面的回调，我觉得我做错了什么。我知道 Promise 和异步节点库，但似乎如果这些是解决方案，它们应该是默认功能。是我做错了什么，还是只是没有为我点击？

编辑：一些建议包括使用回调函数，但这似乎更糟（除非我做错了，这是完全可能的）。你最终会在另一个函数中调用一个函数，这看起来特别像意大利面条。

上面的例子，带有函数：

function make_connection (hosts) {
hosts.foreach(function(host){
      //here's where the fun starts
    };
}


function query_db(dbinfo){
    var mysql_conn = mysql.createConnection({
          host:  dbinfo.host,
          user:  dbinfo.user,
          password:       dbinfo.password,
          database:       dbinfo.database
    });

// do some querying here.
    mysql_conn.query(query, function(err, records, fields){
    make_connection(records);
});

}



// first, get the config
fnoc(function(err, confs){
   // code stuff in here

   //now check that there's a database config
   if (confs.hasOwnProperty("database"))
   {
      // set up db connection

      query_db(confs.database);
      var mysql_conn = mysql.createConnection({
          host:   confs.database.host,
          user:   confs.database.user,
          password:       confs.database.password,
          database:       confs.database.database
      });
      // do some querying here.
      mysql_conn.query(query, function(err, records, fields){
          records.forEach(function(host){
              // four levels in, and just now starting the device connections
          });
      });


   }
});

Answer 1

异步函数和回调的目的是避免对象之间的任何冲突（发生的可能比你想象的要多！）。

我想向您指出这位异步爱好者：http://www.sebastianseilund.com/nodejs-async-in-practice

是的，回调确实需要一些时间来适应，但这是值得的！

Answer 2

简而言之：代替

foo(function () {
    // ... stuff #1 ...

    bar(function () {
        // ... stuff #2 ...

        baz();
    });
});

做

foo(handleFoo);

function handleFoo() {
    // ... stuff #1 ...

    bar(handleBar);
}

function handleBar() {
    // ... stuff #2 ...

    baz();
}

当然，它可以（也许应该）更细化，但这取决于实际代码。这只是一种避免嵌套函数的模式。还可以对这些方法进行更多的封装。

这是“普通”方法。还有一些库可以让您以很好的方式管理它。

Answer 3

如果您真的厌倦了无休止的回调，请尝试Q 或co。你可以像这样编写 node.js 代码：

co(function *(){
  var a = get('http://google.com');
  var b = get('http://yahoo.com');
  var c = get('http://cloudup.com');
  var res = yield [a, b, c];
  console.log(res);
})()

这几乎是一种不同的写作方式，因此可能难以掌握，但结果非常好。