NodeJS异步调用的顺序化处理

NodeJS本身一个重要的特性就是异步处理，但异步处理多了，会把一个完整的“业务”逻辑拆分的支离破碎，让人看到头大，或许这就是所谓的异步陷阱？！最近看NodeJS项目代码时，发现了一个Step的模块，就是专门将一系列执行有先后关系的异步调用做序列化调用处理的，使之在代码层面上尽量看起来更清晰。Step详情可参见 https://github.com/creationix/step

1. 简单的将异步处理顺序化

step本身定义了一个 Step 的方法， Step可以接收任意多的方法，并按顺序执行这些方法，其中this代表下一个方法的回调。

var fs = require('fs');
var Step = require('step'); 
Step( function readSelf() {
  fs.readFile(__filename, 'utf-8', this); }, 
  function capitalize(err, text) { 
    if (err) throw err; 
    return text.toUpperCase(); 
  }, 
  function showIt(err, newText) { 
    if (err) throw err; 
    console.log(newText); 
  }
);

执行以上代码后，会看到一段大写的代码，从代码逻辑上不难理解：

1. readSelf(), 使用了异步函数读取方法readFile(), 并通过this来指定下一个方法(capitalize)作为callback函数。
2. capitalize(), 没有使用异步方法，所以直接通过return调用下一个方法(showIt)
3. showIt(), 将上一个方法return的值(newText)打印出来

第一个参数固定为一个异常接收的参数，只要你不嵌套回调，这将有助于你捕获所有的异常，保证你的服务足够健壮。

2. 通过this.parallel()实现并行调用

如果在一个逻辑处理，我们需要触发多个异步调用，并写保证这个逻辑的顺序执行，我们可以使用this.parallel() 来代替 this，通过代码我们将很容易明白：

var fs = require('fs');
var Step = require('step');
Step( // Loads two files in parallel
  function loadStuff() { 
    fs.readFile(__filename, 'utf-8', this.parallel());
    fs.readFile("/etc/passwd", 'utf-8', this.parallel()); 
  },
  // Show the result when done function 
  showStuff(err, code, users) { 
    if (err) throw err; 
    console.log(code); 
    console.log(users); 
  } 
)

3. group() 方法

如果在一个方法内，我们需要批量调用同一个回调方法，并对该方法产生的数据有统一的处理模式，那么我们需要使用group()。例如我们需要读取一个目录下所有的js文件，然后再将这些文件的内容打印出来，我们就可以使用group这个方法。看代码会比较好明白：

var fs = require('fs');
var Step = require('step');
Step(
  function readDir() { fs.readdir(__dirname, this); },
  function readFiles(err, results) { 
    if (err) throw err; // Create a new group 
    var group = this.group(); 
    results.forEach(function (filename) { 
      if (/\.js$/.test(filename)) { 
        fs.readFile(__dirname + "/" + filename, 'utf8', group()); } }); }, 
        function showAll(err , files) { 
          if (err) throw err; 
          console.dir(files); 
        } 
);

其中特别需要说明的是，这里的group()一定要“new”出来一个，不可直接使用this.group()，因为此处的group()需要统一管理所有回调的状态，也就是说在 readFiles().results.forEach循环回调读取当前目录下所有文件完成后，再统一调用下一步定义的文件内容处理方法showAll()。