【SSD系列】傻傻的,3行代码一个订阅发布中心,不会不知道吧

简介: 无处不在的订阅发布模式,也是常备手写系列,可见其地位。其实,在浏览器端,3行代码,没错3行代码,你就可以拥有一个具备订阅,取消订阅,发布,并具备once能力的订阅发布中心。

1.JPG


关于[SSD系列]


专门为8月征文活动而建立的系列,收集整理前端一些有意思或者我们不重视的内容,可能是部分掘友不知道的。


前言


无处不在的订阅发布模式,也是常备手写系列,可见其地位。


其实,在浏览器端,3行代码,没错3行代码,你就可以拥有一个具备订阅,取消订阅,发布,并具备once能力的订阅发布中心。


4行代码的订阅发布中心


订阅发布中心代码


window._on = window.addEventListener;
window._off = window.removeEventListener;
window._emit = (type, data) => window.dispatchEvent(new CustomEvent(type, { detail: data }));;
window._once = (type, callback) => window.addEventListener(type, callback, { once: true, capture: true });
复制代码


标题是3行也是可以的,把1,2行合并一下:


(window._on = window.addEventListener, window._off = window.removeEventListener);
复制代码


测试代码


function onEventX(ev) {
    console.log("event-x 收到数据:", ev.detail);
}
// 订阅
window._on("event-x", onEventX);
window._once("event-once", ev => console.log("event-once 收到数据:", ev.detail));
// once
window._emit("event-once", { uid: -100, message: "you love me" });
window._emit("event-once", { uid: -100, message: "you love me" });
// 订阅和取消订阅
window._emit("event-x", { uid: 100, message: "i love you" })
window._off("event-x", onEventX);
window._emit("event-x", { uid: 100, message: "i love you" })
复制代码


输出结果




1.JPG


是不是有点小惊喜。


原理浅析



window是表象,根源是 EventTarget


其一共三个方法,也正是这三个方法,让其自身是一个订阅发布中心:



Window的继承关系:


2.JPG


Document的继承关系:


3.JPG


Element的继承关系:


4.JPG


所以document和window对象均是一个订阅发布中心。

更重要的是我们常用的div, span, input等等nodeType为1的元素节点,也统统是一个订阅发布中心。


假如你连nodeType也不清楚,没关系,请参见Node.nodeType


当前版本的问题


  1. 不能多实例化啊
  2. 挂载window上太丑了
  3. 不能多参数啊
    答:要那么多参数干嘛
  4. 参数从ev.detail上获取
    答:还好
  5. 不能在node, web worker中使用啊
    答:node要你写吗, 自带啊。 web worker嘛,确实。
  6. ........


到这里,我不生气,真的不生气, 特定场景解决特定问题就完毕了。 1毛钱还想上天啊。


但是就算是1毛钱,我也希望大家获得更好的体验,所以要改造升级。


3以及之后的别想了,我们把1,2点进行完美升级。


升级



升级后的代码会多一点,2倍吧,一共6行代码


代码


class EventEmitter extends EventTarget {
    on = this.addEventListener;
    off = this.removeEventListener;
    emit = (type, data) => this.dispatchEvent(new CustomEvent(type, { detail: data }));
    once = (type, callback) => this.on(type, callback, { once: true, capture: true });
}
复制代码


测试代码


var emitter = new EventEmitter();
        function onEventX(ev) {
            console.log("event-x 收到数据:", ev.detail);
        }
        // 订阅
        emitter.on("event-x", onEventX);
        emitter.once("event-once", ev => console.log("event-once 收到数据:", ev.detail));
        // 发布
        emitter.emit("event-once", { uid: -100, message: "you love me" });
        emitter.emit("event-once", { uid: -100, message: "you love me" });
        emitter.emit("event-x", { uid: 100, message: "i love you" })
        emitter.off("event-x", onEventX);
        emitter.emit("event-x", { uid: 100, message: "i love you" })
复制代码


完美,名字好看了,使用方便了,也支持多实例了。


结果


5.JPG


总结



是不是很简单,其实不用第三方库,你也可以拥有订阅发布中心,就这么简单。

要是都看到这了,都不点个赞,那就是你的不对了。

相关文章
|
存储 消息中间件 缓存
|
8月前
|
消息中间件 API RocketMQ
消息队列 MQ产品使用合集之设备在国外收不到指令,是什么原因
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
6月前
|
网络安全
【Azure 事件中心】如何查看Event Hub的生产者或者是消费者端的IP地址呢?
【Azure 事件中心】如何查看Event Hub的生产者或者是消费者端的IP地址呢?
|
8月前
|
消息中间件 Java 测试技术
【消息队列开发】 测试MessageFileManager(对硬盘中的消息操作)类
【消息队列开发】 测试MessageFileManager(对硬盘中的消息操作)类
|
9月前
|
消息中间件 存储 Apache
MQ产品使用合集之有RocketMQ arm架构的镜像吗
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
398 1
|
9月前
|
设计模式 负载均衡 算法
C/C++发布-订阅者模式世界:揭秘高效编程的秘诀
C/C++发布-订阅者模式世界:揭秘高效编程的秘诀
370 1
|
9月前
|
移动开发 小程序 Go
【社区每周】小程序消息订阅插件升级为消息订阅接口(2022年8月第五期)
【社区每周】小程序消息订阅插件升级为消息订阅接口(2022年8月第五期)
63 0
|
存储 缓存 监控
聊聊消息中心的设计与实现逻辑
消息通知的流程设计,在各个业务线中通过消息中心提供的接口方法,将不同场景下的消息内容提交到消息中心,消息中心进行统一维护管理,并根据消息的来源和去向,适配相应的推送逻辑。
1229 0
聊聊消息中心的设计与实现逻辑
操作系统2020年8月生产消费者问题解析思路
操作系统2020年8月生产消费者问题解析思路
88 0
|
消息中间件 监控 JavaScript
聊聊 消息中心的设计与实现
聊聊 消息中心的设计与实现