3. //发布订阅模式  主要分成两个部分 on emit
    4. //on 就是把一些函数维护到一个数组中
    5. //emit 让数组中的函数依次执行
    7. let fs = require('fs');
    9. // 订阅和发布没有明显的关系 靠数组做中介
    10. let event = {
    11.     arr:[],
    12.     on(fn){
    13.         this.arr.push(fn)
    14.     },
    15.     emit(data){
    16.         this.arr.forEach(fn=>fn(data))
    17.     }
    18. }
    20. let obj = {}
    21. event.on(function(data){
    22.     obj = {...obj,...data}; 
    23.     if(Object.keys(obj).length === 2){
    24.         console.log('读取完毕: ', obj);
    25.     }
    26. })
    28. fs.readFile('./name.txt','utf8',function(err,data){
    29.     event.emit({name:data})
    30. })
    31. fs.readFile('./age.txt','utf8',function(err,data){
    32.     event.emit({age:data})
    34. })
    1. //观察者模式  有观察者 肯定有被观察者
    2. // 观察者需要放到被观察者中 被观察者状态发生变化 需要通知观察者 
    3. // 内部也是基于发布订阅模式 收集观察者 状态变化后 通知观察者
    7. class Observer{ //
    8.     constructor(){
    9.         this.state = '开心'
    10.         this.observers = [];
    11.     }
    12.     attach(o){
    13.         this.observers.push(o)
    14.     }
    15.     setState(newState){
    16.         this.state = newState;
    17.         this.observers.forEach(o=>o.update(this))
    18.     }
    20. }
    21. class Subject{ // 观察者
    22.     constructor(name){
    23.         this.name = name;
    24.     }
    25.     update(baby){
    26.         console.log('当前' + this.name + '被通知了，当前小宝宝现在的状态是' + baby.state)
    27.     }
    28. }
    30. let baby = new Observer('小宝宝')
    32. let parent = new Subject('爸爸');
    33. let mother = new Subject('妈妈');
    34. baby.attach(parent);
    35. baby.attach(mother);
    36. baby.setState('哭了')