JavaScript实现发布订阅模式_javascript设计模式_技术教程

发布订阅模式通过事件中心实现组件间解耦，支持on、emit、off和once方法，适用于跨组件通信与异步通知，需注意及时取消订阅以避免内存泄漏。

发布订阅模式是一种在JavaScript中广泛使用的通信机制，特别适用于解耦组件或模块之间的依赖关系。它允许对象（称为“订阅者”）监听某个事件（由“发布者”触发），而无需彼此直接引用。这种模式在前端开发中常用于状态管理、事件总线、跨组件通信等场景。

基本概念

发布订阅模式包含三个核心角色：

事件中心（Event Bus）：负责维护事件列表，提供订阅、取消订阅和触发事件的接口。
发布者（Publisher）强>：当某个事件发生时，向事件中心发送通知。
订阅者（Subscriber）：提前注册对某个事件的兴趣，并提供回调函数处理该事件。

简单实现一个事件中心

我们可以用一个简单的JavaScript类来实现发布订阅模式：

class EventEmitter {
  constructor() {
    // 存储事件及其对应的回调函数数组
    this.events = {};
  }

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

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

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

  // 只监听一次
  once(event, callback) {
    const wrapper = (data) => {
      callback(data);
      this.off(event, wrapper);
    };
    this.on(event, wrapper);
  }
}

使用示例

下面是一个实际使用该事件中心的例子：

// 创建事件中心实例
const eventBus = new EventEmitter();

// 订阅用户登录事件
eventBus.on('userLogin', (user) => {
  console.log(`欢迎 ${user.name} 登录系统`);
});

eventBus.on('userLogin', (user) => {
  console.log(`当前用户ID: ${user.id}`);
});

// 某处触发登录事件
eventBus.emit('userLogin', { id: 1, name: 'Alice' });

// 输出：
// 欢迎 Alice 登录系统
// 当前用户ID: 1

也可以使用 once 方法监听只执行一次的事件：

eventBus.once('appInitialized', () => {
  console.log('应用初始化完成，仅提示一次');
});

eventBus.emit('appInitialized'); // 触发一次
eventBus.emit('appInitialized'); // 不再响应