node.js中如何使用async異步控制工具-創(chuàng)新互聯(lián)

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

為企業(yè)提供成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站優(yōu)化、成都全網(wǎng)營銷推廣、競價(jià)托管、品牌運(yùn)營等營銷獲客服務(wù)。創(chuàng)新互聯(lián)建站擁有網(wǎng)絡(luò)營銷運(yùn)營團(tuán)隊(duì)，以豐富的互聯(lián)網(wǎng)營銷經(jīng)驗(yàn)助力企業(yè)精準(zhǔn)獲客，真正落地解決中小企業(yè)營銷獲客難題，做到“讓獲客更簡單”。自創(chuàng)立至今，成功用技術(shù)實(shí)力解決了企業(yè)“網(wǎng)站建設(shè)、網(wǎng)絡(luò)品牌塑造、網(wǎng)絡(luò)營銷”三大難題，同時(shí)降低了營銷成本，提高了有效客戶轉(zhuǎn)化率，獲得了眾多企業(yè)客戶的高度認(rè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)試起來也很不方便。那么就要用到異步控制的利器async了。

介紹

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

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

集合類（Collections）
流程控制類（Control Flow）
工具類（Utils）

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

二、函數(shù)介紹

async中提供了非常多的方法可供使用，我們僅僅是講解其中幾個(gè)比較有代表性的，其他的可以訪問官方文檔：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ù)名稱	類型	說明
coll	iteratee	callback
Array \| Iterable \| Object	function	function
需要處理數(shù)組，集合或其他可迭代的類型	迭代方法，用來對(duì)集合中的每一項(xiàng)進(jìn)行處理。該方法接收兩個(gè)參數(shù)(item, callback)；item為集合中的每一項(xiàng), callback為回調(diào)函數(shù)。callback需要帶有err(有時(shí)可能為null)和處理后的數(shù)據(jù)，callback(err, data)	最終回調(diào)函數(shù)，當(dāng)集合處理完畢后調(diào)用此函數(shù)，傳遞兩個(gè)參數(shù)err和result，result為之前處理后的所有的結(jié)果的集合

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

我們來舉個(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)去，不過參數(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，用來限制并發(fā)的數(shù)量：mapLimit(coll, limit, iteratee, callbackopt)：

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

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

each : 與map類似，但是最后的回調(diào)函數(shù)里沒有results，each只循環(huán)不負(fù)責(zé)處理結(jié)果
every : 中間處理函數(shù)iteratee的參數(shù)(err, boolean)需要傳遞一個(gè)boolean值，若所有選項(xiàng)的結(jié)果都為true，則results為true
some : 與every類似，只是只要其中一個(gè)選項(xiàng)的結(jié)果為true，則results為true
filter : 對(duì)coll進(jìn)行篩選，篩選出結(jié)果為true的結(jié)果
reject : 與filter正好相反，篩選出結(jié)果為false的結(jié)果
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è)流程：

串行且無關(guān)聯(lián)，即執(zhí)行完一個(gè)后再依次執(zhí)行下一個(gè)，且相互之間無數(shù)據(jù)交互，都執(zhí)行完后，再執(zhí)行最后的回調(diào)函數(shù)。可以使用async.series
串行且有關(guān)聯(lián)，即執(zhí)行完一個(gè)后再依次執(zhí)行下一個(gè)，且上一個(gè)回調(diào)函數(shù)的結(jié)果會(huì)作為下一個(gè)回調(diào)函數(shù)的參數(shù)?？梢允褂胊sync.waterfall
并行，這幾個(gè)回調(diào)函數(shù)同時(shí)并發(fā)執(zhí)行，都執(zhí)行完成后，再執(zhí)行最后的回調(diào)函數(shù)?？梢允褂?code>async.parallel

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

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

})

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

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

// 串行且無關(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格式的：

// 串行且無關(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異步控制工具問題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司行業(yè)資訊頻道了解更多相關(guān)知識(shí)。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)建站muchs.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

新聞標(biāo)題：node.js中如何使用async異步控制工具-創(chuàng)新互聯(lián)
文章出自：http://muchs.cn/article16/djijdg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站收錄、移動(dòng)網(wǎng)站建設(shè)、手機(jī)網(wǎng)站建設(shè)、網(wǎng)站營銷、網(wǎng)站導(dǎo)航、定制網(wǎng)站

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容