EventProxy流程控制
EventProxy是一个通过控制事件触发顺序来控制业务流程的工具。
1. 利用事件机制解耦复杂业务逻辑
2. 移除被广为诟病的深度callback嵌套问题
3. 将串行等待变成并行等待,提升多异步协作场景下的执行效率
4. 友好的Error handling
node.js的亮点是回调函数,node.js流程控制、传参都是通过回调函数来实现的。开发中经常会遇到回调嵌套的场景,尤其是在业务复杂的场景下,会嵌套n层回调函数,这样做的原因是为了控制代码执行的流程。
下面是一个需要同步读取文件的例子
var str = ''; fs.readFile('file1.txt', function(err, data1) { str += data1; fs.readFile('file2.txt', function(err, data2) { str += data2; fs.readFile('file3.txt', function(err, data3) { str += data3; }); }); });
上面代码有3层回调嵌套,用嵌套来保障文件的顺序读取。这样代码可读性就比较差了,而开发中用到的嵌套往往有很多层,代码很难读。
我们用EventProxy来解耦
安装:npm install eventproxy
引包:var EventProxy = require('eventproxy');
var ep = new EventProxy();
1、异步协作 all
多个操作并行执行,每个操作完成后触发一个自定义事件.ep.all监听所有操作触发的事件,然后在回调函数里面提供各事件提供的结果
ep.all('read1', 'read2', 'read3', function(data1, data2, data3) { //监听事件,所有事件都触发完成后,在这里汇总结果 console.info(data1 + '~' + data2 + '~' + data3); }); fs.readFile('file1.txt', function(err, data1) { ep.emit('read1', data1);//触发事件 }); fs.readFile('file2.txt', function(err, data2) { ep.emit('read2', data2);//触发事件 }); fs.readFile('file3.txt', function(err, data3) { ep.emit('read3', data3);//触发事件 });
2、重复异步协作 after
`after`方法适合重复的操作,比如读取10个文件,调用5次数据库等。将handler注册到N次相同事件的触发上。达到指定的触发数,handler将会被调用执行,每次触发的数据,将会按触发顺序,存为数组作为参数传入。
var files = ['file1.txt', 'file2.txt', 'file3.txt']; ep.after('readfile', files.length, function(list) { // 在所有文件的异步执行结束后将被执行 // 所有文件的内容都存在list数组中 //list中值是无序的,因为for循环中ep.emit触发顺序是无序的(node异步特点),排列顺序取决于node事件触发的顺序。可以通过group来控制对应关系,后续讲。 }); for (var i = 0; i < files.length; i++) { fs.readFile(files[i], function(err, data) { // 触发结果事件 ep.emit('readfile', data); }); }
注意:如果ep.emit('你的事件名称') 的次数没有达到after中次数(第二个参数),是无法触发after的回调函数的,这里一定要注意!
参考:https://blog.csdn.net/shmnh/article/details/43866677