设计模式学习——观察者模式（Observer Pattern）

0. 前言

　　观察者模式在许多地方都能够用到，特别是作为MVC模式的一部分，在MVC中，模型（M）：存放数据，视图（V）：显示数据。当模型中的数据发生改变时，视图会得到通知，这是典型的观察者模式。

1. 定义

　　观察者模式：定义了一对多的关系，一个对象作为主题，它维护了一系列的依赖对象，当主题的状态发生改变时，会自动地通知依赖对象（通常通过调用依赖对象的方法来实现）。

　　官方定义：wiki

2. 应用

　　这里通过《Head first 设计模式》中的例子来实现观察者模式。这里有一个气象数据和公布栏，当气象数据发生改变时，会通知公布栏，使其更新数据。

源码：

主题Subject接口：

 package ObserverPattern;

 public interface Subject {

     public void registerObserver( Observer observer );

     public void removeObserver( Observer observer );

     public void notifyObservers();

 }

观察者Observer接口

 package ObserverPattern;

 public interface Observer {

     public void update(Object obj);

 }

气象数据实现：

 package ObserverPattern;

 import java.util.ArrayList;

 import java.util.Iterator;

 public class WeatherData implements Subject {

     private ArrayList<Observer> observers = null;

     private double temperature;

     private double humidity;

     private double pressure;

     public WeatherData(  )

     {

         observers = new ArrayList<>();

     }

     public double getTemperature() {

         return temperature;

     }

     public double getHumidity() {

         return humidity;

     }

     public double getPressure() {

         return pressure;

     }

     public void SetWeather( double temperature, double humidity, double pressure )

     {

         this.temperature = temperature;

         this.humidity = humidity;

         this.pressure = pressure;

         mesurementsChanged();

     }

     public void mesurementsChanged()

     {

         notifyObservers();

     }

     @Override

     public void registerObserver(Observer observer) {

         observers.add(observer);

     }

     @Override

     public void removeObserver(Observer observer) {

         observers.remove(observer);

     }

     @Override

     public void notifyObservers() {

         for ( Iterator<Observer> iterator = observers.iterator();  iterator.hasNext(); ) {

             Observer observer = (Observer) iterator.next();

             observer.update(this);

         }

     }

 }

显示接口：

 package ObserverPattern;

 public interface DisplayBoard {

     public void display();

 }

公布栏实现：

 package ObserverPattern;

 public class CurrentWeatherBoard implements Observer, DisplayBoard {

     private double temperature;

     public CurrentWeatherBoard( Subject subject ) {

         subject.registerObserver(this);

     }

     @Override

     public void update(Object obj) {

         if ( obj instanceof WeatherData ) {

             WeatherData weatherData = (WeatherData)obj;

             this.temperature = weatherData.getTemperature();

             display();

         }

     }

     @Override

     public void display() {

         System.out.println(this.getClass().getName() + ":" +  this.temperature);

     }

 }

3. JDK中Observable类分析

　　在JDK中提供了Observable类以及Observer接口方便实现观察者模式，但是这里的主题是Observable是一个类，需要通过继承来实现，所以很大的限制了它的使用。

　　Observable类的添加观察者方法，通过synchronized实现同步，其Observable内部维护着一个Vector容器，用于存放观察者对象。　　

  public synchronized void addObserver(Observer o) {

         if (o == null)

             throw new NullPointerException();

         if (!obs.contains(o)) {

             obs.addElement(o);

         }

     }

　　通知函数，这里会判断一个标识，所以在调用通知时需要先调用 setChanged 方法，然后将其观察者保存到一个数组中，这里会有一个问题，即当调用删除一个观察者的时候，如果正在调用notifyObservers时，依然会通知到被删除的观察者。对于添加来说也是一样的，会错过这一次的通知。

 public void notifyObservers(Object arg) {

         Object[] arrLocal;

         synchronized (this) {

             if (!changed)

                 return;

             arrLocal = obs.toArray();

             clearChanged();

         }

         for (int i = arrLocal.length-1; i>=0; i--)

             ((Observer)arrLocal[i]).update(this, arg);

     }

巴特西

设计模式学习——观察者模式（Observer Pattern）

最新文章

热门文章