EventProxy的使用 - 解决异步回调地狱
最近在看node社区的nodeclub源码，看到一个玩意EventProxy，这里记录一下基本语法
nodeclub社区源码:https://github.com/cnodejs/
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
本文内容仅供个人学习、研究或参考使用，不构成任何形式的决策建议、专业指导或法律依据。未经授权，禁止任何单位或个人以商业售卖、虚假宣传、侵权传播等非学习研究目的使用本文内容。如需分享或转载，请保留原文来源信息，不得篡改、删减内容或侵犯相关权益。感谢您的理解与支持！
