理解并实现你自己的订阅-发布模式

订阅发布模式：
这是一种广泛应用于异步编程的模式，是回调函数的事件化，常常用来解耦业务逻辑。事件的发布者无需关注订阅的侦听器如何实现业务逻辑，甚至不用关注有多少个侦听器存在。数据通过消息的方式可以灵活的传递。 ——《深入浅出Nodejs》
由于浏览器js单线程的原因，编写js代码经常会用到异步，回调函数，业内解决异步比较流行的方式订阅发布模式、 promise 、async/await 。
例如 promise 我们都是在then 函数中传入回调函数，传入之后发生了什么。。。为什么回调没有立即执行而是等状态发生后执行的，同一个promise 实例注册多个then函数，为什么可以依次执行。。。很多主流的库或框架也用的订阅发布模式，例如 mobx vue . 所以有必要总结下原理，相信你看完本文，收获颇多。

下面我们可以构造下事件类需要包含下面的内容：
subscribers：一个对象，其中每个属性（订阅的事件类型),对应一个数组，存储订阅者（同一个事件类型可能有多个订阅者，故放到数组中保存）
subscribe()：注册/订阅，将订阅者添加到 subscribers 数组中；
unsubscribe()：取消订阅。从 subscribers 数组中删除订阅者；
publish()：循环遍历 subscribers 数组中的每一个元素，并且调用它们注册时所提供的方法；
所有这三种方法都需要一个 type 参数。这是因为发布者可能触发多个事件（比如同时发布一本杂志和一份报纸）

class Publisher {constructor(){this.subscribers={}
}subscribe(type,fn){// 将订阅的事件回调保存到if (typeof fn !=='function'){throw new Error (`${fn} is not a function`)
}if(!this.subscribers[type]){this.subscribers[type] = []}this.subscribers[type].push(fn);
}unsubscribe(type,fn){this.subscribers[type]=this.subscribers[type].filter(item=>item!==fn)}publish(type,...params){if(!this.subscribers[type])return;this.subscribers[type].forEach(item=>item(...params));
}static makePublisher (obj){obj.publisher = new Publisher(); // 创建一个发布者   }}function fn1(name){
console.log(`hello，my name is ${name}`);
}function meet(){
console.log('nice to meet you ');
}function fn2 (age){console.log(`hello , I am ${age} years old!`);
}var people= {};Publisher.makePublisher(people);people.publisher.subscribe('name',fn1);people.publisher.subscribe('name',meet);people.publisher.unsubscribe('name',meet);people.publisher.subscribe('age',fn2);people.publisher.publish('name','Tom');
people.publisher.publish('age',30);//hello，my name is Tom
// hello , I am 30 years old!

理解并实现你自己的订阅-发布模式相关推荐

RabbitMQ下的生产消费者模式与订阅发布模式
所谓模式,就是在某种场景下,一类问题及其解决方案的总结归纳.生产消费者模式与订阅发布模式是使用消息中间件时常用的两种模式,用于功能解耦和分布式系统间的消息通信,以下面两种场景为例: 数据接入假 ...
Publisher/Subscriber 订阅-发布模式原理解析
Publisher/Subscriber 订阅-发布模式原理解析参考资料 What Is Pub/Sub? Publish/Subscribe Messaging Explained 什么是serv ...
Java设计模式-观察者模式(订阅发布模式)
Java设计模式-观察者模式(订阅发布模式) 一起来看会了就当复习丫,不会来一起来看看吧. 很喜欢一句话:"八小时内谋生活,八小时外谋发展". 如果你也喜欢,让我们一起坚持吧!! ...
4 交换机-fanout（订阅发布模式）
目录订阅发布模式 1.交换器(Exchange) 1.1.创建交换器 1.2 .推送消息到交换器 2.临时队列 3.绑定(bingdings) 5.代码例子 5.1.生产者代码示例 5.2.消费者代 ...
Redis实现消息队列和订阅发布模式
转载:https://www.cnblogs.com/qlqwjy/p/9763754.html 在项目中用到了redis作为缓存,再学习了ActiveMq之后想着用redis实现简单的消息队列,下面 ...
嵌入式消息订阅发布模式软件框架
文章目录一.总体框架二.基于RT-Thread的SoftBus 2.1 SoftBus的由来 2.2 消息订阅者模式 2.3 静态订阅关系与动态订阅关系 2.4 C/S模式 2.5 消息订阅者模式 ...
java订阅发布模式_Spring Boot ActiveMQ发布/订阅消息模式原理解析
本文在<Spring Boot基于Active MQ实现整合JMS>的基础上,介绍如何使用ActiveMQ的发布/订阅消息模式.发布/订阅消息模式是消息发送者发送消息到主题(topic), ...
js设计模式之观察者模式和订阅发布模式
观察者模式这个模式在我看来原理就是发布者身上放着一个电话本(list)存着订阅者的l联系方式(回调函数),在触发条件(发布)后就会依次联系(遍历调用list中的回调函数)订阅者上代码: funct ...
报纸的配送方式：订阅发布模式
这种设计模式比较简单,属于一对多.类似顾客与报社的关系,顾客订阅报纸,每当有新闻发布时快递员一一给订阅报纸的顾客配送下面是代码实现两个接口 /*** 被观察者** Created by Vola ...

理解并实现你自己的订阅-发布模式