大话--观察者模式

观察者模式：

定义：

定义了对象之间的一对多依赖，让多个观察者(Observer)同时监听某一主题对象(Subject)。当主题对象变化时，所有观察者都会收到通知并更新。
核心代码是在抽象类中有一个ArrayList用来存放观察者们。

使用场景：

一个抽象模型有两个方面，其中一个方面依赖于另一个方面。将这些方面封装在独立的对象中使它们可以各自独立地改变和复用。
一个对象的改变将导致其他一个或多个对象也发生改变，而不知道具体有多少对象将发生改变，可以降低对象之间的耦合度。
一个对象必须通知其他对象，而并不知道这些对象是谁。
需要在系统中创建一个触发链，A对象的行为将影响B对象，B对象的行为将影响C对象……，可以使用观察者模式创建一种链式触发机制。

优点：

观察者和被观察者是抽象耦合的；建立了一套触发机制

缺点：

1、如果一个被观察者对象有很多的直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间。
2、如果在观察者和观察目标之间有循环依赖的话，观察目标会触发它们之间进行循环调用，可能导致系统崩溃。
3、观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的，而仅仅只是知道观察目标发生了变化。

组成：

主题对象（Subject）具有注册和移除观察者、并通知所有观察者的功能，主题是通过维护一张观察者列表来实现这些操作的。
观察者（Observer）的注册功能需要调用主题的 registerObserver() 方法。

类图：

原始普通方案的类图

原始方案的缺点：
无法在运行时动态地添加第三方（网站等）
违反ocp原则（在WheatherData中，每增加一个第三方都需要创建一个对应的第三方的公告板对象，并加入到dataChange，不利于维护，也不是动态加入）

使用观察者模式的源码

JDK的Observable类

　　public interface Observer{
        void update(Observable o,Object arg);
}
Observable就等同于前文中的Subject，但它是一个类不是接口，类中已经实现了核心方法（add,delete,notify），通过继承来实现观察者模式。
Observer等同于前文中的Observer，有update方法。

java.util.EventListener
javax.servlet.http.HttpSessionBindingListener

具体实现

1.创建Subject接口和Observer接口

//主题对象接口，让WeatherData来实现
public interface Subject {

    public void registerObserver(Observer o);
    public void removeObserver(Observer o);
    public void notifyObservers();

}

//观察者接口，有很多观察者来实现
public interface Observer {

    public void update(float temperature,float pressure,float humidity);

}

2.创建Subject接口的具体实现类WeatherData

package Observer;

import java.util.ArrayList;

/**
 * @title: WeatherData
 * @Author yzhengy
 * @Date: 2020/7/25 18:27
 * @Question:
 * 本类是核心
 * 1. 包含最新的天气情况信息
 * 2. 含有观察者集合，使用ArrayList管理
 * 3. 当数据有更新时，就主动的调用ArrayList, 通知所有的（接入方）就看到最新的信息
 */
public class WeatherData implements Subject{

    private float temperature;
    private float pressure;
    private float humidity;

    private ArrayList<Observer> observers;//观察者集合

    //加入新的第三方
    public WeatherData() {
        observers = new ArrayList<Observer>();
    }

    public float getTemperature() {
        return temperature;
    }

    public float getPressure() {
        return pressure;
    }

    public float getHumidity() {
        return humidity;
    }

    public void dataChange(){
        notifyObservers();//调用接入方的update方法
    }

    //有数据更新时，就调用setData
    public void setData(float temperature,float pressure,float humidity){
        this.temperature = temperature;
        this.pressure = pressure;
        this.humidity = humidity;
        //调用dataChange，将最新的数据推送给接入方CurrentCondition
        dataChange();
    }

    @Override
    public void registerObserver(Observer o) {
        observers.add(o);//注册一个观察者
    }

    @Override
    public void removeObserver(Observer o) {
        if (observers.contains(o))
        observers.remove(o);//移除一个观察者
    }

    @Override
    public void notifyObservers() {
        //遍历所有的观察者，并通知
        for (int i = 0; i <observers.size() ; i++) {
            observers.get(i).update(this.temperature,this.pressure,this.humidity);
        }
    }
}

3.创建Observer接口的具体实现类

package Observer;

/**
 * @title: CurrentCondition
 * @Author yzhengy
 * @Date: 2020/7/25 18:41
 * @Question:
 */
public class CurrentCondition implements Observer{

    //温度，气压，湿度
    private float temperature;
    private float pressure;
    private float humidity;

    //更新天气情况
    @Override
    public void update(float temperature, float pressure, float humidity) {
        this.temperature = temperature;
        this.humidity = humidity;
        this.pressure = pressure;
        display();
    }

    //显示
    private void display() {
        System.out.println("***Today mTemperature: " + temperature + "***");
        System.out.println("***Today mPressure: " + pressure + "***");
        System.out.println("***Today mHumidity: " + humidity + "***");
    }
}

4.最后写一个Client类用来调用接口并测试

package Observer;

import javafx.beans.binding.When;

/**
 * @title: Client
 * @Author yzhengy
 * @Date: 2020/7/25 18:45
 * @Question:
 */
public class Client {

    public static void main(String[] args) {
        //创建一个WeatherData
        WeatherData weatherData = new WeatherData();

        //创建观察者
        CurrentCondition currentCondition = new CurrentCondition();
        BaiduSite baiduSite = new BaiduSite();

        //将观察者注册到WeatherData
        weatherData.registerObserver(currentCondition);
        //weatherData.registerObserver(baiduSite);

        //测试
        System.out.println("通知各个注册的观察者查看信息");
        //weatherData.setData(10f,100f,30f);

        weatherData.removeObserver(currentCondition);
        System.out.println();
        System.out.println("通知各个注册的观察者, 看看信息");
        weatherData.setData(100f, 100f, 30.3f);
    }

}

5.以后想添加一个新的网站时，只需要创建一个新的类实现Observer接口，并将新的观察者注册到WeatherData中即可。
例如：在百度站点也想实时显示天气

package Observer;

/**
 * @title: BaiduSite
 * @Author yzhengy
 * @Date: 2020/7/25 18:55
 * @Question:
 */
public class BaiduSite implements Observer {
    // 温度，气压，湿度
    private float temperature;
    private float pressure;
    private float humidity;

    // 更新天气情况
    public void update(float temperature, float pressure, float humidity) {
        this.temperature = temperature;
        this.pressure = pressure;
        this.humidity = humidity;
        display();
    }

    // 显示
    public void display() {
        System.out.println("===百度网站====");
        System.out.println("***百度网站 气温 : " + temperature + "***");
        System.out.println("***百度网站 气压: " + pressure + "***");
        System.out.println("***百度网站 湿度: " + humidity + "***");
    }
}