在NodeJS中使用流程控制工具Async

Async的内容分为三部分：

• 流程控制：简化十种常见流程的处理
• 集合处理：如何使用异步操作处理集合中的数据
• 工具类：几个常用的工具类

本文介绍其中最简单最常用的流程控制部分。
由于nodejs是异步编程模型，有一些在同步编程中很容易做到的事情，现在却变得很麻烦。Async的流程控制就是为了简化这些操作。

安装

npm install async --save -d

1.async.waterfall实例（多个函数依次执行，且前一个的输出为后一个的输入）

这个函数名为waterfall(瀑布)，可以想像瀑布从上到下，按顺序依次执行多个函数。不同之处，每一个函数产生的值，都将传给下一个函数。如果中途出错，后面的函数将不会被执行。错误信息以及之前产生的结果，将传给waterfall最终的callback。
注意，该函数不支持json格式的tasks。

应用场景：在创建课程的接口中，首先解析表单和上传头像，然后保存课程到数据库

async.waterfall([
    function(cb) {
     util.formParse(req,function(err,result){  //from解析
              cb(err,result);
          });  
    },
    function(user, cb) {
        courseCtrl.create(course,function(err,result){ //保存到数据库
            cb(err,result);
        })
    }
], function (err, result) {
    if(err) throw  err;
    var results = util.response.regOK;
    results.item = result;
    res.send(results);
});

2.async.parallel 实例（多个函数并行执行）

并行执行多个函数，每个函数都是立即执行，不需要等待其它函数先执行。传给最终callback的数组中的数据按照tasks中声明的顺序，而不是执行完成的顺序。
如果某个函数出错，则立刻将err和已经执行完的函数的结果值传给parallel最终的callback。其它未执行完的函数的值不会传到最终数据，但要占个位置。
支持json形式的tasks，其最终callback的结果也为json形式。

应用场景：在获取课程列表接口中，要获取课程列表，同时获取课程数目

async.parallel({
     count:function(cb){
         courseController.count( req.query ,cb);   //课程数目
     },
     list:function(cb){
         courseController.getList( req.query ,cb);   //课程列表
     }
 },function(err,results){ 
    res.send(results);
 });

请求结果

{
count:2,
list:[
         {
            courseid:xxx,
            name:xxx
         },
         {
            courseid:xxx,
            name:xxx
         }
     ]
}

3.async.auto实例（多个函数有依赖关系，有的并行执行，有的依次执行）

用来处理有依赖关系的多个任务的执行。比如某些任务之间彼此独立，可以并行执行；但某些任务依赖于其它某些任务，只能等那些任务完成后才能执行。虽然我们可以使用async.parallel和async.series结合起来实现该功能，但如果任务之间关系复杂，则代码会相当复杂，以后如果想添加一个新任务，也会很麻烦。这时使用async.auto，则会事半功倍。
如果有任务中途出错，则会把该错误传给最终callback，所有任务（包括已经执行完的）产生的数据将被忽略。

应用场景：

根据uid（用户id）和course_id（课程id）获取用户信息和用户收藏的视频：
根据uid，在user表中获取用户信息；
根据course_id，在course表中获取课程信息，含teacher_id；
根据teacher_id，在user表中获取讲师信息(上一步执行完，才能执行)；
最后，返回userInfo,courseInfo,tearcherInfo;

async.auto({
    userInfo:function(cb){
            userCtrl.getInfo({uid:req.query.uid}, function (err, result) {   //用户信息
            cb(err,result);
        });
    },
    couseInfo:function(cb){
        courseCtrl.getInfo(req.query.courseid, function (err, result) {  //课程信息
            cb(err,result);
        });
    },
    tearcherInfo:[‘couseInfo‘, function(results,cb) {
        userCtrl.getInfo({uid:results.couseInfo.teacherid},function(err,result){  //讲师信息
            cb(err,result);
        });
    }]
},function(err,results){
    if (err) throw err;
    res.send(results);
});