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