node.js自定义实现EventEmitter的方法是什么
本文讲解"node.js自定义实现EventEmitter的方法是什么"，希望能够解决相关问题。
一、是什么
我们了解到，Node采用了事件驱动机制，而EventEmitter就是Node实现事件驱动的基础。在EventEmitter的基础上，Node几乎所有的模块都继承了这个类，这些模块拥有了自己的事件，可以绑定／触发监听器，实现了异步操作。Node.js 里面的许多对象都会分发事件，比如 fs.readStream 对象会在文件被打开的时候触发一个事件。这些产生事件的对象都是 events.EventEmitter 的实例，这些对象有一个 eventEmitter.on() 函数，用于将一个或多个函数绑定到命名事件上。
二、nodejs中EventEmitter使用方法
Node的events模块只提供了一个EventEmitter类，这个类实现了Node异步事件驱动架构的基本模式――观察者模式
在这种模式中，被观察者(主体)维护着一组其他对象派来(注册)的观察者，有新的对象对主体感兴趣就注册观察者，不感兴趣就取消订阅，主体有更新的话就依次通知观察者们
const EventEmitter = require("events")
class MyEmitter extends EventEmitter {}
const myEmitter = new MyEmitter()
function callback() {
console.log("触发了event事件！")
}
myEmitter.on("event", callback)
myEmitter.emit("event")
myEmitter.removeListener("event", callback);三、实现过程
基本代码如下所示：
//事件派发机制
(function() {
var EventDispatcher = function() {
var EventDispatcherClosure = function() {
};
EventDispatcherClosure.prototype = {
/**
* 注册事件
* @param {Object} key
* @param {Object} fn
*/
on: function(key, fn) {
//获取当前的事件对象
var curEvents = this._getCurEvents(key);
//先检查该事件是否已经注册过了
var flag = false;
for (var i = 0, len = curEvents.length; i < len; i++) {
if (curEvents[i].name == fn.name) {
//已经出现过了,以最新注册的函数为主
flag = true;
curEvents[i] = fn;
break;
}
}
if (!flag) {
curEvents[curEvents.length] = fn;
}
this._register(key, curEvents);
},
/**
* 派发事件
* @param {Object} key
* @param {Object} data
*/
dispatch: function(key) {
//获取当前的事件对象
var curEvents = this._getCurEvents(key);
var shouldDispatch = true;
for (var i = 0, len = curEvents.length; shouldDispatch && i < len; i++) {
try {
//获取参数
var args = [];
for (var j = 1, len1 = arguments.length; j < len1; j++) {
args.push(arguments[j]);
}
shouldDispatch = curEvents[i].apply({}, args);
} catch (e) {
shouldDispatch = false;
}
}
return shouldDispatch;
},
remove: function(key) {
if (this._getCurEvents(key)) {
delete EventDispatcherClosure.events[key];
}
},
/**
* 根据key获取事件列表
* @param {Object} key
*/
_getCurEvents: function(key) {
return EventDispatcherClosure.events[key] || [];
},
/**
* 注册时间
* @param {Object} key
* @param {Object} events
*/
_register: function(key, events) {
EventDispatcherClosure.events[key] = events;
},
};
EventDispatcherClosure.events = {};
return {
create: function() {
return new EventDispatcherClosure();
}
};
};
window.EventDispatcher = new EventDispatcher().create();
})();首先定义一个全局变量的匿名函数，然后将全局变量挂在window上面，这样可以让我们在开发过程中的调用。在匿名函数的原型链上面添加事件分发、事件监听、事件删除等方法。
事件分发的调用
EventDispatcher.dispatch("test", obj)事件监听
EventDispatcher.on("test", function callback(obj) {
})事件删除
EventDispatcher.on("test")代码封装的比较简单
关于 "node.js自定义实现EventEmitter的方法是什么" 就介绍到此。希望多多支持编程宝库。
Node.js怎么实现在线实时多人聊天室：本文讲解"Node.js如何实现在线实时多人聊天室"，希望能够解决相关问题。文件结构如下：前端部分：登录页面Login部分：login.html<!DOCTYPE html> < ...