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

創(chuàng)新互聯(lián)公司是一家專業(yè)提供華亭企業(yè)網(wǎng)站建設,專注與成都做網(wǎng)站、成都網(wǎng)站設計、html5、小程序制作等業(yè)務。10年已為華亭眾多企業(yè)、政府機構等服務。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站設計公司優(yōu)惠進行中。

這兩個操作中，第一個異步的程序我們可能會寫成這樣：

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

將后面的操作寫到執(zhí)行成功后的回調(diào)函數(shù)里。第2個并行的異步操作，可以使用計數(shù)器的方法，每個異步調(diào)用成功時，計數(shù)器加1，當所有的異步都調(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)試起來也很不方便。那么就要用到異步控制的利器async了。

介紹

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

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

• 集合類（Collections）

• 流程控制類（Control Flow）

• 工具類（Utils）

下面我們從這三個分類里分別挑出幾個方法進行講解。

二、函數(shù)介紹

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

2.1 集合類

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

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

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

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

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

// 讀取文件內(nèi)容
// 第1個參數(shù) 文件名稱列表的數(shù)組
// 第2個參數(shù) 傳入數(shù)組中的每一項和回調(diào)函數(shù)
// 第3個參數(shù) results為所有結果的集合
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中，也可以單獨寫成一個函數(shù)，然后傳遞進去，不過參數(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 );
})

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

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

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

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

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

3. some : 與every類似，只是只要其中一個選項的結果為true，則results為true

4. filter : 對coll進行篩選，篩選出結果為true的結果

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

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

2.2 流程控制類

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

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

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

2. 串行且有關聯(lián)，即執(zhí)行完一個后再依次執(zhí)行下一個，且上一個回調(diào)函數(shù)的結果會作為下一個回調(diào)函數(shù)的參數(shù)。可以使用async.waterfall

3. 并行，這幾個回調(diào)函數(shù)同時并發(fā)執(zhí)行，都執(zhí)行完成后，再執(zhí)行最后的回調(diào)函數(shù)。可以使用async.parallel

當然還有其他更復雜的流程，這里也只聊上面的三種情況。

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

})

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

串行且無關聯(lián)async.series：

// 串行且無關聯(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);
})

同時串行的異步可以是json格式的：

// 串行且無關聯(lián)，json個數(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);
})

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

// 串行且上一個結果作為下一個的參數(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同時執(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);
})

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

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

2.3 工具類

async中也提供了不少的工具方法可供使用，比如async.log可以輸出回調(diào)方法中的值，第1個參數(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等方法。

關于node.js中如何使用async異步控制工具問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關知識。