北京北大青鳥(niǎo)學(xué)校學(xué)術(shù)部老師介紹:在Java語(yǔ)言的java.util庫(kù)里面,提供了一個(gè)Observable類以及一個(gè)Observer接口,構(gòu)成Java語(yǔ)言對(duì)觀察者模式的支持。
Observer接口
這個(gè)接口只定義了一個(gè)方法,update()。當(dāng)被觀察者對(duì)象的狀態(tài)發(fā)生變化時(shí),這個(gè)方法就會(huì)被調(diào)用。這個(gè)方法的實(shí)現(xiàn)應(yīng)當(dāng)調(diào)用每一個(gè)被觀察者對(duì)象的notifyObservers()方法,從而通知所有的觀察對(duì)象。(北大青鳥(niǎo)課程)
java.util提供的Observer接口的類圖
package java.util;
public interface Observer
{
/**
* 當(dāng)被觀察的對(duì)象發(fā)生變化時(shí),這個(gè)方法會(huì)被調(diào)用。
*/
void update(Observable o, Object arg);
}
代碼清單5、java.util.Observer接口的源代碼。
Observable類
北京北大青鳥(niǎo)學(xué)校講師介紹,被觀察者類都是java.util.Observable類的子類。java.util.Observable提供公開(kāi)的方法支持觀察者對(duì)象,這些方法中有兩個(gè)對(duì)Observable的子類非常重要:一個(gè)是setChanged(),另一個(gè)是notifyObservers()。第一個(gè)方法setChanged()被調(diào)用之后會(huì)設(shè)置一個(gè)內(nèi)部標(biāo)記變量,代表被觀察者對(duì)象的狀態(tài)發(fā)生了變化。第二個(gè)是notifyObservers(),這個(gè)方法被調(diào)用時(shí),會(huì)調(diào)用所有登記過(guò)的觀察者對(duì)象的update()方法,使這些觀察者對(duì)象可以更新自己。
北京北大青鳥(niǎo)學(xué)校講師介紹,java.util.Observable類還有其它的一些重要的方法。比如,觀察者對(duì)象可以調(diào)用java.util.Observable類的addObserver()方法,將對(duì)象一個(gè)一個(gè)加入到一個(gè)列表上。當(dāng)有變化時(shí),這個(gè)列表可以告訴notifyObservers()方法那些觀察者對(duì)象需要通知。由于這個(gè)列表是私有的,因此java.util.Observable的子對(duì)象并不知道觀察者對(duì)象一直在觀察著它們。
Java語(yǔ)言提供的被觀察者的類圖
被觀察者類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è)觀察者對(duì)象從觀察者列表上刪除。(北大青鳥(niǎo)課程)
*/
public synchronized void deleteObserver(Observer o)
{
obs.removeElement(o);
}
/**
* 相當(dāng)于 notifyObservers(null)
*/
public void notifyObservers()
{
notifyObservers(null);
}
/**
* 如果本對(duì)象有變化(那時(shí)hasChanged 方法會(huì)返回true)
* 調(diào)用本方法通知所有登記在案的觀察者,即調(diào)用它們的update()方法,
* 傳入this和arg作為參量。
*/
public void notifyObservers(Object arg)
{
/**
* 臨時(shí)存放當(dāng)前的觀察者的狀態(tài)。參見(jiàn)備忘錄模式。
*/
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;
}
/**
* 探測(cè)本對(duì)象是否已變化
*/
public synchronized boolean hasChanged()
{
return changed;
}
/**
* 返還被觀察對(duì)象(即此對(duì)象)的觀察者總數(shù)。
*/
public synchronized int countObservers()
{
return obs.size();
}
}
代碼清單6、java.util.Observer接口的源代碼。 (北大青鳥(niǎo)課程)
北京北大青鳥(niǎo)學(xué)校講師介紹,這個(gè)Observable類代表一個(gè)被觀察者對(duì)象。一個(gè)被觀察者對(duì)象可以有數(shù)個(gè)觀察者對(duì)象,一個(gè)觀察者可以是一個(gè)實(shí)現(xiàn)Observer接口的對(duì)象。在被觀察者對(duì)象發(fā)生變化時(shí),它會(huì)調(diào)用Observable的notifyObservers方法,此方法調(diào)用所有的具體觀察者的update()方法,從而使所有的觀察者都被通知更新自己。見(jiàn)下面的類圖:
使用Java語(yǔ)言提供的對(duì)觀察者模式的支持
發(fā)通知的次序在這里沒(méi)有指明。Observerable類所提供的缺省實(shí)現(xiàn)會(huì)按照Observers對(duì)象被登記的次序通知它們,但是Observerable類的子類可以改掉這一次序。子類并可以在單獨(dú)的線程里通知觀察者對(duì)象;或者在一個(gè)公用的線程里按照次序執(zhí)行。
北京北大青鳥(niǎo)學(xué)校講解,當(dāng)一個(gè)可觀察者對(duì)象剛剛創(chuàng)立時(shí),它的觀察者集合是空的。兩個(gè)觀察者對(duì)象在它們的equals()方法返回true時(shí),被認(rèn)為是兩個(gè)相等的對(duì)象。 (北京北大青鳥(niǎo)學(xué)校學(xué)術(shù)部提供)