观察者模式

观察者模式

定义了对象之间一对多的依赖，这样一来，当一个对象改变状态时，它的所有依赖者都能收到通知并且自动更新。观察者模式提供了一种对象设计，让主题和观察者之间松耦合
下面是摘取HeadFirst上的代码：

1.观察者主题接口

package com.wlw.observer;

/**
 * 观察者主题接口
 */
public interface Subject {

    /**
     * 注册观察者
     * 要有观察者作为变量，该观察者是用来注册或被删除的
     * @param o
     */
    void registerOberver(Observer o);

    /**
     * 移除观察者
     * 要有观察者作为变量，该观察者是用来注册或被删除的
     * @param o
     */
    void removeOberver(Observer o);

    /**
     * 通知观察者
     * 当主题改变时，这个方法被调用，通知所有的观察者
     */
    void notifyObservers();

}

/**
 * 观察者对象
 */
interface Observer{

    /**
     * 所有的观察者必须实现update方法
     * 以实现观察者借口
     * 这里把观测值传入观察者中
     * @param temp
     * @param humidity
     * @param pressure
     */
    void update(float temp, float humidity, float pressure);
}

/**
 * 数据展示
 * 数据展示时调用此方法
 */
interface DisplayElement{
    void display();
}

2.观察者主题

package com.wlw.observer;

import java.util.ArrayList;

/**
 * 观察者主题实例
 */
public class WeatherData implements Subject {



    /**
     * 记录观察者
     * 在此list在构造器中建立
     */
    private ArrayList<Observer> observers;

    private float temperature;

    private float pressure;

    private float humidity;


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

    /**
     * 观察者注册时，我们只要把它加到Arraylist后即可
     * @param o
     */
    @Override
    public void registerOberver(Observer o) {

        observers.add(o);
    }

    /**
     * 同样，取消注册，只需要将观察者从list中删除
     * @param o
     */
    @Override
    public void removeOberver(Observer o) {

        int i = observers.indexOf(o);
        if(i >= 0){
            observers.remove(o);
        }
    }

    /**
     * 把状态告诉每一个观察者
     * 因为观察者都实现了update() 所以我们知道如何通知他们
     */
    @Override
    public void notifyObservers() {

        observers.forEach(e -> e.update(temperature, humidity, pressure));
    }

    /**
     * 从气象站得到更新观测值时，通知观察者
     */
    public void measurementsChanged(){
        notifyObservers();
    }

    /**
     * 手动设置值的改变
     * @param temperature
     * @param humidity
     * @param pressure
     */
    public void setMeasurements(float temperature, float humidity, float pressure){
        this.temperature = temperature;
        this.humidity = humidity;
        this.pressure = pressure;
        measurementsChanged();
    }

    // weatherData 其他方法
}

3.测试程序

package com.wlw.observer;

/**
 * 测试程序
 */
public class WeatherStation {

    public static void main(String[] args) {

        // 建立一个WeatherData(Subject)对象
        WeatherData weatherData = new WeatherData();

        // 建立Observer 对象并注册 Subject
        CurrentConditionDisplay conditionDisplay = new CurrentConditionDisplay(weatherData);

        weatherData.setMeasurements(80, 65, 30.4f);
    }
}

4.输出

Currect condictions: 80.0F degrees and 65.0%humidity