发布订阅模式

一、常见的发布订阅模式

1、Dom的事件

Event + addEventListener + dispatchEvent

//订阅中心
const event = new Event('zyk');
//订阅
document.addEventListener('zyk', (value)=>{
    console.log('我收到了:', value)
});
//发布
document.dispatchEvent(e, '1');
document.dispatchEvent(e, '2');

遍历小工具(免密登录):

        通过Dom的事件中心,自动填充用户名、密码,无需手动输入。把以下代码添加收藏到网页,每次点击页面,就可以触发

javascript:
var inputEvent = documnet.createEvent('Event');
inputEvent.initEvent('init');
//获取用户名、密码、登录按钮的Dom
var userInput = document.getElementsByName('usernameInput')[0];
var pwdInput = document.getElementsByName('passwordInput')[0];
var loginButton = document.getElementsByName('loginBtn')[0];
//设置用户、密码的值
userInput.value = 'zyk';
pwdInput.value = '123456';
//发布用户名、密码的事件
userInput.dispatchEvent(inputEvent);
pwdInput.dispatchEvent(inputEvent);
//触发登录按钮的click事件
loginButton.click();

二、手写一个发布订阅中心

思路:

        模仿Event+addEventListener+dispatchEvent,我们的发布订阅库需要以下方法:

  • on = (event: string, callback: Function):void=>{}  //订阅
  • emit = (event: string, ...args): void =>{} //进行发布
  • off = (event: string, callback: Function): void => {} //取消订阅
  • once(event: string, callback: Function):void=>{}  //无论发布多少次,只订阅一次

实现代码:

class EventEmitter {
    constructor() {
        this.events = new Map();
    }
    on(event, callback) {
        if (this.events.has(event)) {
            let cbList = this.events.get(event);
            cbList.push(callback);
            this.events.set(event, cbList);
        } else {
            this.events.set(event, [callback]);
        }
        
    }
    emit(event, ...args) {
        let cbList = this.events.get(event);
        if (Array.isArray(cbList) && cbList.length > 0 ) {
            cbList.forEach(cb => cb(...args));
        }
    }
    off(event, callback) {
        let cbList = this.events.get(event);
        if(Array.isArray(cbList) && cbList.length >0) {
            cbList = cbList.filter(cb => cb!==callback);
            this.events.set(event, cbList);
        }
    }
    once(event, callback) {
        const fn = (...args) => {
            callback(...args); //执行一次
            this.off(event, fn);
        }
        this.on(event, fn)
    }
}

使用:

【1】发布多次,都可以一个他订阅

【2】发布1次,可以被多个订阅到

【3】取消一个订阅

【4】只订阅一次

相关推荐

  1. Redis发布-订阅模式之Channel的发布订阅

    2024-05-14 00:54:10       34 阅读
  2. js设计模式--发布订阅模式

    2024-05-14 00:54:10       39 阅读
  3. 【redis】redis发布/订阅模型

    2024-05-14 00:54:10       25 阅读
  4. springboot rabbitmq 发布订阅 广播模式

    2024-05-14 00:54:10       71 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-05-14 00:54:10       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-05-14 00:54:10       100 阅读
  3. 在Django里面运行非项目文件

    2024-05-14 00:54:10       82 阅读
  4. Python语言-面向对象

    2024-05-14 00:54:10       91 阅读

热门阅读

  1. 【Web前端】jquery_json

    2024-05-14 00:54:10       39 阅读
  2. git把repo1中的test目录中的代码同步到repo2中

    2024-05-14 00:54:10       35 阅读
  3. 孩子如何备考编程竞赛

    2024-05-14 00:54:10       33 阅读
  4. 1-3 如何学习,才能让这门课真正发挥价值

    2024-05-14 00:54:10       35 阅读
  5. 21、Flink 的 Checkpoints 使用介绍

    2024-05-14 00:54:10       29 阅读