使用events.EventEmitter 控制Node.js 程序执行流程

Posted Winter boy

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用events.EventEmitter 控制Node.js 程序执行流程相关的知识,希望对你有一定的参考价值。

使用events.EventEmitter 控制Node.js 程序执行流程

标题写的可能也不太对,大家领会精神;

Node.js 是一个基于Chrome javascript 运行时建立的一个平台。

Node.js是一个事件驱动I/O服务端JavaScript环境,基于Google的V8引擎,V8引擎执行Javascript的速度非常快,性能非常好。

 

Node.js 异步编程的直接体现就是回调。

异步编程依托于回调来实现,但不能说使用了回调后程序就异步化了。

回调函数在完成任务后就会被调用,Node 使用了大量的回调函数,Node 所有 API 都支持回调函数。

例如,我们可以一边读取文件,一边执行其他命令,在文件读取完成后,我们将文件内容作为回调函数的参数返回。

这样在执行代码时就没有阻塞或等待文件 I/O 操作。这就大大提高了 Node.js 的性能,可以处理大量的并发请求。

 

Node.js 是单进程单线程应用程序,但是因为 V8 引擎提供的异步执行回调接口,通过这些接口可以处理大量的并发,所以性能非常高。

Node.js 几乎每一个 API 都是支持回调函数的。

Node.js 基本上所有的事件机制都是用设计模式中观察者模式实现。

Node.js 单线程类似进入一个while(true)的事件循环,直到没有事件观察者退出,每个异步事件都生成一个事件观察者,如果有事件发生就调用该回调函数。

大意就是说:与大多数 代码从上至下线性执行的 程序不同,Node.js 程序不会“等”,

当程序执行到需要I/O执行时间的回调函数时,会主动略过等待,继续执行下面的代码;

因此就会出现一种弊端:一个特定函数的输入(参数),是数个回调函数的返回;

程序的执行机制会略过 对回调函数的等待,直接执行下面的特定函数;此时特定函数并没有等到回调函数返回的输入;

例子如下:

var fs = require("fs");
var array = [1, 2, 3, 4, 5]; var json = {};
for (let index = 0; index < array.length; index++) { const element = array[index]; deal(element, function (ret) { json[element] = ret; console.log(json); }); } console.log(json); function deal(num, callback) { fs.readFile(num + ‘.txt‘, function (err, data) { if (err) { console.error(err); callback(err); } else { callback(data.toString().trim()); } }); } Object {} Object {1: "11111"} Object {1: "11111", 5: "55555"} Object {1: "11111", 3: "33333", 5: "55555"} Object {1: "11111", 3: "33333", 4: "44444", 5: "55555"} Object {1: "11111", 2: "22222", 3: "33333", 4: "44444", 5: "55555"}

回调函数要以数组里的内容作为文件名,读取文件中的数据作为返回值;

但程序不会等待文件读取完成,在没有一个文件读取完毕的情况下就执行了打印操作,输出了空对象;

如果想要按顺序线性执行文件读取,在读取完毕后打印输出,不仅浪费时间,而且一层套一层代码冗余,

还无法预估数组大小(回调函数个数)。

Node.js 所有的异步 I/O 操作在完成时都会发送一个事件到事件队列。

解决的办法是:Node.js 的事件驱动特性,让打印作为一个事件,在所有的回调函数执行完后,再触发打印操作;

var fs = require("fs");
var events = require(‘events‘); 
var emitter = new events.EventEmitter(); 

var array = [1, 2, 3, 4, 5];
var count = 0;
var json = {};

for (let index = 0; index < array.length; index++) {
    const element = array[index];
    deal(element, function (ret) {
        json[element] = ret;
        console.log(json);
    });
}

emitter.on(‘dataBack‘, function() { 
    count ++;
    if(count == array.length){
        console.log(json);
    }
}); 

function deal(num, callback) {
    fs.readFile(num + ‘.txt‘, function (err, data) {
        if (err) {
            console.error(err);
            callback(err);
            emitter.emit(‘dataBack‘); 
        } else {
            callback(data.toString().trim());
            emitter.emit(‘dataBack‘); 
        }
    });
}


Object {1: "11111"}
Object {1: "11111", 4: "44444"}
Object {1: "11111", 3: "33333", 4: "44444"}
Object {1: "11111", 3: "33333", 4: "44444", 5: "55555"}
Object {1: "11111", 2: "22222", 3: "33333", 4: "44444", 5: "55555"}
Object {1: "11111", 2: "22222", 3: "33333", 4: "44444", 5: "55555"}

在程序中添加打印事件和事件触发,全部数据都集齐后再打印,

虽然还有count的锁不锁的问题存在,但实际的问题已然解决;

嗯嗯。

 

引用和改写的程序都来源于 Node.js 教程 | 菜鸟教程

Node.js 文件系统 | 菜鸟教程

Node.js EventEmitter | 菜鸟教程

 

 

                                                                                                                                                                                            J.X.Duasonir



以上是关于使用events.EventEmitter 控制Node.js 程序执行流程的主要内容,如果未能解决你的问题,请参考以下文章

node概念笔记之eventemitter

11.事件驱动events

node模块之events模块

nodejs events

Node.js EventEmitter

Node.js EventEmitter