时间:2021-05-18
Node.js uses an event-driven, non-blocking I/O model that makes it lightweight and efficient.
在nodejs的官方文档中,明确写出了node的一个特性是event-driven(事件驱动),可见其非常重要。查看源码,我们可知其事件机制为用js写的EventEmitter类,写得非常优雅且应用了发布/订阅模式。
通过实现一个简易的、具有发布/订阅模式的事件机制,以此来理清EventEmitter类的实现思路
Publish/Subscribe(发布/订阅模式)
类比
要讲的是一个模式,模式这个词,听起来就很抽象。我们先举个栗子。假设有一家报纸机构,提供晨报、午报、晚报。如果你想要看某种报纸,你需要向报纸机构订阅,等对应的报纸发布出来后,报纸机构就会通知你来拿报纸。
在这个过程中,报纸机构实现了两个功能,一是接受客户的订阅;二是发布不同类型的报纸。发布报纸的时候,订阅该类型报纸的客户就能接收到通知。
这个报纸机构也就是我们要实现的事件机制。
目的
从上面的例子可以看出:1.发布报纸;2.将报纸给到客户;这个连续的过程由于报纸机构的存在,变成了可以先订阅,再发布,等到发布就自动送到客户手中,实现了动作时间上的分离。这也是发布/订阅系统的优势。
实现思路
我们有3种报纸,对应3个事件,每个事件发生时要通知客户。对应的数据格式可以如下:
由于每种报纸都可能有不止一个人订阅,那么格式可优化成这样:
当用户订阅的时候,我们就将其事件添加对应的数组中;当事件发布的时候,就执行相应事件。说白了就是先存储后使用。
具体代码如下:
1.on表示订阅,将事件添加到对应数组中
2.emit表示发布,将对应数组中的数据取出来执行
3.off表示删除无用的事件
node的EventEmitter
node的EventEmitter基本逻辑和上面提供的例子基本一样,只是更加复杂些。
1.订阅事件on
function _addListener(target, type, listener, prepend) { var m; var events; var existing; if (typeof listener !== 'function') throw new TypeError('"listener" argument must be a function'); events = target._events; ... if (typeof existing === 'function') { // Adding the second element, need to change to array. existing = events[type] = prepend ? [listener, existing] : [existing, listener]; } else { // If we've already got an array, just append. if (prepend) { existing.unshift(listener); } else { existing.push(listener); } } return target;}EventEmitter.prototype.addListener = function addListener(type, listener) { return _addListener(this, type, listener, false);};EventEmitter.prototype.on = EventEmitter.prototype.addListener;2.发布事件
讲到这里,相信大家已经明白EventEmitter的实现思路。
参考资料
node events.js
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
基于浏览器的事件轮询机制(以及Node.js中的事件轮询机制),JavaScript常常会运行在异步环境中。由于JavaScript本身语言的特性(不需要程序员
本文实例讲述了js事件机制----捕获与冒泡机制。分享给大家供大家参考,具体如下:先从事件绑定机制说起,事件绑定机制通过绑定方法addEventListener
本文实例讲述了Android基于广播事件机制实现简单定时提醒功能代码。分享给大家供大家参考,具体如下:1.Android广播事件机制Android的广播事件处理
Node.js中的事件触发器所引发的思考今天在看Node.js文档的时候讲到事件触发器,其中的emit方法让我想到了Vue中的自定义事件,借此我对Vue又有了新
前言上一篇讲了Android触摸事件的传递机制,具体可以看这里初识Android触摸事件传递机制。既然知道Android中触摸事件的传递分发,那么它能解决什么样