Node.js 的 EventEmitter 类是如何实现发布-订阅模式的？

Node.js的EventEmitter通过_events对象存储事件名与回调函数数组的映射，实现发布-订阅模式；使用on/once注册监听器，emit触发事件并同步执行回调，支持动态添加和移除监听器，是Stream、HTTP等模块的基础机制。

Node.js 的 EventEmitter 类通过维护一个事件名称与回调函数的映射关系，实现了典型的发布-订阅模式。当某个事件被触发时，所有订阅了该事件的监听函数会依次执行。

事件注册（订阅）

使用 on 或 once 方法将回调函数绑定到指定事件名上，EventEmitter 内部用对象存储这些事件名和对应的回调列表。

• emitter.on('data', callback) 表示订阅名为 'data' 的事件
• 同一个事件可以有多个监听器，它们会被存入数组中按顺序保存
• once 方法注册的监听器只执行一次，之后自动移除

事件触发（发布）

调用 emit 方法时，EventEmitter 会查找对应事件名的监听器数组，并同步执行其中每一个回调函数，传入 emit 提供的参数。

• emitter.emit('data', 'hello') 触发 'data' 事件，并把 'hello' 作为参数传递给所有监听器
• 如果没有任何监听器，emit 不会报错，只是静默执行

事件监听器管理

EventEmitter 提供了对订阅关系的动态控制能力。

自由画布

百度文库和百度网盘联合开发的AI创作工具类智能体

73

查看详情

• removeListener 可以移除某个事件的特定监听函数
• off 是 removeListener 的别名（Node.js v10+）
• removeAllListeners 清空某个事件或所有事件的监听器
• listeners(event) 查看某个事件当前的所有监听函数

底层实现机制

EventEmitter 使用一个私有的事件对象（_events）来存储事件名到监听器数组的映射。每次 on 或 emit 调用都会操作这个结构。

• 事件名通常是字符串，也可以是 Symbol
• 每个事件对应一个函数数组，保证监听器按注册顺序执行
• emit 执行是同步的，不会阻塞事件循环，但若回调中包含异步操作则需注意时序

基本上就这些。EventEmitter 的设计简洁高效，是 Node.js 中很多核心模块（如 Stream、HTTP）的基础。它不依赖外部库，原生支持松耦合的通信方式，非常适合构建可扩展的应用结构。

以上就是Node.js 的 EventEmitter 类是如何实现发布-订阅模式的？的详细内容，更多请关注php中文网其它相关文章！