Nodejs異步流程框架async的方法

更新時(shí)間：2019年06月07日 10:16:32 作者：websun

這篇文章主要介紹了Nodejs異步流程框架async的方法，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來(lái)看看吧

Async的簡(jiǎn)單介紹：

Async是一個(gè)流程控制工具包，提供了直接而強(qiáng)大的異步功能?；贘avascript為Node.js設(shè)計(jì)，同時(shí)也可以直接在瀏覽器中使用。Async提供了大約20個(gè)函數(shù)，包括常用的map, reduce, filter, forEach等，異步流程控制模式包括，串行(series)，并行(parallel)，瀑布(waterfall)等。

https://github.com/caolan/async

我們常用的是以下四種：

串行無(wú)關(guān)聯(lián)
串行有關(guān)聯(lián)
并行無(wú)關(guān)聯(lián)
智能控制

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

多個(gè)函數(shù)或方法要依次執(zhí)行，但是他們之間并沒有什么聯(lián)系，只有先后的順序，比如我要寫一個(gè)文件，寫完之后像用戶發(fā)送郵件，這兩者之間沒有必然的聯(lián)系，但是發(fā)郵件必須在寫文件完成之后。
async里有一個(gè)方法series可以實(shí)現(xiàn)這一流程,代碼實(shí)現(xiàn)如下：

var async = require('async');
console.time('series');
async.series({
  one: function(callback) {
    callback(null, 'one');//callback('i am err','one');異常處理
  },
  two: function(callback) {
    callback(null, 'two');

  },
}, function(error, result) {
  //最后結(jié)果
  console.log('error: ' + error);
  console.log('result: ' + result);
  console.timeEnd('series');
});

// error: null
// result: [object Object]
// series: 4.472ms

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

瀑布流函數(shù),串行執(zhí)行數(shù)組中的每一個(gè)函數(shù)最后執(zhí)行回調(diào)。語(yǔ)法：async.waterfall(tasks,callback) 第一個(gè)參數(shù)tasks是一個(gè)數(shù)組，數(shù)組包含的是需要依次執(zhí)行的函數(shù)。

第二個(gè)參數(shù)為回調(diào)函數(shù)，當(dāng)瀑布流函數(shù)（即tasks數(shù)組中的函數(shù)）執(zhí)行出現(xiàn)錯(cuò)誤時(shí)會(huì)執(zhí)行這個(gè)回調(diào)函數(shù)并將錯(cuò)誤信息返回,當(dāng)瀑布流函數(shù)無(wú)錯(cuò)誤時(shí)，會(huì)在執(zhí)行完tasks數(shù)組中包含的函數(shù)后執(zhí)行這個(gè)回調(diào)函數(shù)。

用法示例：一般用法：

async.waterfall([
  myFirstFun,
  mySecondFun,
  myLastFun
],function(err,result) { // result回調(diào)函數(shù)
  // result 相當(dāng)于tasks數(shù)組中最后一個(gè)函數(shù)（myLastFun）的返回值done
  console.log(result);  // myLastFun
})
function myFirstFun(callback) {
  callback(null,'one','two');
}
function mySecondFun(arg1,arg2,callback) {
  // arg1 相當(dāng)于 'one' ,arg2 相當(dāng)于 'two'
  callback(null,'three');
}
function myLastFun(arg1,callback) {
  // arg1 相當(dāng)于 'three'
  callback(null,'done');
}

3.async.parallel：并行無(wú)關(guān)聯(lián)

task并行運(yùn)行函數(shù)集合，而不必等到上一個(gè)函數(shù)完成。如果任何函數(shù)發(fā)生錯(cuò)誤，會(huì)立刻執(zhí)行回調(diào)函數(shù)，并返回錯(cuò)誤信息；若沒有發(fā)生錯(cuò)誤，則會(huì)再所有tasks函數(shù)執(zhí)行完畢之后用回掉函數(shù)將結(jié)果返回。

語(yǔ)法：async.parallel(tasks,callback) 代碼示例：

async.parallel([
  function(callback) {
    setTimeout(function() {
      callback(null, 'one');
    }, 200);
  },
  function(callback) {
    setTimeout(function() {
      callback(null, 'two');
    }, 100);
  }
],function(err, results) {
  console.log(result)}
);

4.async.auto：智能控制

以上都是純串行傳并行，但是當(dāng)一個(gè)場(chǎng)景里，需要使用串行也需要使用并行的時(shí)候，雖然分別寫能解決，但是效率不是很高，維護(hù)性也不是很好，auto可以解決這一問題。

如下場(chǎng)景：

從某處取得數(shù)據(jù)
在硬盤上建立一個(gè)新的目錄
將數(shù)據(jù)寫入到目錄下某文件
發(fā)送郵件，將文件以附件形式發(fā)送給其它人。
可以知道1與2可以并行執(zhí)行，3需要等1和2完成，4要等3完成。
使用auto來(lái)解決

var async = require('async');
console.time('auto');
async.auto({
  getData: function(callback) {
    setTimeout(function() {
      console.log('1.1: got data');
      callback(null, 'mydata');
    }, 300);
  },
  makeFolder: function(callback) {
    setTimeout(function() {
      console.log('1.1: made folder');
      callback(null, 'myfolder');
    }, 200);
  },
  writeFile: ['getData', 'makeFolder', function(callback) {
    setTimeout(function() {
      console.log('1.1: wrote file');
      callback(null, 'myfile');
    }, 300);
  }],
  emailFiles: ['writeFile', function(callback, results) {
    console.log('emailed file: ', results.writeFile);
    callback(null, results.writeFile);
  }]
}, function(err, results) {
  console.log('err: ', err);
  console.log('results: ', results);
  console.timeEnd('auto');
});

結(jié)果如下

1.1: made folder
1.1: got data
1.1: wrote file
emailed file: myfile
err: null
results: { makeFolder: 'myfolder',
getData: 'mydata',
writeFile: 'myfile',
emailFiles: 'myfile'
}
auto: 650.972ms

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: