浅谈发布订阅和观察者模式，聊聊两者的区别

前段时间心血来潮自己写一一个promise， PRomise刚好就是订阅发布模式，工作中开发用的mobx 整体又是观察者模式，虽然都用，但一直没去细想两者的差异，网上的区别分析看的云里雾里。结合一下 整理一篇自己的总结和最简单实现（也因为简单 所以也很好理解）做个分享同时加深自己对这两者的理解

订阅发布

1、实现思路

• arr 做订阅了的事件的缓存中心
• 通过过on把需要做的事push arr 缓存数组中
• 等待事件触发时 依次emIT执行事件

2、代码实现

interface eventHub {
      arr: ArrayFunction>
    ;
      on(fn: Function): void;
      emit(): void;
}
interface PErson {
      age: number;
      name: string;
}
let eventHub: eventHub = {
      arr: [] as ArrayFunction>
,  // 订阅  on(fn: Function) {
        this.arr.push(fn);
  }
,  //   发布  emit() {
        this.arr.foreach((fn) =>
     fn());
  }
,}
    ;
let person: Person = {
}
     as Person;
    eventHub.on(() =>
 {
//订阅的事件里判断当 person长度为2时 打印person，  if (Object.keys(person).length == 2) {
        console.LOG(person);
  }
}
    );
setTimeout(function () {
      person.age = 27;
      //发布的时候去遍历 this.arr 并执行第一次  eventHub.emit();
}
    , 10);
setTimeout(function () {
      person.name = "Zoe";
      //发布的时候去遍历 this.arr 并执行第二次  eventHub.emit();
}
    , 20);
    

3、结果

虽然发布了两次 但最终on 里的console因为外部条件只执行了一次

观察者模式

1、实现思路

与观察者模式类似，但需要分一个观察者，和被观察者

• 观察者和被观察者存在关联,(内部基于发布订阅模式)

2、代码实现

// 被观察者class Subject {
      name: string;
     //实例上定义一个name属性  @R_406_2358@e: string;
      observers: any[];
  constructor(name:string) {
        this.name = name;
        this.observers = [];
        this.state = "";
  }
  attach(o) {
        //传入观察者    this.observers.push(o);
  }
  setState(newState) {
        this.state = newState;
        this.observers.forEach((o) =>
     o.update(this));
  }
}
// 观察者class Observer {
      name: string;
  constructor(name) {
        this.name = name;
  }
  update(interviewee) {
    console.log(`${
interviewee.name}
 say to: ${
this.name}
 ZOE的${
interviewee.state}
    `);
  }
}
    let hr = new Subject("HR");
    let observer1 = new Observer("内推者");
    let observer2 = new Observer("面试者");
    hr.attach(observer1);
    hr.attach(observer2);
    hr.setState("面试通过了");
    // baby.setState("面试没通过");
    

3、实现结果

两者的区别

eventHub 发布订阅

• on(订阅)和发布(emit)之间没有直接联系,是依赖中间的arr 做衔接 订阅一个push 到arr一个，emit的时候依次执行arr

观察者模式

• 观察者和被观察者存在关联,(内部基于发布订阅模式)
• 将观察者的实例作参数 传入被观察者的attach方法中 并缓存在observers 数组中
• 当观察者setState时候 依次调用缓存数组observers 中观察者的update方法

更多编程相关知识，请访问：编程视频！！

以上就是浅谈发布订阅和观察者模式，聊聊两者的区别的详细内容，更多请关注其它相关文章！

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！