文章目录
  1. 1. 问题
  2. 2. 解决方案
  3. 3. Async介绍
  4. 4. Async函数介绍
    1. 4.1. Collections
    2. 4.2. Control Flow
    3. 4.3. Utils
  5. 5. 参考

nodejs是基于事件驱动的,所有的一切都是异步调用的,这种实现机制优点确实十分明显,那就是避免了同步调用的无尽等待。但有时候可能后面的调用需要等到前面回调函数执行之后才能正常执行。这个时候可能就需要多层嵌套了,不过这种实现方式明显是不好的,如何解决呢?Async.js就派上了用场。

问题

现在有两张数据库表–Resources和MockItems,二者是一对多关系。我们需要根据传入参数获取所有满足条件的Resources,然后再分别获取到属于这些Resources的MockItems,并将其构造成一个新的对象ResourceItems:包含两个属性,Resources以及与之对应的MockItems。最后获取完数据库之后将其传递到前端。

因为使用nodejs使用异步操作,如何才能判断出以及获取完所有数据?如果仅仅使用原生nodejs解决这个问题,好像只能使用多层嵌套,但是Resource如果很大,明显这个程序会block住。最好的方法就是所有的Resources同时去获取MockItems,最后返回数据。

解决方案

我们使用Async可以完美解决上面的问题。下面是我项目中的源码:

var express = require('express');
var router = express.Router();
var async = require('async');

router.route('/domain/:domain_id')
    .get(function(req, res) {
        Resource.find({domain_id: req.params.domain_id}, function(err, resources) {
            if(err) {
                res.send(err);
            }

            var resourceItems = new Array();


            async.each(resources, function(resource, callback) {
                MockItem.find({resource_id: resource._id}, {'name': 1, 'active':1}, function(err, mockItems) {
                    if(err) {
                        res.send(err);
                    }

                    var item = new ResourceItem(resource, mockItems);
                    resourceItems.push(item);

                    callback();
                });
            }, function(err) {
                if(err) {
                    res.send(err);
                }
                res.json(resourceItems);
            });

        });

    });

Async介绍

Async是一个流程控制工具包,提供了直接而强大的异步功能。基于Javascript为Node.js设计,同时也可以直接在浏览器中使用。

Async提供了大约20个函数,包括常用的 map, reduce, filter, forEach 等,异步流程控制模式包括,串行(series),并行(parallel),瀑布(waterfall)等。

Async函数介绍

async主要实现了三个部分的流程控制功能:

集合: Collections
流程控制: Control Flow
工具类: Utils

Collections

  • each: 如果想对同一个集合中的所有元素都执行同一个异步操作。
  • map: 对集合中的每一个元素,执行某个异步操作,得到结果。所有的结果将汇总到最终的callback里。与each的区别是,each只关心操作不管最后的值,而map关心的最后产生的值。
  • filter: 使用异步操作对集合中的元素进行筛选, 需要注意的是,iterator的callback只有一个参数,只能接收true或false。
  • reject: reject跟filter正好相反,当测试为true时则抛弃
  • reduce: 可以让我们给定一个初始值,用它与集合中的每一个元素做运算,最后得到一个值。reduce从左向右来遍历元素,如果想从右向左,可使用reduceRight。
  • detect: 用于取得集合中满足条件的第一个元素。
  • sortBy: 对集合内的元素进行排序,依据每个元素进行某异步操作后产生的值,从小到大排序。
  • some: 当集合中是否有至少一个元素满足条件时,最终callback得到的值为true,否则为false.
  • every: 如果集合里每一个元素都满足条件,则传给最终回调的result为true,否则为false
  • concat: 将多个异步操作的结果合并为一个数组。

Control Flow

  • series: 串行执行,一个函数数组中的每个函数,每一个函数执行完成之后才能执行下一个函数。
  • parallel: 并行执行多个函数,每个函数都是立即执行,不需要等待其它函数先执行。传给最终callback的数组中的数据按照tasks中声明的顺序,而不是执行完成的顺序。
  • whilst: 相当于while,但其中的异步调用将在完成后才会进行下一次循环。
  • doWhilst: 相当于do…while, doWhilst交换了fn,test的参数位置,先执行一次循环,再做test判断。
  • until: until与whilst正好相反,当test为false时循环,与true时跳出。其它特性一致。
  • doUntil: doUntil与doWhilst正好相反,当test为false时循环,与true时跳出。其它特性一致。
  • forever: 无论条件循环执行,如果不出错,callback永远不被执行。
  • waterfall: 按顺序依次执行一组函数。每个函数产生的值,都将传给下一个。
  • compose: 创建一个包括一组异步函数的函数集合,每个函数会消费上一次函数的返回值。把f(),g(),h()异步函数,组合成f(g(h()))的形式,通过callback得到返回值。
  • applyEach: 实现给一数组中每个函数传相同参数,通过callback返回。如果只传第一个参数,将返回一个函数对象,我可以传参调用。
  • queue: 是一个串行的消息队列,通过限制了worker数量,不再一次性全部执行。当worker数量不够用时,新加入的任务将会排队等候,直到有新的worker可用。
  • cargo: 一个串行的消息队列,类似于queue,通过限制了worker数量,不再一次性全部执行。不同之处在于,cargo每次会加载满额的任务做为任务单元,只有任务单元中全部执行完成后,才会加载新的任务单元。
  • auto: 用来处理有依赖关系的多个任务的执行。
  • iterator: 将一组函数包装成为一个iterator,初次调用此iterator时,会执行定义中的第一个函数并返回第二个函数以供调用。
  • apply: 可以让我们给一个函数预绑定多个参数并生成一个可直接调用的新函数,简化代码。
  • nextTick: 与nodejs的nextTick一样,再最后调用函数。
  • times: 异步运行,times可以指定调用几次,并把结果合并到数组中返回
  • timesSeries: 与time类似,唯一不同的是同步执行

Utils

  • memoize: 让某一个函数在内存中缓存它的计算结果。对于相同的参数,只计算一次,下次就直接拿到之前算好的结果。
  • unmemoize: 让已经被缓存的函数,返回不缓存的函数引用。
  • log: 执行某异步函数,并记录它的返回值,日志输出。
  • dir: 与log类似,不同之处在于,会调用浏览器的console.dir()函数,显示为DOM视图。
  • noConflict: 如果之前已经在全局域中定义了async变量,当导入本async.js时,会先把之前的async变量保存起来,然后覆盖它。仅仅用于浏览器端,在nodejs中没用,这里无法演示。

参考

文章目录
  1. 1. 问题
  2. 2. 解决方案
  3. 3. Async介绍
  4. 4. Async函数介绍
    1. 4.1. Collections
    2. 4.2. Control Flow
    3. 4.3. Utils
  5. 5. 参考