Node.js 自定义实现 EventEmitter 的原理与代码封装
本文详解 Node.js 中 EventEmitter 的事件驱动机制与观察者模式原理，并提供从零开始自定义封装 EventEmitter 的完整代码实现。通过解析事件注册、触发与移除的核心逻辑，帮助开发者理解异步操作背后的机制，并掌握如何在项目中手动封装事件派发函数以减少外部依赖。
前言
近期在处理商品批发业务需求时，系统需根据特定商户筛选并回显对应的批发商品至原界面。鉴于该项目代码库年代久远，属于公司遗留的老系统，开发人员在排查和修复问题时往往如履薄冰，稍有不慎便可能引发连锁反应。为了降低对现有复杂代码的依赖并减少潜在风险，决定手动封装一套轻量级的事件派发函数，以替代部分外部依赖。
一、是什么
Node.js 的核心架构基于事件驱动机制，而 EventEmitter 正是实现这一机制的基石。在 Node.js 生态中，绝大多数内置模块都继承自 EventEmitter 类，从而具备了独立的事件处理能力。通过绑定和触发监听器，这些模块能够高效地处理异步操作。例如，fs 模块中的 readStream 对象在文件打开时会触发特定事件。所有这类产生事件的对象均为 events.EventEmitter 的实例，它们通过 eventEmitter.on() 方法将一个或多个回调函数绑定到指定的命名事件上。
二、nodejs中EventEmitter使用方法
Node.js 的 events 模块仅提供了 EventEmitter 这一个类，它实现了 Node.js 异步事件驱动架构的基本模式——观察者模式。在该模式下，被观察的主体（EventEmitter 实例）维护着一组由其他对象注册进来的观察者列表。当有新对象对主体的状态变化感兴趣时，便注册为观察者；若不再关注，则取消订阅。一旦主体状态发生更新，便会依次通知所有已注册的观察者执行相应的回调逻辑。
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实现EventEmitter内容请搜索本站以前的文章或继续浏览下面的相关文章希望大家以后多多支持本站！
Node.js 安装配置与第一个 HTTP 服务器编写
2026-11-05 11:41:40
怎么使用 nvm 管理并平滑升级 Node.js 版本
2026-11-04 23:15:07
Node.js 怎么使用 zlib 模块解压 gzip 和 deflate
2026-11-03 23:40:50
直接覆盖安装还是用版本管理器？Node.js 升级方式对比
2026-11-03 22:59:07
Express.js 是什么：Node.js Web 框架核心概念与适用场景
2026-11-03 20:00:12