观察者模式

观察者模式，主要用的场景例子：

某一个气象站，他提供一个数据访问接口，然后有许多其他的气象站要根据气象站提供的数据进行显示。

例如：气象总站获取数据的类。

package 观察者模式;

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

public class WeatherData {

 public float temp;
 public float pressure;
 public void notifyObservers() {

     //气象站 1 = new 气象站1().update (temp,pressure);

     //气象站 2 = new 气象站2().update (temp,pressure);

}

 public void setMeasurements(float temp,float pressure)
 {
  this.temp = temp;
  this.pressure = pressure;
  measureChanged();
 }
 private void measureChanged() {
  notifyObservers();
  
 }

 }

 

通过这种方式有个很明显的缺陷就是，当我们要增多更多的气象站的时候，我们不得不在notifyObservers方法中NEW除更多的对象来。

所以我们首先考虑的就是将WeatherData 实现一个Subject接口：

package 观察者模式;

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

}
//主题中有注册和移除观察者的方法

然后我们创建一个观察者的接口：

package 观察者模式;

public interface Observer {
 public void update(float temp,float pressure);

}

然后我们对刚才的代码进行改写：

package 观察者模式;

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

public class WeatherData implements Subject {

 public List<Observer> list = new ArrayList<Observer>();
 public float temp;
 public float pressure;
 public void notifyObservers() {
  for(int i=0;i<list.size();i++)
  {
   Observer o = (Observer)list.get(i);
   o.update(temp, pressure);
  }

 }

 public void setMeasurements(float temp,float pressure)
 {
  this.temp = temp;
  this.pressure = pressure;
  measureChanged();
 }
 private void measureChanged() {
  notifyObservers();
  
 }

 public void registerObserver(Observer o) {
  list.add(o);

 }

 public void removeObserver(Observer o) {
  list.remove(o);

 }

}

改良后的WeatherData他不关心观察者到底是谁了。这样就可以不用NEW对象了。他将所有实现了Observer类的接口，前提是要注册了WeatherData的。然后将他放入到一个LIST中，当有数据改变的时候，将改变的消息通知所有的气象站。

 

某一个气象站的代码：

package 观察者模式;

public class Observer1 implements Observer ,DisplayElement{

 public float temp;
 public float pressure;
 public Subject sub;
 public Observer1(Subject sub)
 {
  this.sub = sub;
  sub.registerObserver(this);//初始化的时候注册了一个主题
 }
 public void update(float temp, float pressure) {
  this.temp = temp;
  this.pressure = pressure;
  display();
 }
 public void display() {
  System.out.println("Observer1 "+temp+":"+pressure);
  
 }

}

调用类：

package 观察者模式;

public class Test {

 /**
  * @param args
  */
 public static void main(String[] args) {
  WeatherData wd = new WeatherData();
  Observer1 o1 = new Observer1(wd);
  wd.setMeasurements(1, 2);
 }

}