北京北大青鳥學(xué)校講解:Java語言提供的對觀察者模式的支持

北京北大青鳥學(xué)校學(xué)術(shù)部老師介紹:在Java語言的java.util庫里面,提供了一個(gè)Observable類以及一個(gè)Observer接口,構(gòu)成Java語言對觀察者模式的支持。

Observer接口

這個(gè)接口只定義了一個(gè)方法,update()。當(dāng)被觀察者對象的狀態(tài)發(fā)生變化時(shí),這個(gè)方法就會(huì)被調(diào)用。這個(gè)方法的實(shí)現(xiàn)應(yīng)當(dāng)調(diào)用每一個(gè)被觀察者對象的notifyObservers()方法,從而通知所有的觀察對象。(北大青鳥課程

北大青鳥學(xué)校

java.util提供的Observer接口的類圖


package java.util;

public interface Observer
{
/**
* 當(dāng)被觀察的對象發(fā)生變化時(shí),這個(gè)方法會(huì)被調(diào)用。
*/
void update(Observable o, Object arg);
}
代碼清單5、java.util.Observer接口的源代碼。

Observable類

北京北大青鳥學(xué)校講師介紹,被觀察者類都是java.util.Observable類的子類。java.util.Observable提供公開的方法支持觀察者對象,這些方法中有兩個(gè)對Observable的子類非常重要:一個(gè)是setChanged(),另一個(gè)是notifyObservers()。第一個(gè)方法setChanged()被調(diào)用之后會(huì)設(shè)置一個(gè)內(nèi)部標(biāo)記變量,代表被觀察者對象的狀態(tài)發(fā)生了變化。第二個(gè)是notifyObservers(),這個(gè)方法被調(diào)用時(shí),會(huì)調(diào)用所有登記過的觀察者對象的update()方法,使這些觀察者對象可以更新自己。

北京北大青鳥學(xué)校講師介紹,java.util.Observable類還有其它的一些重要的方法。比如,觀察者對象可以調(diào)用java.util.Observable類的addObserver()方法,將對象一個(gè)一個(gè)加入到一個(gè)列表上。當(dāng)有變化時(shí),這個(gè)列表可以告訴notifyObservers()方法那些觀察者對象需要通知。由于這個(gè)列表是私有的,因此java.util.Observable的子對象并不知道觀察者對象一直在觀察著它們。

北大青鳥學(xué)校

Java語言提供的被觀察者的類圖

被觀察者類Observable的源代碼:
 
 package java.util;
 public class Observable
  {
 private boolean changed = false;
 private Vector obs;
 
  /** 用0個(gè)觀察者構(gòu)造一個(gè)被觀察者。**/
 
 public Observable()
  {
 obs = new Vector();
 }
 
  /**
 * 將一個(gè)觀察者加到觀察者列表上面。
 */
 public synchronized void addObserver(Observer o)
  {
 if (!obs.contains(o))
  {
 obs.addElement(o);
 }
 }
 
  /**
 * 將一個(gè)觀察者對象從觀察者列表上刪除。(北大青鳥課程)
 */
 public synchronized void deleteObserver(Observer o)
  {
 obs.removeElement(o);
 }
 
  /**
 * 相當(dāng)于 notifyObservers(null)
 */
 public void notifyObservers()
  {
 notifyObservers(null);
 }
 
  /**
 * 如果本對象有變化(那時(shí)hasChanged 方法會(huì)返回true)
 * 調(diào)用本方法通知所有登記在案的觀察者,即調(diào)用它們的update()方法,
 * 傳入this和arg作為參量。
 */
 public void notifyObservers(Object arg)
  {
  /**
 * 臨時(shí)存放當(dāng)前的觀察者的狀態(tài)。參見備忘錄模式。
 */
 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);
 }
 
  /**
 * 將觀察者列表清空
 */
 public synchronized void deleteObservers()
  {
 obs.removeAllElements();
 }
 
  /**
 * 將“已變化”設(shè)為true
 */
 protected synchronized void setChanged()
  {
 changed = true;
 }
 
  /**
 * 將“已變化”重置為false
 */
 protected synchronized void clearChanged()
  {
 changed = false;
 }
 
  /**
 * 探測本對象是否已變化
 */
 public synchronized boolean hasChanged()
  {
 return changed;
 }
 
  /**
 * 返還被觀察對象(即此對象)的觀察者總數(shù)。
 */
 public synchronized int countObservers()
  {
 return obs.size();
 }
 }
 

代碼清單6、java.util.Observer接口的源代碼。 (北大青鳥課程)

北京北大青鳥學(xué)校講師介紹,這個(gè)Observable類代表一個(gè)被觀察者對象。一個(gè)被觀察者對象可以有數(shù)個(gè)觀察者對象,一個(gè)觀察者可以是一個(gè)實(shí)現(xiàn)Observer接口的對象。在被觀察者對象發(fā)生變化時(shí),它會(huì)調(diào)用Observable的notifyObservers方法,此方法調(diào)用所有的具體觀察者的update()方法,從而使所有的觀察者都被通知更新自己。見下面的類圖:
北大青鳥學(xué)校

使用Java語言提供的對觀察者模式的支持

發(fā)通知的次序在這里沒有指明。Observerable類所提供的缺省實(shí)現(xiàn)會(huì)按照Observers對象被登記的次序通知它們,但是Observerable類的子類可以改掉這一次序。子類并可以在單獨(dú)的線程里通知觀察者對象;或者在一個(gè)公用的線程里按照次序執(zhí)行。

北京北大青鳥學(xué)校講解,當(dāng)一個(gè)可觀察者對象剛剛創(chuàng)立時(shí),它的觀察者集合是空的。兩個(gè)觀察者對象在它們的equals()方法返回true時(shí),被認(rèn)為是兩個(gè)相等的對象。 (北京北大青鳥學(xué)校學(xué)術(shù)部提供)

 

北大青鳥網(wǎng)上報(bào)名
北大青鳥招生簡章