百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 文章教程 > 正文

一文带你彻底搞懂发布与订阅设计

xsobi 2024-11-24 00:28 1 浏览



一、介绍

我们常说的发布订阅设计模式,也叫观察者模式,也就是事件监听机制,观察者模式订阅了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,当这个主题对象发生改变时,会通知所有的观察者对象,使他们能够自动的更新自己!

一个软件系统要求某个对象在发生变化时,某些其他的对象作出相应的改变,能做到这点的设计方案有很多,但观察者模式是满足这一要求的各种设计方案中最重要的一种。

从整体来看,观察者模式所涉及的角色有:

  • 抽象主题角色:抽象主题角色把所有对观察者对象的引用保存在一个集合中,每个主题都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象;
  • 具体主题角色:将有关状态存入具体观察者对象,在具体主题的内部状态改变时,给所有登记过的观察者发出通知;
  • 抽象观察者角色:为所有的具体观察者提供一个接口,在得到主题通知时更新自己;
  • 具体观察者角色:存储与主题的状态相关的状态。具体观察者角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态协调

废话也不多说了,下面我们直接讲案例!

二、示例

抽象主题角色,有增加观察者、删除观察者、通知观察者的功能,内容如下:

public abstract class AbstractSubject {

    /** 用来保存注册的观察者对象 */
    private List<Observer> list = new ArrayList<Observer>();

    /**
     * 注册观察者对象
     */
    public void add(Observer observer){
        list.add(observer);
        System.out.println("add an observer");
    }

    /**
     * 删除观察者对象
     * @param observer
     */
    public void remove(Observer observer){
        list.remove(observer);
        System.out.println("delete an observer");
    }

    /**
     * 通知所有注册的观察者对象
     * @param state
     */
    public void notifyObservers(String state){
        for (int i = 0; i < list.size(); i++) {
            list.get(i).update(state);
        }
    }
}

具体主题角色,这个change方法放在子类中是因为可能不同的主题在改变观察者状态的时候会做一些不同的操作,因此就不统一放在父类Subject里面了,内容如下:

public class ConcreteSubject extends AbstractSubject{

    private String state;

    public void change(String newState){
        state = newState;
        System.out.println("主题状态:" + state);

        //状态发生改变,通知所有的观察者
        super.notifyObservers(state);
    }
}

观察者接口,内容如下:

public interface Observer {

    /**
     * 修改状态
     * @param state
     */
    void update(String state);
}

具体观察者实现了观察者接口,内容如下:

public class ConcreteObserver implements Observer{

    @Override
    public void update(String state) {
        System.out.println("观察者,收到状态:" + state);
    }
}

客户端调用代码,一旦主题调用了change方法改变观察者的状态,那么观察者Observer里面的observerState全都改变了,内容如下:

public class ObserverClient {

    public static void main(String[] args) {
        //创建一个主题角色
        ConcreteSubject subject = new ConcreteSubject();

        //创建观察者对象
        ConcreteObserver observer = new ConcreteObserver();

        //将观察者加入主题对象上
        subject.add(observer);

        //改变主题状态
        subject.change("hello world");
    }
}

运行结果如下:

add an observer
主题状态:hello world
观察者,收到状态:hello world

这里只添加了一个观察者,有兴趣的可以试试看多添加几个观察者,效果都是一样的,主题角色改变状态,观察者状态全变。

三、应用

观察者模式的两种模型

  • 推模型:主题对象向观察者推送主题的详细信息,不管观察者是否需要。推送的信息通常是主题对象的全部或部分数据,上面的例子就是典型的推模型。
  • 拉模型:主题对象在通知观察者的时候,只传递少量信息。如果观察者需要更具体的信息,由观察者主动到主题对象中去获取,相当于是观察者从主题对象中拉数据。一般这种模型的实现中,会把主题对象自身通过update()方法传递给观察者,这样观察者在需要获取数据的时候,就可以通过这个引用来获取了。

两种模型的比较

  • 1、推模型是假设主题对象知道观察者需要的数据,拉模型是假设主题对象不知道观察者需要什么数据,干脆把自身传递过去,让观察者自己按需要取值。
  • 2、推模型可能会使得观察者对象难以复用,因为观察者的update()方法是按需要定义的参数,可能无法兼顾到没有考虑到的使用情况,这意味着出现新的情况时,可能要提供新的update()方法。

JDK是有直接支持观察者模式的,就是java.util.Observer这个接口,内容如下:

public interface Observer {
    /**
     * This method is called whenever the observed object is changed. An
     * application calls an <tt>Observable</tt> object's
     * <code>notifyObservers</code> method to have all the object's
     * observers notified of the change.
     *
     * @param   o     the observable object.
     * @param   arg   an argument passed to the <code>notifyObservers</code>
     *                 method.
     */
    void update(Observable o, Object arg);
}

这就是观察者的接口,定义的观察者只需要实现这个接口就可以了。update()方法,被观察者对象的状态发生变化时,被观察者的notifyObservers()方法就会调用这个方法,内容如下:

public class Observable {
    private boolean changed = false;
    private Vector obs;
   
    /** Construct an Observable with zero Observers. */

    public Observable() {
    obs = new Vector();
    }

    /**
     * Adds an observer to the set of observers for this object, provided 
     * that it is not the same as some observer already in the set. 
     * The order in which notifications will be delivered to multiple 
     * observers is not specified. See the class comment.
     *
     * @param   o   an observer to be added.
     * @throws NullPointerException   if the parameter o is null.
     */
    public synchronized void addObserver(Observer o) {
        if (o == null)
            throw new NullPointerException();
    if (!obs.contains(o)) {
        obs.addElement(o);
    }
    }
    ...
}

这是被观察者的父类,也就是主题对象。这是一个线程安全的类,是基于Vector实现的。

创建一个观察者,内容如下:

import java.util.Observable;
import java.util.Observer;

public class Watched implements Observer {

    @Override
    public void update(Observable o, Object arg) {
        System.out.println("观察者,收到状态:" + arg);
    }
}

创建一个主题,内容如下:

import java.util.Observable;

public class Subject extends Observable {

    private String data;

    public void setData(String newData){
        System.out.println("主题状态:" + newData);
        data = newData;
        setChanged();
        notifyObservers(data);
    }
}

写一个main函数调用,内容如下:

public class WatchedClient {

    public static void main(String[] args) {
        //创建观察者对象
        Watched watched = new Watched();

        //创建主题
        Subject subject = new Subject();

        //将观察者对象加入主题
        subject.addObserver(watched);

        //修改主题状态
        subject.setData("hello world");

    }
}

运行结果,内容如下:

主题状态:hello world
观察者,收到状态:hello world

看到主题对象改变的时候,观察者对象的状态也随之改变。

四、总结

引入设计模式最主要的作用我认为就是两点:

  • 去重复代码,使得代码更清晰、更易读、更易扩展
  • 解耦,使得代码可维护性更好,修改代码的时候可以尽量少改地方

使用观察者模式可以很好地做到这两点。增加观察者,直接new出观察者并注册到主题对象之后就完事了,删除观察者,主题对象调用方法删除一下就好了,其余都不用管。主题对象状态改变,内部会自动帮我们通知每一个观察者,是不是很方便呢?

观察者模式主要应用场景有:

  • 对一个对象状态的更新需要其他对象同步更新
  • 对象仅需要将自己的更新通知给其他对象而不需要知道其他对象的细节,如消息推送

相关推荐

好用的云函数!后端低代码接口开发,零基础编写API接口

前言在开发项目过程中,经常需要用到API接口,实现对数据库的CURD等操作。不管你是专业的PHP开发工程师,还是客户端开发工程师,或者是不懂编程但懂得数据库SQL查询,又或者是完全不太懂技术的人,通过...

快速上手:Windows 平台上 cURL 命令的使用方法

在工作流程中,为了快速验证API接口有效性,团队成员经常转向直接执行cURL命令的方法。这种做法不仅节省时间,而且促进了团队效率的提升。对于使用Windows系统的用户来说,这里有一套详细...

使用 Golang net/http 包:基础入门与实战

简介Go的net/http包是构建HTTP服务的核心库,功能强大且易于使用。它提供了基本的HTTP客户端和服务端支持,可以快速构建RESTAPI、Web应用等服务。本文将介绍ne...

#小白接口# 使用云函数,人人都能编写和发布自己的API接口

你只需编写简单的云函数,就可以实现自己的业务逻辑,发布后就可以生成自己的接口给客户端调用。果创云支持对云函数进行在线接口编程,进入开放平台我的接口-在线接口编程,设计一个新接口,设计和配置好接口参...

极度精神分裂:我家没有墙面开关,但我虚拟出来了一系列开关

本内容来源于@什么值得买APP,观点仅代表作者本人|作者:iN在之前和大家说过,在iN的家里是没有墙面开关的。...

window使用curl命令的注意事项 curl命令用法

cmd-使用curl命令的注意点前言最近在cmd中使用curl命令来测试restapi,发现有不少问题,这里记录一下。在cmd中使用curl命令的注意事项json不能由单引号包括起来json...

Linux 系统curl命令使用详解 linuxctrl

curl是一个强大的命令行工具,用于在Linux系统中进行数据传输。它支持多种协议,包括HTTP、HTTPS、FTP等,用于下载或上传数据,执行Web请求等。curl命令的常见用法和解...

Tornado 入门:初学者指南 tornados

Tornado是一个功能强大的PythonWeb框架和异步网络库。它最初是为了处理实时Web服务中的数千个同时连接而开发的。它独特的Web服务器和框架功能组合使其成为开发高性能Web...

PHP Curl的简单使用 php curl formdata

本文写给刚入PHP坑不久的新手们,作为工具文档,方便用时查阅。CURL是一个非常强大的开源库,它支持很多种协议,例如,HTTP、HTTPS、FTP、TELENT等。日常开发中,我们经常会需要用到cur...

Rust 服务器、服务和应用程序:7 Rust 中的服务器端 Web 应用简介

本章涵盖使用Actix提供静态网页...

我给 Apache 顶级项目提了个 Bug apache顶级项目有哪些

这篇文章记录了给Apache顶级项目-分库分表中间件ShardingSphere提交Bug的历程。说实话,这是一次比较曲折的Bug跟踪之旅。10月28日,我们在GitHub上提...

linux文件下载、服务器交互(curl)

基础环境curl命令描述...

curl简单使用 curl sh

1.curl--help#查看关键字2.curl-A“(添加user-agent<name>SendUser-Agent<name>toserver)”...

常用linux命令:curl 常用linux命令大全

//获取网页内容//不加任何选项使用curl时,默认会发送GET请求来获取内容到标准输出$curlhttp://www.baidu.com//输出<!DOCTYPEh...

三十七,Web渗透提高班之hack the box在线靶场注册及入门知识

一.注册hacktheboxHackTheBox是一个在线平台,允许测试您的渗透技能和代码,并与其他类似兴趣的成员交流想法和方法。它包含一些不断更新的挑战,并且模拟真实场景,其风格更倾向于CT...