简化理解：发布订阅

// 发布者 Publisher
class Pub {
    constructor() {
        this.deps = [];
    }
    addDep(dep) {
        this.deps.push(dep);
    }
    publish(dep) {
        this.deps.forEach(item => item === dep && item.notify());
    }
}
// 订阅者 Subscriber
class Sub {
    constructor(val) {
        this.val = val;
    }
    update(callback) {
        callback(this.val)
    }
}
// 调度中心
class Dep {
    constructor(callback) { // 核心是这个 callback 函数；
        this.subs = [];
        this.callback = callback;
    }
    addSub(sub) {
        this.subs.push(sub);
    }
    notify() {
        this.subs.forEach(item => item.update(this.callback));
    }
}
let pub = new Pub() // 实例化一个发布者
// 实例化一个调度中心，传入一个用于处理数据的函数；
const dep1 = new Dep((data) =>
              console.log('我是调度中心，我先把消息处理一下，然后发给 ===》》》', data)) 
let sub1 = new Sub("订阅者1") // 实例化订阅者1
let sub2 = new Sub("订阅者2") // 实例化订阅者2
pub.addDep(dep) // 发布者绑定调度中心
dep.addSub(sub1) // 调度中心添加订阅者1
dep.addSub(sub2) // 调度中心添加订阅者2
pub.publish(dep) // 发布者把消息推给调度者
// 我是调度中心，我先把消息处理下先 订阅者1
// 我是调度中心，我先把消息处理下先 订阅者2

function weatherWarning(weatherStatus){
  if(weatherStatus==='warning'){ // 糟糕的天气
      buildingsite.stopwork() // 工地停工
      ships.mooring()　// 船舶停航
      tourists.canceltrip() // 旅游取消
  }
}
weatherWarning("warning") // 发布坏天气通知

const EventEmit = function() { // 调度中心
  this.events = {};
  this.on = function(name, cb) { // 绑定订阅器
    if (this.events[name]) {
      this.events[name].push(cb); // 支持同一个订阅器执行多个事情
    } else {
      this.events[name] = [cb];
    }
  };
  this.trigger = function(name, ...arg) { // 发送消息
    if (this.events[name]) {
      this.events[name].forEach(eventListener => {
        eventListener(...arg);
      });
    }
  };
};

let weatherEvent = new EventEmit() // 实例化一个调度中心
weatherEvent.on('warning', function () { // 绑定发布通知的关系
  // buildingsite.stopwork()
  console.log('buildingsite.stopwork()')
})
weatherEvent.on('warning', function () { // 绑定发布通知的关系
  // ships.mooring()
  console.log('ships.mooring()')
})
weatherEvent.on('warning', function () { // 绑定发布通知的关系
  // tourists.canceltrip()
  console.log('tourists.canceltrip()')
})
weatherEvent.trigger('warning')  // 发布消息

class Subject{// 被观察者
    constructor(){
        this.observers=[]
    }
    add(observer){
        this.observers.push(observer)
    }
    notify(weatherStatus){
        this.observers.forEach(i=>i(weatherStatus))
    }
}
let sub = new Subject()
sub.add((reason)=>{
  // buildingsite.stopwork()
  console.log('工地停工，因为天气：',reason)
}) 
sub.add((reason)=>{
  // ships.stopwork()
  console.log('船舶停航，因为天气：',reason)
})
sub.add((reason)=>{
  // tourists.canceltrip()
  console.log('旅游取消，因为天气：',reason)
})
sub.notify("warning") // sub 发布消息
// 工地停工，因为天气： warning
// 船舶停航，因为天气： warning
// 旅游取消，因为天气： warning

element.addEventListener('click', function(){ 
  //... 
})