设计模式行为型观察者模式

Posted 2022-05-26 lisin-lee-cooper

一.概述

1.1 概述
又被称为发布-订阅（Publish/Subscribe）模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时，会通知所有的观察者对象，使他们能够自动更新自己。

1.2 结构

Subject：抽象主题（抽象被观察者），抽象主题角色把所有观察者对象保存在一个集合里，每个主题都可以有任意数量的观察者，抽象主题提供一个接口，可以增加和删除观察者对象。
ConcreteSubject：具体主题（具体被观察者），该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。
Observer：抽象观察者，是观察者的抽象类，它定义了一个更新接口，使得在得到主题更改通知时更新自己。
ConcrereObserver：具体观察者，实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态。

二.场景

在使用CSDN时，大家都会有这样的体验，当你关注的博主有新内容更新的话，它就会推送给粉丝。我们使用观察者模式来模拟这样的场景，粉丝就是观察者，博客是被观察者，有多个的粉丝关注了程序猿这个公众号。

三.类图及实现

public interface Subject 
    public void attach(Observer observer);

    public void detach(Observer observer);

    public void notify(String message);

public class SubscriptionSubject implements Subject 

    private List<Observer> weixinUserlist = new ArrayList<>();

    @Override
    public void attach(Observer observer) 
        weixinUserlist.add(observer);
    

    @Override
    public void detach(Observer observer) 
        weixinUserlist.remove(observer);
    

    @Override
    public void notify(String message) 
        for (Observer observer : weixinUserlist) 
            observer.update(message);
        
    

public interface Observer 
    void update(String message);

public class WeixinUser implements Observer 

    private String name;

    public WeixinUser(String name) 
        this.name = name;
    

    @Override
    public void update(String message) 
        System.out.println(name + "-" + message);
    

public class ObserverMain 

    public static void main(String[] args) 
        SubscriptionSubject mSubscriptionSubject = new SubscriptionSubject();
        WeixinUser user1 = new WeixinUser("孙悟空");
        WeixinUser user2 = new WeixinUser("猪悟能");
        WeixinUser user3 = new WeixinUser("沙悟净");
        mSubscriptionSubject.attach(user1);
        mSubscriptionSubject.attach(user2);
        mSubscriptionSubject.attach(user3);
        mSubscriptionSubject.notify("内容更新了");
    

四.JDK源码应用

在 Java 中，通过 java.util.Observable 类和 java.util.Observer 接口定义了观察者模式，只要实现它们的子类就可以编写观察者模式实例。
1，Observable类
Observable 类是抽象目标类（被观察者），它有一个 Vector 集合成员变量，用于保存所有要通知的观察者对象

void addObserver(Observer o) 方法：用于将新的观察者对象添加到集合中。
void notifyObservers(Object arg) 方法：调用集合中的所有观察者对象的 update方法，通知它们数据发生改变。通常越晚加入集合的观察者越先得到通知。
void setChange() 方法：用来设置一个 boolean 类型的内部标志，注明目标对象发生了变化。当它为true时，notifyObservers() 才会通知观察者。

2，Observer 接口
Observer 接口是抽象观察者，它监视目标对象的变化，当目标对象发生变化时，观察者得到通知，并调用 update 方法，进行相应的工作。