从0到1学习node(八)之异步控制工具async

系列索引： https://www.xiabingbao.com/node/2017/01/08/node-list.html
本文地址： https://www.xiabingbao.com/node/2017/02/25/node-async.html

咱们在编写异步程序时，最头痛的就是不知道结果何时返回给咱们，而后执行后面的操做，不少时候只能把后面的操做放到返回成功的函数里，或者使用计数器等方法。

比较典型的两个就是：后面的操做须要依赖上一个异步操做的结果；多个异步操做并行执行，都执行完成后再执行接下来的操做。这两个操做中，第一个异步的程序咱们可能会写成这样：

db.select(SQL1, function(res1){
    db.delete(SQL2, function(res2){
        db.insert(SQL3, function(res3){
            // ...
        })
    })
});

将后面的操做写到执行成功后的回调函数里。第2个并行的异步操做，可使用计数器的方法，每一个异步调用成功时，计数器加1，当全部的异步都调用成功后，再接着执行：

var count = 0;
var success = function(){
    count++;
    if(count>=3){ 
        console.log('执行完毕...');
    }
}

var select = function(){
    db.select(sql, function(res){
        success();
    })
}
var select2 = function(){
    db.select(sql, function(res){
        success();
    })
}
var select3 = function(){
    db.select(sql, function(res){
        success();
    })
}
select();
select2();
select3();

这些编写方式很是麻烦，并且代码逻辑比较混乱，调试起来也很不方便。那么就要用到异步控制的利器async了。

1. 介绍

async的做用是进行流程的控制，并且提供了很是多的方法可供调用。这些方法能够分为三大类：

• 集合类（Collections）

• 流程控制类（Control Flow）

• 工具类（Utils）

下面咱们从这三个分类里分别挑出几个方法进行讲解。

2. 函数介绍

async中提供了很是多的方法可供使用，咱们仅仅是讲解其中几个比较有表明性的，其余的能够访问官方文档：http://caolan.github.io/async/docs.html。

2.1 集合类

集合类中的方法主要有some, 'map', 'each', 'every'等，这些方法是对数组或组合进行某个相同的操做后，统一执行回调函数。

咱们以map为例，map对集合中的每个元素，执行某个相同的异步操做，获得结果。全部的结果将汇总到最终的callback里。

使用方法，map接收三个参数，分别是：

参数名称	类型	说明
coll	iteratee	callback
Array | Iterable | Object	function	function
须要处理数组，集合或其余可迭代的类型	迭代方法，用来对集合中的每一项进行处理。该方法接收两个参数(item, callback)；item为集合中的每一项, callback为回调函数。callback须要带有err(有时可能为null)和处理后的数据，callback(err, data)	最终回调函数，当集合处理完毕后调用此函数，传递两个参数err和result，result为以前处理后的全部的结果的集合

注意：中间处理函数iteratee对coll中的每一项都是并发处理的，所以并不能保证iteratee按照顺序完成。不过，若是coll是个数组，最后的结果集results会按照coll中的顺序排列；若是coll是个集合（Object）类型，results会是数组类型，结果将大体按照coll的键的顺序排列（可是不一样在不一样的JavaScript引擎中会有可能发生变化）。

咱们来举个例子，使用map获取几个文件中的内容：

var files = ['./file/cnode_1.txt', './file/cnode_2.txt', './file/cnode_3.txt'];

// 读取文件内容
// 第1个参数 文件名称列表的数组
// 第2个参数 传入数组中的每一项和回调函数
// 第3个参数 results为全部结果的集合
async.map(files, function(file, cb){
    fs.readFile(file, 'utf-8', function(err, data){
        cb(err, data);
    })
}, function(err, results){
    console.log( results );
})

并且，若是中间的处理函数比较大，不想写在map中，也能够单独写成一个函数，而后传递进去，不过参数传递仍是要符合规则的：

var files = ['./file/cnode_1.txt', './file/cnode_2.txt', './file/cnode_3.txt'];

var read = function(file, cb){
    fs.readFile(file, 'utf-8', function(err, data){
        cb(err, data);
    })
}
async.map(files, read, function(err, result){
    console.log( result );
})

这里还有一个mapLimit，能够传递一个参数limit，用来限制并发的数量：mapLimit(coll, limit, iteratee, callbackopt)：

// 并发数量为2
async.mapLimit(files, 2, read, function(err, result){
    console.log( result );
})

同时，集合类中还有其余的方法，咱们也稍微了解下：

• each : 与map相似，可是最后的回调函数里没有results，each只循环不负责处理结果

• every : 中间处理函数iteratee的参数(err, boolean)须要传递一个boolean值，若全部选项的结果都为true，则results为true

• some : 与every相似，只是只要其中一个选项的结果为true，则results为true

• filter : 对coll进行筛选，筛选出结果为true的结果

• reject : 与filter正好相反，筛选出结果为false的结果

• concat : 将每一个异步操做的结果合并为一个数组

2.2 流程控制类

上面的集合类是对一个集合进行相同的处理，集合中的每一项都处理完后，再对结果进行回调处理。而多个回调方法执行时，则须要对这几个回调方法进行控制了。

多个回调方法执行时，一般有这么几个流程：

1. 串行且无关联，即执行完一个后再依次执行下一个，且相互之间无数据交互，都执行完后，再执行最后的回调函数。可使用async.series

2. 串行且有关联，即执行完一个后再依次执行下一个，且上一个回调函数的结果会做为下一个回调函数的参数。可使用async.waterfall

3. 并行，这几个回调函数同时并发执行，都执行完成后，再执行最后的回调函数。可使用async.parallel

固然还有其余更复杂的流程，这里也只聊上面的三种状况。

async.series，async.waterfall和async.parallel的语法都是同样的：

async.Method(coll, function(err, results){

})

其中coll既能够是数组，也能够是json格式的，并且results的类型与coll对应。

串行且无关联async.series：

// 串行且无关联，数组格式
async.series([
    function(cb){
        getAllList(function(result){
            cb(null, result);
        });
    },
    function(cb){
        getAllUser(function(result){
            cb(null, result);
        });
    }
], function(err, result){
    console.log(result);
})

同时串行的异步能够是json格式的：

// 串行且无关联，json个数
async.series({
    one: function(cb){
        getAllList(function(result){
            cb(null, result);
        });
    },
    two: function(cb){
        getAllUser(function(result){
            cb(null, result);
        });
    }
}, function(err, result){
    console.log(result);
})

串行且有关联async.waterfall：

// 串行且上一个结果做为下一个的参数
async.waterfall([
    function(cb){
        getListById(1, function(result){
            cb(null, result);
        });
    },
    function(params, cb){
        console.log(params);
        getAllUser(function(result){
            cb(null, result);
        });
    }
], function(err, result){
    console.log(result);
})

并行async.parallel：

// 并行，getAllList与getAllUser同时执行
async.parallel([
    function(cb){
        getAllList(function(result){
            cb(null, result);
        });
    },
    function(cb){
        getAllUser(function(result){
            cb(null, result);
        });
    }
], function(err, result){
    console.log(result);
})

关于并行的异步操做，这里还有一个async.parallelLimit，限制并发的数量：

// 并发数量为2
async.parallelLimit([
    iteratee1, iteratee2, iteratee3, ...
], 2, function(err, results){
    
})

2.3 工具类

async中也提供了很多的工具方法可供使用，好比async.log能够输出回调方法中的值，第1个参数为函数，后面的参数为传递给函数的参数：

var hello = function(name, callback) {
    setTimeout(function() {
        callback(null, 'hello ' + name);
    }, 1000);
};

// 将'world'传递给hello方法
async.log(hello, 'world'); // 'hello world'

这里面还有apply, dir, timeout等方法。

3. 总结

使用async控制异步流程很是的方便，并且也能够在前端使用，好比能够操做多个ajax请求等。

系列索引： https://www.xiabingbao.com/node/2017/01/08/node-list.html
本文地址： https://www.xiabingbao.com/node/2017/02/25/node-async.html

欢迎你们关注个人微信公众号：