理解發(fā)布/訂閱

異步編程方法

1.回調(diào)函數(shù)
2.事件發(fā)布/訂閱
3.Promise
4.generator函數(shù)
5.async函數(shù)

//回調(diào)地獄
function ajax(url, callback){
 //實(shí)現(xiàn)省略
}

ajax('./test1.json',function(data){
 console.log(data);
 ajax('./test2.json',function(data){
   console.log(data);
   ajax('./test3.json',function(data){
     console.log(data);
   });
 });

//發(fā)布/訂閱
const pbb = new PubSub();
ajax("./test1.json",function(data){
 pbb.publish("test1Success",data);
});
pbb.subscribe("test1Success",function(data){
 console.log(data);
 ajax("./test2.json",function(data){
   pbb.publish("test2Success",data);
 });
});
pbb.subscribe("test2Success",function(data){
 console.log(data);
 ajax("./test3.json",function(data){
   pbb.publish("test3Success",data);
 });
});
pbb.subscribe("test2Success",function(data){
 console.log(data);
});

實(shí)現(xiàn)發(fā)布/訂閱

class PubSub{
  constructor(){
    this.events = {};
  }
  publish(eventName,data){
    if(this.events[eventsName]){
      this.events[eventName].forEach(cb => {
        cb.apply(this.data)
      });
    }
  }

  subscribe(eventName, callback){
    if(this.events[eventName]){
      this.events[eventName].push(callback);
    }else{
      this.events[eventName] = [callback];
    }
  }

  unSubcribe(eventName,callback){
    if(this.events[eventName]){
      this.events[eventName] = this.events[eventName].filter(
        cb => cb !== callback
      );
    }
  }
}

Node.js的發(fā)布/訂閱

});