目的
观察者模式其实就是发布-订阅的模式。一个主题（Subject）发布消息，N个观察者（Observer）订阅消息。主题发生变动，观察者可以自动接收到消息，而不需要被动的轮询查询主题是否发生变化
让主题和观察者之间松耦合
- 任何时候，都可以增加新的观察者。主题唯一依赖的东西是一个实现Observer接口的对象列表
- 有新类型的观察者出现时，主题的代码不需要修改。主题不在乎别的，它只会发送通知给所有实现了观察者接口的对象
- 我们可以独立地复用主题或观察者
- 改变主题或观察者其中一方，并不会影响另一方
概念
定义：观察者模式定义了对象之间的一对多依赖，这样一来，当一个对象改变状态时，它的所有依赖者都会收到通知并自动更新
一个主题对应多个观察者
- 主题是具有状态的对象，并且可以控制这些对象（注册、删除、变动通知）
- 观察者使用这些状态，虽然这些状态不属于它们
Demo
场景描述（来自书中例子）
建立一个布告板(CurrentConditionsDisplay)，实时展现气象站监测的气象数据（气温、湿度、气压……）
主题
public interface Subject {
// 注册一个新的观察者
public void registerObserver(Observer o);
// 删除观察者
public void removeObserver(Observer o);
// 状态发生变化时，通知所有的观察者
public void notifyObservers();
}
观察者
public interface Observer {
// 所有的观察者都必须实现这个方法
public void update(float temp, float humidity, float pressure);
}
实现主题接口的气象站
public class WeatherData implements Subject{
// 主题与观察者的唯一依赖就是观察者的列表
// 主动通知的本质就是调用观察者对象的update方法
private ArrayList<Observer> observers;
private float temperature;
private float humidity;
private float pressure;
public WeatherData() {
observers = new ArrayList<>(8);
}
@Override
public void registerObserver(Observer o) {
observers.add(o);
}
@Override
public void removeObserver(Observer o) {
int i = observers.indexOf(o);
if(i > 0) {
observers.remove(i);
}
}
@Override
public void notifyObservers() {
for(int i = 0; i < observers.size(); i++) {
Observer observer = observers.get(i);
observer.update(temperature, humidity, pressure);
}
}
// 当从气象站得到更新观测值时，通知观察者
public void measurementsChanged() {
notifyObservers();
}
// 设置气象监测数据（每次气象监测数值变动调用此方法）
public void setMeasurements(float templateure, float humidity, float pressure) {
this.temperature = templateure;
this.humidity = humidity;
this.pressure = pressure;
measurementsChanged();
}
}
布告板接口
public interface DisplayElement {
// 展现气象监测信息
public void display();
}
布告板实现
public class CurrentConditionsDisplay implements Observer, DisplayElement{
private float temperature;
private float humidity;
private Subject weatherData;
public CurrentConditionsDisplay(Subject weatherData) {
this.weatherData = weatherData;
weatherData.registerObserver(this);
}
@Override
public void update(float temp, float humidity, float pressure) {
this.temperature = temp;
this.humidity = humidity;
display();
}
@Override
public void display() {
System.out.println("当前温度：" + temperature + " 湿度：" + humidity + "%");
}
}
测试
public class WeatherStationTest {
public static void main(String[] args) {
WeatherData weatherData = new WeatherData();
CurrentConditionsDisplay currentDisplay = new CurrentConditionsDisplay(weatherData);
// 气象测量，每次测量完后都会通知布告板（观察者）
weatherData.setMeasurements(80, 65, 30.4f);
weatherData.setMeasurements(81, 66, 30.5f);
}
}
控制台输出如下
当前温度：80.0 湿度：65.0%
当前温度：81.0 湿度：66.0%
Demo解析
-
对象之间的一对多依赖
一个气象站可以有N个布告板订阅气象监测信息，理论上可以无限新增布告板。
-
当一个对象改变状态时，它的所有依赖者都会收到通知并自动更新
每个新增的布告板只需要实现
update方法即可订阅气象监测信息。每次气象监测数据变动时都会主动通知所有的布告板。 -
随心插拔
新增、删除布告板只需要调用主题的
registerObserver或removeObserver方法即可
