node.js中如何使用async異步控制工具

node.js中如何使用async異步控制工具，針對(duì)這個(gè)問(wèn)題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。

這兩個(gè)操作中，第一個(gè)異步的程序我們可能會(huì)寫成這樣：

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

將后面的操作寫到執(zhí)行成功后的回調(diào)函數(shù)里。第2個(gè)并行的異步操作，可以使用計(jì)數(shù)器的方法，每個(gè)異步調(diào)用成功時(shí)，計(jì)數(shù)器加1，當(dāng)所有的異步都調(diào)用成功后，再接著執(zhí)行：

var count = 0;
var success = function(){
 count++;
 if(count>=3){ 
  console.log('執(zhí)行完畢...');
 }
}

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();

這些編寫方式非常麻煩，而且代碼邏輯比較混亂，調(diào)試起來(lái)也很不方便。那么就要用到異步控制的利器async了。

介紹

async的作用是進(jìn)行流程的控制，而且提供了非常多的方法可供調(diào)用。

這些方法可以分為三大類：

• 集合類（Collections）

• 流程控制類（Control Flow）

• 工具類（Utils）
  

下面我們從這三個(gè)分類里分別挑出幾個(gè)方法進(jìn)行講解。

二、函數(shù)介紹

async中提供了非常多的方法可供使用，我們僅僅是講解其中幾個(gè)比較有代表性的，其他的可以訪問(wèn)官方文檔：http://caolan.github.io/async/docs.html。

2.1 集合類

集合類中的方法主要有some, ‘map', ‘each', ‘every'等，這些方法是對(duì)數(shù)組或組合進(jìn)行某個(gè)相同的操作后，統(tǒng)一執(zhí)行回調(diào)函數(shù)。

我們以map為例，map對(duì)集合中的每一個(gè)元素，執(zhí)行某個(gè)相同的異步操作，得到結(jié)果。所有的結(jié)果將匯總到最終的callback里。
使用方法，map接收三個(gè)參數(shù)，分別是：

注意：中間處理函數(shù)iteratee對(duì)coll中的每一項(xiàng)都是并發(fā)處理的，因此并不能保證iteratee按照順序完成。不過(guò)，如果coll是個(gè)數(shù)組，最后的結(jié)果集results會(huì)按照coll中的順序排列；如果coll是個(gè)集合（Object）類型，results會(huì)是數(shù)組類型，結(jié)果將大致按照coll的鍵的順序排列（但是不同在不同的JavaScript引擎中會(huì)有可能發(fā)生變化）。

我們來(lái)舉個(gè)例子，使用map獲取幾個(gè)文件中的內(nèi)容：

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

// 讀取文件內(nèi)容
// 第1個(gè)參數(shù) 文件名稱列表的數(shù)組
// 第2個(gè)參數(shù) 傳入數(shù)組中的每一項(xiàng)和回調(diào)函數(shù)
// 第3個(gè)參數(shù) results為所有結(jié)果的集合
async.map(files, function(file, cb){
 fs.readFile(file, 'utf-8', function(err, data){
  cb(err, data);
 })
}, function(err, results){
 console.log( results );
})

而且，如果中間的處理函數(shù)比較大，不想寫在map中，也可以單獨(dú)寫成一個(gè)函數(shù)，然后傳遞進(jìn)去，不過(guò)參數(shù)傳遞還是要符合規(guī)則的：

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 );
})

這里還有一個(gè)mapLimit，可以傳遞一個(gè)參數(shù)limit，用來(lái)限制并發(fā)的數(shù)量：mapLimit(coll, limit, iteratee, callbackopt) ：

// 并發(fā)數(shù)量為2
async.mapLimit(files, 2, read, function(err, result){
 console.log( result );
})

同時(shí)，集合類中還有其他的方法，我們也稍微了解下：

1. each : 與map類似，但是最后的回調(diào)函數(shù)里沒(méi)有results，each只循環(huán)不負(fù)責(zé)處理結(jié)果

2. every : 中間處理函數(shù)iteratee的參數(shù)(err, boolean)需要傳遞一個(gè)boolean值，若所有選項(xiàng)的結(jié)果都為true，則results為true

3. some : 與every類似，只是只要其中一個(gè)選項(xiàng)的結(jié)果為true，則results為true

4. filter : 對(duì)coll進(jìn)行篩選，篩選出結(jié)果為true的結(jié)果

5. reject : 與filter正好相反，篩選出結(jié)果為false的結(jié)果

6. concat : 將每個(gè)異步操作的結(jié)果合并為一個(gè)數(shù)組

2.2 流程控制類

上面的集合類是對(duì)一個(gè)集合進(jìn)行相同的處理，集合中的每一項(xiàng)都處理完后，再對(duì)結(jié)果進(jìn)行回調(diào)處理。而多個(gè)回調(diào)方法執(zhí)行時(shí)，則需要對(duì)這幾個(gè)回調(diào)方法進(jìn)行控制了。

多個(gè)回調(diào)方法執(zhí)行時(shí)，通常有這么幾個(gè)流程：

1. 串行且無(wú)關(guān)聯(lián)，即執(zhí)行完一個(gè)后再依次執(zhí)行下一個(gè)，且相互之間無(wú)數(shù)據(jù)交互，都執(zhí)行完后，再執(zhí)行最后的回調(diào)函數(shù)?？梢允褂?code>async.series

2. 串行且有關(guān)聯(lián)，即執(zhí)行完一個(gè)后再依次執(zhí)行下一個(gè)，且上一個(gè)回調(diào)函數(shù)的結(jié)果會(huì)作為下一個(gè)回調(diào)函數(shù)的參數(shù)?？梢允褂胊sync.waterfall

3. 并行，這幾個(gè)回調(diào)函數(shù)同時(shí)并發(fā)執(zhí)行，都執(zhí)行完成后，再執(zhí)行最后的回調(diào)函數(shù)?？梢允褂?code>async.parallel
   

當(dāng)然還有其他更復(fù)雜的流程，這里也只聊上面的三種情況。

async.series，async.waterfall和async.parallel的語(yǔ)法都是一樣的：
async.Method(coll, function(err, results){

})

其中coll既可以是數(shù)組，也可以是json格式的，而且results的類型與coll對(duì)應(yīng)。

串行且無(wú)關(guān)聯(lián)async.series：

// 串行且無(wú)關(guān)聯(lián)，數(shù)組格式
async.series([
 function(cb){
  getAllList(function(result){
   cb(null, result);
  });
 },
 function(cb){
  getAllUser(function(result){
   cb(null, result);
  });
 }
], function(err, result){
 console.log(result);
})

同時(shí)串行的異步可以是json格式的：

// 串行且無(wú)關(guān)聯(lián)，json個(gè)數(shù)
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);
})

串行且有關(guān)聯(lián)async.waterfall：

// 串行且上一個(gè)結(jié)果作為下一個(gè)的參數(shù)
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同時(shí)執(zhí)行
async.parallel([
 function(cb){
  getAllList(function(result){
   cb(null, result);
  });
 },
 function(cb){
  getAllUser(function(result){
   cb(null, result);
  });
 }
], function(err, result){
 console.log(result);
})

關(guān)于并行的異步操作，這里還有一個(gè)async.parallelLimit，限制并發(fā)的數(shù)量：

// 并發(fā)數(shù)量為2
async.parallelLimit([
 iteratee1, iteratee2, iteratee3, ...
], 2, function(err, results){
 
})

2.3 工具類

async中也提供了不少的工具方法可供使用，比如async.log可以輸出回調(diào)方法中的值，第1個(gè)參數(shù)為函數(shù)，后面的參數(shù)為傳遞給函數(shù)的參數(shù)：

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

// 將'world'傳遞給hello方法
async.log(hello, 'world'); // 'hello world'

這里面還有apply, dir, timeout等方法。

關(guān)于node.js中如何使用async異步控制工具問(wèn)題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒(méi)有解開(kāi)，可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。