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

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));
  }
}

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

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