Nodejs本身是基于事件驱动的，这个都知道。如果你看过Nodejs events模块，应该很了解Nodejs是如何驱动异步回调的。
现在有许多人对异步和异步后台多并发产生了迷惑，或借助koa，或借助async，但是代码一出来，结果是什么呢？ 我认为是维护灾难！这样的代码被扔到大量的语法糖构造起来的数组中，所有使用这个代码的人必须同意和遵守潜在的约定，才能知道这个代码是怎么串行或者并行的。
我想，这绝对不是Nodejs作者对异步设计的初衷。
事件的优势是“分发”，在任何一个事件都对自己的代码有绝对的控制权。
Nodejs源代码本身就提供了很好的异步事件驱动模型编码的范例。
下面，我们谈谈，最典型的例子： ***并发|串行向数据库异步提取数据，然后把返回的所有数据聚合，并且作出响应。***<br />
###为了模拟这个数据库操作，现在构建这么两个函数:
var dbFindA = function (name, callback) {// 数据库查询模拟函数，输入name，1秒后返回结果 setTimeout(function () { callback(name.length * 1000); }, 1000);};var dbFindB = function (id, callback) {// 数据库查询模拟函数，输入id，2秒后返回结果 setTimeout(function () { callback(parseInt(id) + 1000); }, 2000);}; dbFindA耗时1秒，dbFindB耗时2秒。<br />
###然后，使用内置的EventEmitter来达到事件驱动的效果。 代码如下:
var events = require('events');function Model (name, id) {// 基于事件驱动的并发查询模型 var self = this; var count = 2; function roll () { // 检测查询完成处理器数 if (--count === 0) { self.emit('end'); } } dbFindA(name, function (result) { self.emit('name', result); roll(); }); dbFindB(id, function (result) { self.emit('id', result); roll(); });}Model.prototype = Object.create(events.EventEmitter.prototype); 这就是写出来的基于事件驱动的数据并发读取模型，按照设计，会有3个事件:
- "name" dbFindA查询完的时候触发
- "id" dbFindB查询完的时候触发
- "end" 所有的查询完的时候触发<br />
###那么，来测试一下这个模型是不是我们想要的:
var assert = require('assert');var results = {};var m = new Model('lili', 10);m.on('name', function (result) { results['name'] = result; assert.ok(typeof result === 'number'); assert.strictEqual(result, 4000);}).on('id', function (result) { results['id'] = result; assert.ok(typeof result === 'number'); assert.strictEqual(result, 1010);}).on('end', function () { console.log('-- results: ', results); assert.deepEqual(results, { name: 4000, id: 1010 });}); 这里会得到想到的结果。<br />
###那么实际的模型会是这样的
var events = require('events');function Model (db, userColl, articleColl, userSelector, articleSelector) {// 基于事件驱动的并发查询模型 var self = this; var count = 2; function roll () { // 检测查询完成处理器数 if (--count === 0) { self.emit('end'); } } db.collection(userColl).findOne(userSelector, function (result) { self.emit('user', result); roll(); }); db.collection(articleColl).findOne(articleSelector, function (result) { self.emit('article', result); roll(); });}Model.prototype = Object.create(events.EventEmitter.prototype);var results = {};var m = new Model(db, 'users', 'articles', { username:'lili' }, { articleID:'123456' });m.on('user', function (result) { results['user'] = result;}).on('article', function (result) { results['article'] = result;}).on('end', function () { console.log('-- results: ', results);}); <br />
编写的思想是: 先使用构造器，编写出我们想要的逻辑结构，然后暴露事件接口。在外部通过事件来控制数据和状态。