编写事件驱动模型

<br />Nodejs本身是基于事件驱动的，这个都知道。如果你看过Nodejs events模块，应该很了解Nodejs是如何驱动异步回调的。

现在有许多人对异步和异步后台多并发产生了迷惑，或借助koa，或借助async，但是代码一出来，结果是什么呢？ 我认为是维护灾难！这样的代码被扔到大量的语法糖构造起来的数组中，所有使用这个代码的人必须同意和遵守潜在的约定，才能知道这个代码是怎么串行或者并行的。

我想，这绝对不是Nodejs作者对异步设计的初衷。事件的优势是“分发”，在任何一个事件都对自己的代码有绝对的控制权。Nodejs源代码本身就提供了很好的异步事件驱动模型编码的范例。

下面，我们谈谈，最典型的例子：

并发|串行向数据库异步提取数据，然后把返回的所有数据聚合，并且作出响应。

Step I 为了模拟这个数据库操作，现在构建这么两个函数:

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 />

Step II 使用内置的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 />

Step III 测试一下这个模型是不是我们想要的：

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 (err, result) {
        self.emit('user', err, result);
        roll();
    });
    db.collection(articleColl).findOne(articleSelector, function (err, result) {
        self.emit('article', err, 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 (err, result) { 
    results['user'] = {err:err, result:result};
})
.on('article', function (err, result) {
    results['article'] = {err:err, result:result};
})
.on('end', function () {
    console.log('-- results: ', results);
});

<br />

编写的思想是:

先使用构造器，编写出我们想要的逻辑结构，然后暴露事件接口。在外部通过事件来控制数据和状态。