当前位置：首页 > 文章列表 > 文章 > 前端 > JavaScript发布订阅模式实现全解析

JavaScript发布订阅模式实现全解析

2026-04-13 13:44:30 0浏览收藏

本文深入解析了JavaScript中发布-订阅模式的完整实现原理与实战应用，通过手写一个功能完备的EventEmitter类（支持on、off、emit及once等核心方法），清晰展示了如何借助事件中心实现对象间的松耦合通信；结合具体代码示例和常见业务场景（如组件通信、状态响应、模块解耦、异步通知等），不仅让读者掌握底层机制，更能即学即用，快速构建灵活、可维护的事件驱动架构。

在JavaScript中，如何实现一个完整的发布-订阅模式？

发布-订阅模式（Pub-Sub）是一种对象间解耦的通信机制，一个对象（发布者）不直接调用另一个对象（订阅者）的方法，而是通过一个事件通道来通知所有监听该事件的订阅者。在JavaScript中，可以通过创建一个事件中心来实现完整的发布-订阅模式。

1. 实现事件中心类

定义一个 EventEmitter 类，提供 on（订阅）、off（取消订阅）、emit（发布）三个核心方法。

class EventEmitter {
  constructor() {
    this.events = {};
  }

  // 订阅事件
  on(event, callback) {
    if (!this.events[event]) {
      this.events[event] = [];
    }
    this.events[event].push(callback);
  }

  // 取消订阅
  off(event, callback) {
    if (!this.events[event]) return;
    this.events[event] = this.events[event].filter(cb => cb !== callback);
  }

  // 发布事件
  emit(event, ...args) {
    if (!this.events[event]) return;
    this.events[event].forEach(callback => callback(...args));
  }
}

2. 使用示例

创建实例并使用订阅与发布功能。

const eventBus = new EventEmitter();

// 订阅 'userLogin' 事件
const loginHandler = (username) => {
console.log('用户已登录：', username);
};
eventBus.on('userLogin', loginHandler);

// 再订阅一个处理函数
eventBus.on('userLogin', (username) => {
console.log('发送欢迎消息给：', username);
});

// 触发事件（发布）
eventBus.emit('userLogin', 'Alice');
// 输出：
// 用户已登录： Alice
// 发送欢迎消息给： Alice

3. 支持只触发一次的事件（once）

可以扩展添加 once 方法，用于绑定只执行一次的监听器。

once(event, callback) {
  const onceWrapper = (...args) => {
    callback.apply(this, args);
    this.off(event, onceWrapper);
  };
  this.on(event, onceWrapper);
}

这样可以在事件第一次被触发后自动移除监听，适用于初始化完成、资源加载等场景。