设计模式系列之——观察者模式

我们以一个老生常谈的例子来说明观察者模式——天气预报接口

第一步：天气预报一定有一个数据获取中心（姑且理解为气象局）

①气象局里面一定会有各个用户（网站）的注册信息（只有已经注册了人家气象局有气象数据变化了才能通知你嘛）-registerObserver

②气象局里面一定有一个移除某个用户（网站）的方法-removeObserver

③气象局里面一定有一个通知各个用户（网站）关于气象数据的方法-notifyObservers

第二步：另外，因为用户（网站也可以叫观察者）一定是有多个的，所以这个一定会被设计成一个抽象类或者是接口（我自己是这么理解的），为了体现面向接口编程，我们就设计成接口MyObserver

①MyObserver里面一定有一个方法update，用户（网站）/观察者，需要根据中心的的数据来更新自己的数据

第三步：开始撸代码

气象中心接口：Subject.java

//接口让WeatherData来实现，它的实现类需要聚合观察者
public interface Subject {
    //注册观察者
    void registerObserver(MyObserver o);
    //移除观察者
    void removeObserver(MyObserver o);
    //通知观察者
    void notifyObserver();
}

气象中心接口实现类WeatherData.java

package com.example.demo.designmodel.observer.improve;

import com.example.demo.designmodel.observer.CurrentConditions;

import java.util.ArrayList;
import java.util.List;

/**
 * 类是核心
 * 1. 包含最新的天气情况信息
 * 2. 含有观察者集合
 * 3. 当数据有更新时，就主动的调用   ArrayList通知所有的接入方
 *
 * @author miles zhu
 */
public class WeatherData implements Subject {
    //气温
    private float temperatrue;
    //气压
    private float pressure;
    //湿度
    private float humidity;

    //定义一个集合，用于存放所有的观察者
    //因为观察者不可能只有一个
    private List<MyObserver> observersList;

    private CurrentConditions currentConditions;
    //加入新的第三方

    public WeatherData() {
        observersList = new ArrayList<>();
    }


    //这个方式实际上是用来管理观察者的
    public void dataChange() {
        //调用 接入方的 update
        notifyObserver();
    }

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

    //添加一个观察者
    @Override
    public void registerObserver(MyObserver o) {
        observersList.add(o);
    }

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

    //通知观察者
    @Override
    public void notifyObserver() {
        for (int i = 0; i < observersList.size(); i++) {
            observersList.get(i).update(this.temperatrue, this.pressure, this.humidity);
        }
    }

    //get方法
    public float getTemperature() {
        return temperatrue;
    }

    public float getPressure() {
        return pressure;
    }

    public float getHumidity() {
        return humidity;
    }
}

观察者接口MyObserver.java

package com.example.demo.designmodel.observer.improve;

//观察者接口，由观察者实现
public interface MyObserver {
    //观察者模式的核心方法
    void update(float temperature, float pressure, float humidity);
}

某个实现类CurrentConditions.java

package com.example.demo.designmodel.observer.improve;

/**
 * 文件名：CurrentConditions
 * 作 者：Miles zhu
 * 时 间：2019/7/30 17:04
 * -------------------------
 * 功能和描述：
 **/
public class CurrentConditions  implements MyObserver{
    private float tempurature;
    private float pressure;
    private float humidity;

    @Override
    public void update(float tempurature, float pressure, float humidity) {
        this.tempurature = tempurature;
        this.pressure = pressure;
        this.humidity = humidity;
        display();
    }

    public void display() {
        System.out.println("tempurature============" + tempurature);
        System.out.println("pressure============" + pressure);
        System.out.println("humidity============" + humidity);
    }
}

搞定，先爽一下呗？测试类Client.java

package com.example.demo.designmodel.observer.improve;

/**
 * 文件名：Client
 * 作 者：Miles zhu
 * 时 间：2019/7/30 17:30
 * -------------------------
 * 功能和描述：
 **/
public class Client {
    public static void main(String[] args) {
        //创建一个WeatherData
        WeatherData weatherData = new WeatherData();
        //创建一个观察者
        CurrentConditions currentConditions = new CurrentConditions();
        //将观察者注册到weatherdata
        weatherData.registerObserver(currentConditions);
        weatherData.setData(30.f,150f,10f);
    }
}

然后又加入了一个观察者Baidu.java

package com.example.demo.designmodel.observer.improve;

/**
 * 文件名：Client
 * 作 者：Miles zhu
 * 时 间：2019/7/30 17:30
 * -------------------------
 * 功能和描述：
 **/
public class Client {
    public static void main(String[] args) {
        //创建一个WeatherData
        WeatherData weatherData = new WeatherData();
        //创建一个观察者
        CurrentConditions currentConditions = new CurrentConditions();
        //将观察者注册到weatherdata
        weatherData.registerObserver(currentConditions);

        //将Baidu添加进去----新添加的Baidu这个观察者
        Baidu baidu = new Baidu();
        weatherData.registerObserver(baidu);
        
        weatherData.setData(30.f,150f,10f);
    }
}

输出：

OVER