美文网首页
史上最简单的发布者与订阅者程序

史上最简单的发布者与订阅者程序

作者: 米拉蜀黍 | 来源:发表于2018-10-28 18:47 被阅读0次

前言

我建议很多人着急去了解某些框架源码的人,自己要做好一定的知识储备,先把基础做好,再去解读人家源码,否则你只会盲目的崇拜(因为人家写的太好,但你看不懂人家写的东西),然后收藏起来,从而一篇篇好文章被打入你的冷宫。
我们知道前端MVVM框架最核心的内容是其响应式系统。想要完全解读整个响应式系统,就必须要了解其中涉及的到发布者与订阅者设计模式。
同样在Java中,我们一般用该设计模式来实现消息队列

该文章并不去研究响应式系统的实现,也不研究消息队列的实现。只是在语言层面上给刚入坑的孩子们的启示例子。

什么是 发布者与订阅者?

这种设计模式,简单的说,例如我们在微信中关注过的订阅号。那该订阅号我们可以称为发布者,我们每个订阅者(关注该订阅号的微信)可以称为订阅者。每当该订阅号发布消息的时候,并不是发送给所有微信用户,而是会选择所有订阅该订阅号的微信用户。

用代码来解释下,我们需要两个角色

  1. 发布者
    添加订阅 (我们所谓的关注其订阅号)
    移除订阅 (我们取消关注该订阅号)
    通知订阅者 (订阅号发布消息,所有关注者都会收到)
  2. 订阅者
    接收消息 (接收订阅号发布的消息)

订阅者注册

image

发布者发布消息

image

了解以上关系后,我们来用最少的代码,用JS和JAVA分别来实现一下这个设计模式吧。

JavaScript最简单实现

        // 微信订阅号 -- 发布者
        class Dep {
            constructor(name) {
                // 订阅号名字
                this.name = name
                // 该订阅号内存的订阅者
                this.subs = []
            }
            // 添加订阅者
            addSub(sub) {
                this.subs.push(sub)
            }

            // 发布消息通知所有订阅者
            notifySubs(notifyInfo) {
                this.subs.forEach((sub) => {
                    sub.receiveInfo(notifyInfo)
                })
            }
        }
        
        // 微信号 -- 订阅者
        class Sub {
            constructor(name) {
                // 微信用户名字
                this.name = name
            }
            
            // 接收订阅号发布的消息
            receiveInfo(notifyInfo) {
                console.log('尊敬的' + this.name + ', ' + notifyInfo)
            }
        }

        // Test
        let d1 = new Dep('王者荣耀订阅号')
        let d2 = new Dep('腾讯棋牌订阅号')
        
        let s1 = new Sub('小雪')
        let s2 = new Sub('小黑')
        let s3 = new Sub('小白')

        // 王者荣耀订阅号添加订阅者
        d1.addSub(s1)
        d1.addSub(s2)

        // 腾讯棋牌订阅号添加订阅者
        d2.addSub(s2)
        d2.addSub(s3)

        // 王者荣耀订阅号发布消息
        d1.notifySubs('王者荣耀更新了,快来围观啊!')
        
        console.log('============')
        
        // 腾讯棋牌订阅号发布消息
        d2.notifySubs('腾讯棋牌有新玩法了,快来围观啊!')
以上会看到 每个订阅号发布消息后,会发给对应的订阅者。 image

我相信移除你会写吧?

Java 的最简单实现

import java.util.ArrayList;


// 微信订阅号 -- 发布者
class Dep {
    private String name;
    private ArrayList<Sub> subs = new ArrayList<Sub>();

    public Dep(String name) {
        this.name = name;
    }

    // 添加订阅者
    public void addSub (Sub sub) {
        subs.add(sub);
    }

    // 发布消息通知所有订阅者
    public void notifySubs (String notifyInfo) {
        for (Sub sub : subs) {
            sub.receiveInfo(notifyInfo);
        }
    }

}

// 微信号 -- 订阅者
class Sub {
    private String name;
    public Sub (String name) {
        this.name = name;
    }

    // 接收订阅号发布的消息
    public void receiveInfo (String notifyInfo) {
        System.out.println("尊敬的" + this.name + ", " + notifyInfo);
    }
}

public class TestDepAndSub {
    public static void main (String[] args) {
        Dep d1 = new Dep("王者荣耀订阅号");
        Dep d2 = new Dep("腾讯棋牌订阅号");

        Sub s1 = new Sub("小雪");
        Sub s2 = new Sub("小黑");
        Sub s3 = new Sub("小白");

        // 王者荣耀订阅号添加订阅者
        d1.addSub(s1);
        d1.addSub(s2);

        // 腾讯棋牌订阅号添加订阅者
        d2.addSub(s2);
        d2.addSub(s3);

        // 王者荣耀订阅号发布消息
        d1.notifySubs("王者荣耀更新了,快来围观啊!");

        System.out.println("============");

        // 腾讯棋牌订阅号发布消息
        d2.notifySubs("腾讯棋牌有新玩法了,快来围观啊!");
    }
}

同样我们也得到了相应的结果。


image

总结

框架源码肯定要看的,但我们不要忘了,我们为什么去看源码,不是为了跟风看而看,也不要越过自己的技术底线去看,脚踏实地一步一步来,掌握好每一个基础知识点,再去阅读源码吧,你会事半功倍的。

初学者可以关注下,以后会更新适合初学者的入门文章,循序顿进讲解下Vue的运行机制和原理。

相关文章

  • 史上最简单的发布者与订阅者程序

    前言 我建议很多人着急去了解某些框架源码的人,自己要做好一定的知识储备,先把基础做好,再去解读人家源码,否则你只会...

  • Java学习笔记--Redis的发布与订阅

    一、发布与订阅 订阅者(subscribe)-------> 发布者(publish) <----订阅者(subs...

  • t-pot使用hpfeeds协议爬坑

    hpfeeds协议是一种发布者/订阅者协议,发布者/订阅者拥有着自己的发布/订阅频道,发布者可以通过发布频道发送消...

  • MQTT 5.0 特性 | 保留消息

    前言 发布订阅模式虽然让消息的发布者与订阅者充分解耦,但也出现了一个隐含的问题,即订阅者无法主动向发布者请求消息,...

  • C#沉淀-事件:发布订阅模式

    认识发布者/订阅者模式 情景:当一个特定的程序事件发生时,程序的其他部分可以得到该事件已经发生的通知 发布者定义一...

  • EventBus解读

    EventBus 基础发布者通过EventBus发布事件,订阅者通过EventBus订阅事件。当发布者发布事件时,...

  • 使用Typescript手写一个Eventhub(发布订阅模式)

    什么是发布-订阅模式? 发布-订阅模式主要包含三个模块, 发布者,事件处理中心,订阅者。举个简单的例子,假设我们是...

  • Redis高级功能之 - 发布/订阅与Stream

    发布订阅 发布/ 订阅系统 是 Web 系统中比较常用的一个功能。简单点说就是 发布者发布消息,订阅者接受消息。虽...

  • 订阅与发布者模式

    理解发布-订阅模式其实是一种对象间一对多的依赖关系,当一个对象的状态发生改变时,所有依赖与它的对象都将得到状态改变...

  • 发布者-订阅者模式简单实现

    之前在看DMQ根据vue双向数据绑定原理模拟实现了mvvm,里面有提高发布者-订阅者模式,看了一些资料,今天自己简...

网友评论

      本文标题:史上最简单的发布者与订阅者程序

      本文链接:https://www.haomeiwen.com/subject/gwtmtqtx.html