EventProxy的使用-解决异步回调地狱

最近在看 node 社区的 nodeclub 源码，看到一个玩意 EventProxy，这里记录一下基本语法

nodeclub 社区源码:

https://github.com/cnodejs/no…

eventproxy 工具源码：

https://github.com/JacksonTia…

EventProxy 可以理解为一个基于事件机制对复杂的业务逻辑进行解耦的工具，可以解决 javascript 异步回调地狱问题的工具。

• 利用事件机制解耦复杂业务逻辑
• 移除被广为诟病的深度 callback 嵌套问题
• 将串行等待变成并行等待，提升多异步协作场景下的执行效率
• 友好的 Error handling
• 无平台依赖，适合前后端，能用于浏览器和 Node.js
• 兼容 CMD，AMD 以及 CommonJS 模块环境

先来看一段回调嵌套的示例代码：

准备工作：三个文件 file1.txt，file2.txt, file3.txt 文件，在里面随便写点内容

var fs = require('fs');

fs.readFile('./file1.txt', 'utf8', function (err1, data1) {fs.readFile('./file2.txt', 'utf8', function (err2, data2) {fs.readFile('./file3.txt', 'utf8', function (err3, data3) {console.log(data1 + data2 + data3);
        });
    });
});

这种代码在 node 中是不是经常见？?

看着是不是有点心疼的感觉~

哈哈，看到两句有意思的话：

这个世界上不存在所谓回调函数深度嵌套的问题。

世界上本没有嵌套回调，写得人多了，也便有了 }}}}}}}}}}}}。

正题：

安装 eventproxy

npm install eventproxy

使用

var EventProxy = require('eventproxy');

var ep = new EventProxy();

常用方法分为两部分：

• 解决回调的方法：

  • emit()
  • after()
  • all()

• 优化代码的方法：

  • done()
  • throw()
  • fail()

emit() 方法、all() 方法

var fs = require('fs');
var EventProxy = require('eventproxy');

var ep = new EventProxy();

// all() 方法用于指定接收哪几种事件，并在回调函数中进行统一处理，回调函数可以接收事件中携带的参数，参数位置与事件位置一一对应
ep.all(['read_file1', 'read_file2', 'read_file3'], function (data1, data2, data3) {console.log(data1 + data2 + data3);
});

fs.readFile('/file1.txt', 'utf8', function (err, data) {
    // 使用 emit 抛出一个事件 read_file1
    ep.emit('read_file1', data);
});

fs.readFile('/file2.txt', 'utf8', function (err, data) {
    // 使用 emit 抛出一个事件 read_file2
    ep.emit('read_file2', data);
});

fs.readFile('/file3.txt', 'utf8', function (err, data) {
    // 使用 emit 抛出一个事件 read_file3
    ep.emit('read_file3', data);
});

上面的例子，我们使用 emit() 方法抛出了三个不同的事件，然后使用 all() 方法统一接收处理

但是类似这样的例子，其实我们可以抛出三个相同的事件，看下面的例子

emit() 方法、after() 方法

var fs = require('fs');
var EventProxy = require('eventproxy');

var ep = new EventProxy();

// after() 接收一个事件集，对相同事件进行处理，接收三个参数：// 第一个参数：事件名
// 第二个参数：接收这个事件几次
// 第三个参数：接收这个事件传递过来的数据的数组
ep.after('read_file', 3, function (results) {
    var s = '';
    for (let data of result) {s += data;}
    console.log(s);
});

// 抛出同一事件 read_file
fs.readFile('/file1.txt', 'utf8', function (err, data) {ep.emit('read_file', data);
});

fs.readFile('/file2.txt', 'utf8', function (err, data) {ep.emit('read_file', data);
});

fs.readFile('/file3.txt', 'utf8', function (err, data) {ep.emit('read_file', data);
});

fail() 方法

var fs = require('fs');
var EventProxy = require('eventproxy');

var ep = new EventProxy();

// fail() 方法接收 error 事件，使用回调函数接收 error 事件携带的参数
ep.fail(function (err) {console.log(err);
});

// 不存在 file4.txt 文件
fs.readFile('/file4.txt', 'utf8', function (err, data) {if (err) {ep.emit('error', err);
    }
});

throw() 方法

var fs = require('fs');
var EventProxy = require('eventproxy');

var ep = new EventProxy();

// fail() 方法接收 error 事件，使用回调函数接收 error 事件携带的参数
ep.fail(function (err) {console.log(err);
});

// 不存在 file4.txt 文件，可以使用 throw() 方法抛出错误事件
fs.readFile('/file4.txt', 'utf8', function (err, data) {if (err) {ep.throw(err);
    }
});

done() 方法

// 接收一个事件集，这个实例中只有一个事件，但是回调中接收的参数还是数组
ep.after('read_file', 1, function (results) {});

// done() 方法时下面注释掉的代码中回调方法的简写
// done() 方法其实就是一个语法糖，背后逻辑就是抛出一个事件，并把回调的 data 数据携带
fs.readFile('/file1.txt', 'utf8', ep.done('read_file'));

/*
fs.readFile('/file1.txt', 'utf8', function (err, data) {ep.emit('read_file', data);
});
*/

done() 方法还可以指定抛出, 可以对数据进行处理

fs.readFile('/file1.txt', 'utf8', ep.done('read_file', function (data) {console.log(data + 'xxoo');
}));

原文链接：http://www.mi360.cn/articles/37

更多文章：
Node 构建 TCP 服务
lodash 库常用方法