需求

实现一种天气实时更新的程序（天气推送），当气象站数据更新后，天气接口程序去获取最新天气数据，然后将数据分发给所有订阅过 “天气日报” 程序的用户，即使更新数据。

1. 定义

观察者模式是定义了一系列对象之间1的一对多关系,当一个对象改变状态,其他依赖者都会收到通知

2. 组成

• 抽象主题角色: 把所有对观察者的引用保存在一个集合中,每个抽象主题角色都可以有任意数量的观察者,抽象主题提供一个接口,可以增加和删除观察者角色,一般用一个抽象类或接口来实现.
• 抽象观察者角色: 为所有具体的观察者定义一个接口,在得到主题的通知时更新自己.
• 具体主题角色: 在具体主题内部状态改变时,给所有登记过的观察者发出通知,具体主题角色通常是一个子类.
• 具体观察者角色: 改角色事项抽象观察者所要求的更新接口,以便是本身的状态与主题的状态一致,

3. 观察者模式原型图

4. 实现

4.1 抽象观察者

/**
 * 
 * 抽象观察者
 */
public interface IObserver {
    void update(String temperature,String humidity,String pressure);
}

4.2 抽象主题

public interface ISubject {

    void registerObserver(IObserver observer);

    void removeObserver(IObserver observer);

    void notifyObserver();
}

4.3 实现观察者

public class ObserverClient implements IObserver {

    private ISubject subject;
    private String name;

    public ObserverClient(ISubject subject, String name) {
        this.subject = subject;
        this.name = name;
        System.out.println("观察者"+name+"开始订阅");
        subject.registerObserver(this);
    }

    public void register(){
        System.out.println("观察者"+name+"开始订阅");
        subject.registerObserver(this);
    }

    public void cancelRegister(){
        System.out.println("观察者"+name+"取消订阅");
        subject.removeObserver(this);
    }

    @Override
    public void update(String temperature, String humidity, String pressure) {
        System.out.println("观察者"+name+"收到更新数据: 温度：" + temperature + " 湿度：" + humidity + " 气压：" + pressure);
    }

}

4.4 实现主题

public class WeatherDataSubject implements ISubject {
    private List<IObserver> observers;
    //温度
    private String temperature;
    //湿度
    private String humidity;
    //气压
    private String pressure;

    public WeatherDataSubject() {
        observers = new ArrayList<>();
    }

    /**
     * 订阅
     * @param observer 观察者
     */
    @Override
    public void registerObserver(IObserver observer) {
        observers.add(observer);
    }

    /**
     * 取消订阅
     * @param observer 观察者
     */
    @Override
    public void removeObserver(IObserver observer) {
        observers.remove(observer);
    }

    /**
     * 通知观察者
     */
    @Override
    public void notifyObserver() {
        System.out.println("通知观察者");
        for (IObserver observer : observers) {
            observer.update(temperature,humidity,pressure);
        }
    }

    /**
     * 更新数据后,通知观察者
     * @param temperature 温度
     * @param humidity    湿度
     * @param pressure    气压
     */
    public void updateDate(String temperature,String humidity,String pressure){
        this.temperature = temperature;
        this.humidity = humidity;
        this.pressure=pressure;
        notifyObserver();
    }

}

4.5 测试

public class Test {

    public static void main(String[] args) {
        WeatherDataSubject weatherDataSubject = new WeatherDataSubject();
        ObserverClient observer1 = new ObserverClient(weatherDataSubject,"观察者1");
        ObserverClient observer2 = new ObserverClient(weatherDataSubject,"观察者2");
        weatherDataSubject.updateDate("35'C","20","30");
        observer1.cancelRegister();
        System.out.println("=============");
        weatherDataSubject.updateDate("30'C","20","30");
        observer1.register();
        System.out.println("============");
        weatherDataSubject.updateDate("25'C","20","30");

    }
}