Events模块用来做什么,如何弄明白EventEmitter对象
Admin 2022-08-16 群英技术资讯 1003 次浏览
这篇文章主要介绍了Events模块用来做什么,如何弄明白EventEmitter对象相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Events模块用来做什么,如何弄明白EventEmitter对象文章都会有所收获,下面我们一起来看看吧。Events是Node中的一个很重要的核心模块,Stream, 网络,文件系统统统都是继承自这个模块。
Streams模块就是继承自EventEmitter,所以说弄明白Events模块,特别是EventEmitter对象, 对于理解Node中的很多模块都是有好处的。
Stream非常擅长处理数据,无论是读,写或者是转换。比如,你可以用Stream接收数据库中的数据,将其流出到csv的流中,导出成为csv格式。
接着你可以再传入一个http请求(也是一种流)将数据再流入到http流中,这样就可以直接将数据显示在浏览器中。
或者你可以将数据流入到一个可写的文件流中,通过创建文件将文件发送给浏览器。
除了Node自身的核心模块,很多第三方开源项目也都是基于EventEmitter构建的。如 Express, Connect, RedisClient
通常来说,我们都希望自定义类能够实现EventEmitter类提供的基本功能。
于是我们可以使用util模块提供的util.inherits()方法来实现原型链上的继承。
而EventEmitter类提供了on() 和 emit() 方法用于绑定事件和触发事件。
也可以使用removeListener() 方法来删除监听器,但是需要注意,和定时器一样,你需要将监听器保存在某个函数变量中。
同样,可以使用 once() 方法来绑定只执行一次的监听事件。
// musicPlayer.js // 通过继承EventEmitter来实现一个基于事件的音乐播放器 var util = require("util"); var events = require("events"); function MusicPlayer(){ this.playing = false; events.EventEmitter.call(this); } util.inherits(MusicPlayer, events.EventEmitter); var audioDevice = { play: function(track){ console.log("play in ", track); }, stop: function(){ console.log("stop play"); } }; // 实例化播放器类 var myMusicPlayer = new MusicPlayer(); myMusicPlayer.on('play', function() { this.playing = true; }); myMusicPlayer.on('stop', function() { this.playing = false; audioDevice.stop(); }); myMusicPlayer.once('play', function(){ console.log("begin play"); }); myMusicPlayer.on('play', function(track) { audioDevice.play(track); }); myMusicPlayer.emit("play", "The roots - the fire"); setTimeout(function(){ myMusicPlayer.emit("stop"); setTimeout(function(){ myMusicPlayer.emit("play", "Country Road"); }, 3000); }, 2000);
混合EventEmitter类
有些时候你使用的类是别人提供给你的类,这个时候不能简单的将其继承自EventEmitter类。那么可以通过for ... in 循环将一个原型对象上的属性拷贝到另外一个原型对象上。
前面那个音乐播放器类可以升级为
// musicPlayer 音乐播放器类升级版 var EventEmitter = require("events").EventEmitter; function MusicPlayer(track){ this.track = track; this.playing = false; for(var method in EventEmitter.prototype){ this[method] = EventEmitter.prototype[method]; } } MusicPlayer.prototype.toString = function(){ if(this.playing){ return "Now playing: " + this.track; }else{ return "Stopped"; } }; var myMusicPlayer = new MusicPlayer("Girl Talk - Still Here"); myMusicPlayer.on('play', function() { this.playing = true; console.log(this.toString()); }); myMusicPlayer.on("stop", function(){ this.playing = false; console.log(this.toString()); }); myMusicPlayer.emit("play"); setTimeout(function(){ myMusicPlayer.emit("stop"); },3000);
在Node中,error事件被当做特殊情况。如果没有针对error的监听器,那么一旦发生错误,则系统将会按照默认的方式进行处理,即打印一个堆栈并且退出程序。
建议使用 on() 方法来监听 error 事件。上面这种是常用的处理异常的一种方式,其实到这一步,就可以了。
但是如果想了解更多如何集中处理多个异常操作,特别是当你正在执行多个非阻塞IO操作时,如何有效处理异常则是需要认真学习的地方。这里需要使用到node的核心模块 domain
domain接口提供了用异常处理封装已有的非阻塞API以及错误的方法。能够帮助我们集中处理所有的异常,特别是有多个相互依赖的IO操作时非常有用。
domain模块使用create() 方法创建实例,给实例绑定一个error事件监听器,于是在实例的run 方法中运行回调函数导致的error都会被domain覆盖。
根据最新Node官方文档,一旦有新的可替代方案出现,domain模块就会被彻底废弃。所以第二种方法就不介绍了。
Node的events模块提供了一个 newListener 事件,用于跟踪监听器何时被添加,而监听这个事件的监听器函数会接收到事件名称和事件处理程序(监听器的方法)
也就是说当你通过 on() 方法添加事件监听器时就会触发 newListener 事件。在这个回调函数中,新注册的同名事件都会被插入到同名事件监听器队列的前面。
eventEmitter.on("newListener", function(eventName, function){ });
EventEmitter实例的 listeners(eventName) 方法会返回指定事件名称的监听器数组的副本,通过 length属性检查当前监听器的数量。
接下来说到一个小技巧: 如何管理模块中众多的事件名,而不会出现混乱。
解决方案就是给你的模块定义一个events对象专门用来存放事件名。
虽然EventEmitter模块很重要,并且很多开源项目都是基于EventEmitter开发的。但是,并不能说EventEmitter就是完美的。所以就出现了替代品。如 AMQP, ZeroMQ, js-signals, Redis等等
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
猜你喜欢
这篇文章主要介绍了JavaScript中的语法和代码结构,对JS初学者而言,这些基础一定要看一下
Typescript中extends关键字的基本使用 目录 前言 基本使用 泛型约束 条件类型与高阶类型 在高级类型中的应用 参考文献 总结 前言 extends关键字在TS编程中出现的频率挺高的,而且不同场景下代表的含义不一样,特此总结一下
使用JavaScript实现随机颜色生成器 目录 项目基本结构 1.颜色生成器的基本结构 2.使用 HTML 添加标题 3.创建用于颜色查看的显示器 4.创建一个框以查看颜色代码 5.创建生成器和复制按钮 6.使用 JavaScript 激活随机颜色生成器 完整源码下载 在线演示地址 项目基本结构 目录结构如下: 1.颜色生成器的基本结构 我使用了以下的 HTML 和 CSS 代码创建了这个颜色生成器的基本结构.在添加所有信息的页面上创建了一个小框,框的背景颜色为白色. <div class="container" ...
1、什么时候该用buffer,什么时候不该用看一下如下的测试代码,分别是拼接各种不同长度的字符串,最后直接拼接了10MB的字符串varstring,string2,string3;varbufstr,bufstr2,bufstr3;varj;console.time('write1000string');for(j=0;j<1000;j++){varx=j
这篇文章主要给大家分享react中不可变值,对大家学习什么是不可变值和理解为何要用不可变值有一定的帮助,感兴趣的朋友可以参考一下,希望大家阅读完这篇文章能有所收获,下面我们一起来学习一下吧。
成为群英会员,开启智能安全云计算之旅
立即注册Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2020 群英 版权所有
增值电信经营许可证 : B1.B2-20140078 粤ICP备09006778号 域名注册商资质 粤 D3.1-20240008