专栏首页JAVA杂谈CRUD很无聊?一起学设计模式吧!— 观察者模式

CRUD很无聊?一起学设计模式吧!— 观察者模式

定义

观察者模式是对象的行为模式,又叫发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式、源-监听器(Source/Listener)模式或从属者(Dependents)模式。

观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时,会通知所有观察者对象,使它们能够自动更新自己。

一个软件系统常常要求在某一个对象的状态发生变化的时候,某些其他的对象做出相应的改变。做到这一点的设计方案有很多,但是为了使系统能够易于复用,应该选择低耦合度的设计方案。减少对象之间的耦合有利于系统的复用,但是同时设计师需要使这些低耦合度的对象之间能够维持行动的协调一致,保证高度的协作。观察者模式是满足这一要求的各种设计方案中最重要的一种。

顾名思义,观察者主要是分为两个大的对象角色,观察者和主题(也叫被观察者)。他们是如何做到松耦合的呢?

关于观察者的一切,主题只需要知道观察者实现了某个接口,主题不需要知道观察者的具体类是谁,做了什么或其他任何细节。当有新的观察者出现时,主题的代码不需要做任何修改。如果有个新的对象需要成为观察者并接收主题的变化通知,我们只需要让这个对象实现此观察者接口,然后注册成为观察者即可。主题不在乎别的,它只会发送通知给所有实现了观察者接口的对象。

改变主题或观察者其中一方,并不影响另外一方。两者之间是松耦合的,所以只要他们之间的接口仍被遵守,我们就可以自由的改变他们。

UML

角色定义

观察者模式涉及四个角色

  • 抽象主题(Subject):抽象主题角色把所有对观察者对象的引用保存在一个聚集(比如ArrayList对象)里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对 象,抽象主题角色又叫做抽象被观察者(Observable)角色。
  • 具体主题(ConcreteSubject):将有关状态存入具体观察者对象;在具体主题的内部状态改变时,给所有登记过的观察者发出通知。具体主题角色又叫做具体被观察者(Concrete Observable)角色
  • 观察者对象(Observer):所有潜在的观察者必须实现观察者接口,这个接口一般只有一个方法update(),当主题对象发生变化时它被调用。
  • 具体观察者(ConcreteObserver):具体的观察者可以是实现观察者对象的任意类,观察者必须要注册具体的主题,以便接收更新。

场景实战

平时我们都喜欢关注一些微信公众号看一些大佬吹牛皮,当公众号发布消息后,作为粉丝的我们就可以收到消息。而对于公众号作者而言,他们主要是管理粉丝还有吹牛皮,这个场景我们可以套用观察者模式来实现。

代码示例

抽象观察者

首先我们定义一个抽象观察者,这个类很简单,只要定义一个所有观察者公有的方法。在我们的场景中,当公众号发布消息后我们就能得到通知,我们这里使用一个String类型的参数用来接收公众号的消息。

/** * <p> * <code>Observer</code> * </p> * Description: * 抽象观察者,所有实现该接口的类都可以成为观察者 * @author jam * @date 2019/4/19下午11:25 */public interface Observer {    public void recive(String message);}

具体观察者

关注公众号的读者称之为粉丝,这里我们简单的打印一下公众号发布的消息

/** * <p> * <code>Fans</code> * </p> * Description: * 具体观察者 -- 粉丝类 * @author jam * @date 2019/4/19下午11:26 */public class Fans implements Observer {    private String name;
    public Fans(String name) {        this.name = name;    }
    @Override    public void recive(String message) {        System.out.println("粉丝 " + this.name + " 收到消息: "+message);    }}

抽象主题(抽象被观察者)

抽象主题主要是定义一些接口用于管理观察者,公众号有权利来管理所有的粉丝并在发布消息后通知所有的粉丝。

/** * <p> * <code>Subject</code> * </p> * Description: *  定义抽象主题,主题需要实现添加、删除、通知观察者 * @author jam * @date 2019/4/19下午11:20 */public interface Subject {    /**     * 注册成为观察者     * @param observer     */    public void attach(Observer observer);
    /**     * 删除观察者     * @param observer     */    public void detach(Observer observer);
    /**     * 通知所有观察者     */    public void notifyObservers();}

具体主题(具体被观察者)

具体主题除了必须要实现抽象主题定义的方法外,还需要有个额外的方法change(),当主题发生变化时才会告诉观察者。在本场景中公众号发布消息,我们使用publish(String message)方法替代change()方法。

/** * <p> * <code>WechatServer</code> * </p> * Description: * 具体主题 * @author jam * @date 2019/4/19下午11:24 */public class WechatServer implements Subject {    private ArrayList<Observer> observers;    private String message;
    public WechatServer() {        observers = new ArrayList<>();    }
    /**     * 让一个用户注册成为观察者即粉丝     * @param observer     */    @Override    public void attach(Observer observer) {        observers.add(observer);    }
    /**     * 不喜欢这个观察者,删除掉     * @param observer     */    @Override    public void detach(Observer observer) {        observers.remove(observer);    }
    /**     * 通知所有的观察者     */    @Override    public void notifyObservers() {        for (Observer observer : observers) {            observer.recive(message);        }    }
    /**     * 当主题发生变化时通知观察者     * @param message     */    public void publish(String message){        this.message = message;        System.out.println("webchat publish message:" + message);        notifyObservers();    }}

测试类

public class Test {    public static void main(String[] args) {        WechatServer wechatServer = new WechatServer();        Fans fans1 = new Fans("张三");        Fans fans2 = new Fans("李四");        Fans fans3 = new Fans("杨五");
        wechatServer.attach(fans1);        wechatServer.attach(fans2);        wechatServer.attach(fans3);        wechatServer.publish("CRUD很无聊?跟我一起学命令模式吧!");
        System.out.println("--------");                //删除其中一个粉丝        wechatServer.detach(fans1);        wechatServer.publish("CRUD很无聊?跟我一起学观察者模式吧!");
    }}

执行结果

通过执行结果我们可以发现,在公众号发布消息后所有的粉丝都可以收到消息,而取消关注或者被剔除粉丝队伍以后就收不到消息了。

推模式与拉模式

我们上面的场景是观察者模式中的推模式,这种场景是主题主动向观察者推送数据,不管观察者需要不需要。推模式的前提是主题对象知道观察者需要的数据,观察中的update()方法里的参数是按照需要定义的方法,但是随着业务的发展会出现考虑不到的情形。

比如我们上述场景中粉丝只需要知道公众号发布的内容,所以我们先约定String类型的参数,但是有些粉丝却想知道这个消息的真实作者是谁(是否转载?),这个时候就需要提供新的方法,比如update(String message,String author),或者干脆重新实现观察者,不管如何都得作相应的改动。

观察者模式还有另外一个模式拉模式,这个模式不需要知道观察者需要什么数据,他把主题自身都传递给观察者,update(Subject subject),然后对外提供一些getter方法,让观察者按需来取,这样基本上可以适用各种情况的需要。

接下来我们用拉模式来实现上面的场景。

抽象观察者

这里我们不再适用约定参数处理recive方法,而是使用主题直接作为参数。

public interface Observer {    /**     * 使用主题作为参数     * @param subject     */    public void recive(Subject subject);}

具体观察者

收到通知后,我们按需从主题对象中获取相应的数据。

public class Fans implements Observer {    private String name;
    public Fans(String name) {        this.name = name;    }
    @Override    public void recive(Subject subject) {        //观察者可以同时观察多个主题        //所以我们需要确保被观察者属于我们需要的WechatServer类型        //如果是其他类型可能需要作其他方式处理        if(subject instanceof WechatServer){            WechatServer wechatServer = (WechatServer) subject;            System.out.println("粉丝 " + this.name + " 收到消息: "                    + wechatServer.getMessage() + " 作者是:"                    + wechatServer.getAuthor());        }    }}

抽象主题

未发生变化

public interface Subject {    /**     * 注册成为观察者     * @param observer     */    public void attach(Observer observer);
    /**     * 删除观察者     * @param observer     */    public void detach(Observer observer);
    /**     * 通知所有观察者     */    public void notifyObservers();}

具体主题

重点关注 notifyObservers()方法,直接将this即当前主题作为参数传递给观察者,并对外提供 getMessage()getAuthor()方法,好让观察者对象可以方便取走想要的数据。

public class WechatServer implements Subject {    private ArrayList<Observer> observers;    private String message;    private String author;
    /**     * 对外提供获取内容的方法     * @return     */    public String getMessage() {        return message;    }
    /**     * 对外提供获取作者的方法     * @return     */    public String getAuthor() {        return author;    }
    public WechatServer() {        observers = new ArrayList<>();    }
    /**     * 让一个用户注册成为观察者即粉丝     * @param observer     */    @Override    public void attach(Observer observer) {        observers.add(observer);    }
    /**     * 不喜欢这个观察者,删除掉     * @param observer     */    @Override    public void detach(Observer observer) {        observers.remove(observer);    }
    /**     * 通知所有的观察者     */    @Override    public void notifyObservers() {        for (Observer observer : observers) {            //这里不再是具体的参数,而是把主题自身给通知给观察者            observer.recive(this);        }    }
    /**     * 当主题发生变化时通知观察者     * @param message     */    public void publish(String message,String author){        this.message = message;        this.author = author;        System.out.println("webchat publish message:" + message);        notifyObservers();    }}

测试类

public class Test {    public static void main(String[] args) {        WechatServer wechatServer = new WechatServer();        Fans fans1 = new Fans("张三");        Fans fans2 = new Fans("李四");        Fans fans3 = new Fans("杨五");
        wechatServer.attach(fans1);        wechatServer.attach(fans2);        wechatServer.attach(fans3);        wechatServer.publish("CRUD很无聊?跟我一起学命令模式吧!","JAVA日知录");
        System.out.println("--------");
        wechatServer.detach(fans1);        wechatServer.publish("CRUD很无聊?跟我一起学观察者模式吧!","JAVA日知录");
    }}

执行结果

使用拉模式后只要主题提供了对应的get方法,基本可以满足各种需求的场景。

再深入一点

观察者模式在JAVA中已经有相应的实现,抽象观察者角色由 java.util.Observer充当,抽象主题角色由 java.util.Observable充当。

我们可以利用java内置的观察者模式很容易实现上面的推模式和拉模式的场景代码,这里就不再演示了。

最后提醒大家一下,主题角色Observable是一个类,我们要想要实现具体的主题必须要继承它,如果某类想同时具有Observable和其他一个超类的行为,就会陷入两难,毕竟JAVA不支持多重继承。

如果你的应用场景中不需要考虑如上情形,那么Observable可能会符合你的需求,否则还是需要使用自定义观察者模式来实现你的需求,反正这也很简单,不是吗?

本文分享自微信公众号 - JAVA日知录(java_daily),作者:张坚

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-04-20

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • RocketMQ进阶-延时消息

    在开发中经常会遇到延时任务的需求,例如在12306购买车票,若生成订单30分钟未支付则自动取消;还有在线商城完成订单后48小时不评价 ,自动5星好评。像这类在某...

    JAVA日知录
  • 多线程设计模式 : Master-Worker模式

    Master-Worker是常用的并行计算模式。它的核心思想是系统由两类进程协作工作:Master进程和Worker进程。Master负责接收和分配任务,Wor...

    JAVA日知录
  • 微服务架构 CI/CD 实战

    在项目根路径下执行,Maven 命令 mvn clean install -pl com.lab:book-common -am -Ptest,截取输出如下

    JAVA日知录
  • 一起学设计模式 - 观察者模式

    观察者模式是一种使用率极高的模式,用于建立一种对象与对象之间的依赖关系,一个对象发生改变时将自动通知其他对象,其他对象将相应作出反应。在观察者模式中,发生改变的...

    battcn
  • 设计模式----观察者模式

    SuperHeroes
  • 观察者模式 Observer 发布订阅模式 源 监听 行为型 设计模式(二十三)

    定义对象一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖他的对象都得到通知并自动更新。

    noteless
  • Java设计模式之观察者模式

    观察者模式就是一个对象的状态或行为发生改变会随之影响其他对象的状态与行为,总之就是对象之间的联动,一个对象发生改变,其他对象也马上发生变化。

    萬物並作吾以觀復
  • 浅谈观察者模式

    前言:到目前已经看了几个设计模式,像简单工厂模式、策略模式、单一职责原则、开放-封闭原则、依赖倒转与装饰模式等。但总是纸上得来终觉浅的感觉,没有深 刻的理解。...

    用户5908113
  • 设计模式走一遍---观察者模式

    红灯车过,人停;绿灯人过,车停。每天走在马路上,到处可见红绿灯指挥着我们什么时候可以过马路,什么时候不能过马路。无论是人还是车,都时刻关注着红绿灯的状态,一旦红...

    帅地
  • Java-观察者模式(订阅-发布者模式)

    观察者模式也叫订阅-发布者模式,是一种一对一或者一对多的依赖关系,当一个对象改变状态,依赖它的对象会收到通知并自动更新。

    android_薛之涛

扫码关注云+社区

领取腾讯云代金券