聊聊Node.js中的事件驱动程序和EventEmitter类

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

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

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

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

事件驱动程序

Node.js 使用事件驱动模型，当web server接收到请求，就把它关闭然后进行处理，然后去服务下一个web请求。

当这个请求完成，它被放回处理队列，当到达队列开头，这个结果被返回给用户。

这个模型非常高效可扩展性非常强，因为 webserver 一直接受请求而不等待任何读写操作。（这也称之为非阻塞式IO或者事件驱动IO）

在事件驱动模型中，会生成一个主循环来监听事件，当检测到事件时触发回调函数。

Node.js 有多个内置的事件，我们可以通过引入 events 模块，并通过实例化 EventEmitter 类来绑定和监听事件，如下实例：

// 引入 events 模块VAR events = require('events');
    // 创建 eventEmitter 对象var eventEmitter = new events.EventEmitter();
    

以下程序绑定事件处理程序：

// 绑定事件及事件的处理程序eventEmitter.on('eventName', eventHandler);
    

我们可以通过程序触发事件：

// 触发事件eventEmitter.emit('eventName');
    

实例

创建 index.js 文件，代码如下所示：

//引入 fs 模块var fs = require("fs");
    // 引入 events 模块var events = require('events');
    // 创建对象var ee = new events.EventEmitter();
// 绑定事件及事件的处理程序ee.on('res', function (data) {
        console.LOG('res-1');
        console.log(data);
}
    );
ee.on('res', function () {
        console.log('res-2');
}
    );
fs.reaDFile('hello.txt',{
flag:'r',encoding:'utf-8'}
,function(err,data){
    if(err){
            console.log("读取出错:"+err);
    }
else{
            console.log("读取成功:"+data);
            // 触发res事件        ee.emit('res',data);
    }
}
    )

接下来让我们执行以上代码：

EventEmitter 类

events 模块只提供了一个对象： events.EventEmitter。EventEmitter 的核心就是事件触发与事件监听器功能的封装。

你可以通过require("events"); 来访问该模块。

// 引入 events 模块var events = require('events');
    // 创建 eventEmitter 对象var eventEmitter = new events.EventEmitter();
    

EventEmitter 对象如果在实例化时发生错误，会触发 error 事件。当添加新的监听器时，newListener 事件会触发，当监听器被移除时，removeListener 事件被触发。

下面我们用一个简单的例子说明 EventEmitter 的用法：

//event.js 文件var EventEmitter = require('events').EventEmitter;
     var event = new EventEmitter();
 event.on('some_event', function() {
         console.log('some_event 事件触发');
 }
    );
 setTimeout(function() {
         event.emit('some_event');
 }
    , 1000);
    

执行结果如下：

运行这段代码，1 秒后控制台输出了 'some_event 事件触发' 。其原理是 event 对象注册了事件 some_event 的一个监听器，然后我们通过 setTimeout 在 1000 毫秒以后向 event 对象发送事件 some_event，此时会调用some_event 的监听器。

$ node event.js some_event 事件触发

EventEmitter 的每个事件由一个事件名和若干个参数组成，事件名是一个字符串，通常表达一定的语义。对于每个事件，EventEmitter 支持 若干个事件监听器。

当事件触发时，注册到这个事件的事件监听器被依次调用，事件参数作为回调函数参数传递。

让我们以下面的例子解释这个过程：

//event.js 文件var events = require('events');
     var emitter = new events.EventEmitter();
 emitter.on('someEvent', function(arg1, arg2) {
         console.log('listener1', arg1, arg2);
 }
    );
 emitter.on('someEvent', function(arg1, arg2) {
         console.log('listener2', arg1, arg2);
 }
    );
     emitter.emit('someEvent', 'arg1 参数', 'arg2 参数');
    

执行以上代码，运行的结果如下：

$ node event.js listener1 arg1 参数 arg2 参数listener2 arg1 参数 arg2 参数

以上例子中，emitter 为事件 someEvent 注册了两个事件监听器，然后触发了 someEvent 事件。

运行结果中可以看到两个事件监听器回调函数被先后调用。 这就是EventEmitter最简单的用法。

EventEmitter 提供了多个属性，如 on 和 emit。on 函数用于绑定事件函数，emit 属性用于触发一个事件。

更多node相关知识，请访问：nodejs 教程！！

以上就是聊聊Node.js中的事件驱动程序和EventEmitter类的详细内容，更多请关注其它相关文章！

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！