设计模式之观察者模式二

问题

气象站变化，需要实时更新布告板（平均 实时 最高 最低），布告板维度变动大（采集维度可能会随时修改） Zookeeper的订阅等

需求

如何解决对象之间的一对多依赖，当一个对象改变状态时，它的所有的依赖者都会自动更新

解决方案

Subject（主题接口）：对象使用此接口注册为观察者，或者把自己从观察者中删除 Observer：所有潜在的观察者必须实现观察者接口，只有update方法，是当主题状态变化时被调用的方法 ConcreteObject:一个具体主题总是实现主题接口，除了注册和撤销方法之外，具体主题还是先了notifyObserver()方法，此方法用于状态改变时更新所有当前观察者 ConcreteObserver:具体的观察者可以是实现此接口任意类。观察者必须注册具体主题，以便接收更新

代码

抽象主题

public interface Subject { public void registerObserver(Observer o); public void removeObserver(Observer o); public void notifyObservers(); }

具体主题

public class WeatherData implements Subject { private ArrayList observers = null; // 观察者列表 private float temperature; // 温度 private float humidity; // 湿度 private float pressure; // 气压 public WeatherData() { observers = new ArrayList(); } @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 = (Observer) observers.get(i); observer.update(temperature, humidity, pressure); } } public void measurementsChanged() { notifyObservers(); } public void setMeasurements(float temperature, float humidity, float pressure) { this.temperature = temperature; this.humidity = humidity; this.pressure = pressure; measurementsChanged(); } }

观察者接口

public interface Observer { public void update(float temperature, float humidity, float pressure); }

推拉

在观察者模式中，又分为推模型和拉模型两种方式。 　　●　　推模型 　　　　 主题对象向观察者推送主题的详细信息，不管观察者是否需要，推送的信息通常是主题对象的全部或部分数据。 　　●　　拉模型 　　　　 主题对象在通知观察者的时候，只传递少量信息。如果观察者需要更具体的信息，由观察者主动到主题对象中获取，相当于是观察者从主题对象中拉数据。一般这种模型的实现中，会把主题对象自身通过update()方法传递给观察者，这样在观察者需要获取数据的时候，就可以通过这个引用来获取了。