Node.js 如何判断多个异步请求全部完成？Promise.all与EventProxy方案对比

Node.js 多异步任务完成判断方案

前言

本文主要介绍在Node.js环境下，如何有效判断多个异步过程是否全部执行完毕。针对这一常见需求，下文将详细展开几种可行的处理思路。

分批处理网络数据的场景

场景：

假设需要处理大量网络数据，例如获取1000条结果。由于数据处理速度较慢且存在超时风险，可以将任务拆分为10次处理，每次处理100条。待所有请求完成后，再进行统一汇总处理。

针对此类应用场景，可采用以下几种处理方式：

方案一：基于数据条目的判断

方案一：判断请求到的数据条目


// 模拟网络请求
function fetch(url, callback) {
 setTimeout(function (){
 callback(null, {
  subjects: [{
   data: Math.round(Math.random() * 100)
  }]
  });
 }, 2000);
}
// 实现方案1
function multiTask_1 () {
 var arr = [];
 var baseUrl = 'https://api.douban.com/v2/movie/top250';
 for (var start = 0; start < 10; start++) {
 var url = baseUrl + '?start=' + start + "&count=1";
  fetch(url, function(error, res) {
  var data = res.subjects;
  arr = arr.concat(data);
  // 调用完成后统一处理
  if (arr.length === 10) {
   console.log(arr);
  }
 });
 }
}

利用arr.length来判断运行结果。若arr.length不符合预期（例如因网络传输或处理异常导致数据少一条），则无法进行后续处理。这种方式与业务逻辑强耦合，缺乏普适性。

方案二：基于执行次数的计数器

方案二：判断异步过程执行次数


// 方案2
function multiTask_2 () {
 var taskWatcher = 0;
 var arr = [];
 var baseUrl = 'https://api.douban.com/v2/movie/top250';
 for (var start = 0; start < 10; start++) {
 taskWatcher++;
 var url = baseUrl + '?start=' + start + "&count=1";
 fetch(url, function(error, res) {
  var data = res.subjects;
  arr = arr.concat(data);
  taskWatcher--;
  if (taskWatcher === 0) {
   console.log(arr);
  }
 });
 }
}

方案二中，充当异步任务执行情况的观察员，其判断条件仅与异步过程的调用次数相关，与其他处理过程解耦。那么，是否存在其他更优方案呢？

方案三：使用 Promise.all

方案三：Promise.all()

Promise.all(iterable) 方法返回一个 Promise 对象，该对象会在可迭代对象中所有 Promise 均被 resolve 后被 resolve，或者在任一 Promise 被 reject 后被 reject。


function multiTask_3 () {
 // var taskWatcher = 0;
 var taskStack = [];
 var arr = [];
 var baseUrl = 'https://api.douban.com/v2/movie/top250';
 for (var start = 0; start < 10; start++) {
 taskStack.push(
  new Promise((resolve, reject) => {
  var url = baseUrl + '?start=' + start + "&count=1";
  fetch(url, function(error, res) {
   var data = res.subjects;
   arr = arr.concat(data);
   resolve();
  });
  })
 );
 }
 Promise.all(taskStack).then(function () {
 console.log(arr);
 });
}

这种方式具有更高的通用性，即使异步任务类型不同，也可通过此方式解决。但需注意处理 reject 情况，以避免其对最终处理结果产生负面影响。

方案四：EventProxy 事件代理

方案四：EventProxy

EventProxy 由朴灵开发，项目地址为 https://github.com/JacksonTian/eventproxy。


 var ep = new EventProxy();
 var arr = [];
 ep.after('fetchData', 10, function (list) {
 list.forEach(function(item){
  arr = arr.concat(item); 
 });
 console.log(arr);
 });
 var baseUrl = 'https://api.douban.com/v2/movie/top250';
 for (var start = 0; start < 10; start++) {
 var url = baseUrl + '?start=' + start + "&count=1";
  fetch(url, function(error, res) {
  var data = res.subjects;
  ep.emit('fetchData', data);
 });
 }

EventProxy 基于事件订阅/发布模式。其中的 after 方法可以侦听多次事件，回调函数中保存了多次异步任务数据结果的数组。此外，EventProxy 还支持对多个不同事件的侦听和处理。

总结

以上就是本文的全部内容，希望这些内容对大家的学习或工作具有参考价值。如有疑问，欢迎留言交流，感谢支持。

Node.js 多异步任务完成判断的四种方案解析