本篇文章带大家了解一下Node中的事件,聊聊一下事件驱动程序和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模块varevents=require('events');//创建eventEmitter对象vareventEmitter=newevents.EventEmitter();
以下程序绑定事件处理程序:
//绑定事件及事件的处理程序eventEmitter.on('eventName',eventHandler);
我们可以通过程序触发事件:
//触发事件eventEmitter.emit('eventName');
实例
创建index.js文件,代码如下所示:
//引入fs模块varfs=require("fs");//引入events模块varevents=require('events');//创建对象varee=newevents.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模块varevents=require('events');//创建eventEmitter对象vareventEmitter=newevents.EventEmitter();
EventEmitter 对象如果在实例化时发生错误,会触发 error 事件。当添加新的监听器时,newListener 事件会触发,当监听器被移除时,removeListener 事件被触发。
下面我们用一个简单的例子说明 EventEmitter 的用法:
//event.js文件varEventEmitter=require('events').EventEmitter;varevent=newEventEmitter();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 的监听器。
$nodeevent.jssome_event事件触发
EventEmitter的每个事件由一个事件名和若干个参数组成,事件名是一个字符串,通常表达一定的语义。对于每个事件,EventEmitter支持 若干个事件监听器。
当事件触发时,注册到这个事件的事件监听器被依次调用,事件参数作为回调函数参数传递。
让我们以下面的例子解释这个过程:
//event.js文件varevents=require('events');varemitter=newevents.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参数');
执行以上代码,运行的结果如下:
$nodeevent.jslistener1arg1参数arg2参数listener2arg1参数arg2参数
以上例子中,emitter为事件someEvent注册了两个事件监听器,然后触发了someEvent事件。
运行结果中可以看到两个事件监听器回调函数被先后调用。 这就是EventEmitter最简单的用法。
EventEmitter提供了多个属性,如on和emit。on函数用于绑定事件函数,emit属性用于触发一个事件。
产品猿社区致力收录更多优质的商业产品,给服务商以及软件采购客户提供更多优质的软件产品,帮助开发者变现来实现多方共赢;
日常运营的过程中我们难免会遇到各种版权纠纷等问题,如果您在社区内发现有您的产品未经您授权而被用户提供下载或使用,您可按照我们投诉流程处理,点我投诉;
本文来自用户发布投稿,不代表产品猿立场 ;若对此文有疑问或内容有严重错误,可联系平台客服反馈;
部分产品是用户投稿,可能本文没有提供官方下下载地址或教程,若您看到的内容没有下载入口,您可以在我们产品园商城搜索看开发者是否有发布商品;若您是开发者,也诚邀您入驻商城平台发布的产品,地址:点我进入;
如若转载,请注明出处:https://www.chanpinyuan.cn/41766.html;