爪哇語言觀察者模式介紹

2019-11-18 12:16:26

字體：大中小

來源：轉載

供稿：網友

　　簡單地說，觀察者模式定義了一個一對多的依靠關系，讓一個或多個觀察者對象監察一個主題對象。這樣一個主題對象在狀態上的變化能夠通知所有的依靠于此對象的那些觀察者對象，使這些觀察者對象能夠自動更新。
　　觀察者模式的結構
　　觀察者（Observer）模式是對象的行為型模式，又叫做發表-訂閱（Publish/Subscribe）模式、模型-視圖（Model/View）模式、源-收聽者（Source/Listener）模式或從屬者（Dependents）模式。
　　本模式的類圖結構如下：
　　　爪哇語言觀察者模式介紹（圖一）

　　圖1、觀察者模式的靜態結構可從類圖中看清楚。　
　　在觀察者模式里有如下的角色：
　　. 抽象主題（Subject）角色：主題角色把所有的觀察者對象的引用保存在一個列表里；每個主題都可以有任何數量的觀察者。主題提供一個接口可以加上或撤銷觀察者對象；主題角色又叫做抽象被觀察者(Observable)角色；
　　　爪哇語言觀察者模式介紹（圖二）

　　圖2、抽象主題角色，有時又叫做抽象被觀察者角色，可以用一個抽象類或者一個接口實現；在具體的情況下也不排除使用具體類實現?！?br />　　. 抽象觀察者（Observer）角色：為所有的具體觀察者定義一個接口，在得到通知時更新自己；
　　　爪哇語言觀察者模式介紹（圖三）

　　圖3、抽象觀察者角色，可以用一個抽象類或者一個接口實現；在具體的情況下也不排除使用具體類實現。　
　　. 具體主題（ConcreteSubject）角色：保存對具體觀察者對象有用的內部狀態；在這種內部狀態改變時給其觀察者發出一個通知；具體主題角色又叫作具體被觀察者角色；
　　　爪哇語言觀察者模式介紹（圖四）

　　圖4、具體主題角色，通常用一個具體子類實現?！?br />　?。唧w觀察者（ConcreteObserver）角色：保存一個指向具體主題對象的引用；和一個與主題的狀態相符的狀態。具體觀察者角色實現抽象觀察者角色所要求的更新自己的接口，以便使本身的狀態與主題的狀態自恰。
　　　爪哇語言觀察者模式介紹（圖五）

　　圖5、具體觀察者角色，通常用一個具體子類實現?！?br />　　下面給出一個示意性實現的java代碼。首先在這個示意性的實現里，用一個Java接口實現抽象主題角色，這就是下面的Subject接口：
　　public interface Subject
　　{
　　public void attach(Observer observer);
　　public void detach(Observer observer);
　　void notifyObservers();
　　}
　　代碼清單1、Subject接口的源代碼。
　　這個抽象主題接口規定出三個子類必須實現的操作，即 attach() 用來增加一個觀察者對象；detach() 用來刪除一個觀察者對象；和notifyObservers() 用來通知各個觀察者刷新它們自己。抽象主題角色實際上要求子類保持一個以所有的觀察者對象為元素的列表。
　　具體主題則是實現了抽象主題Subject接口的一個具體類，它給出了以上的三個操作的具體實現。從下面的源代碼可以看出，這里給出的Java實現使用了一個Java向量來保存所有的觀察者對象，而 attach() 和 detach() 操作則是對此向量的元素增減操作。
　　import java.util.Vector;
　　import java.util.Enumeration;
　　public class ConcreteSubject implements Subject
　　public void attach(Observer observer)
　　{
　　observersVector.addElement(observer);
　　}
　　public void detach(Observer observer)
　　{
　　observersVector.removeElement(observer);
　　}
　　public void notifyObservers()
　　{
　　Enumeration enumeration = observers();
　　while (enumeration.hasMoreElements())
　　{
　　((Observer)enumeration.nextElement()).update();
　　}
　　}
　　public Enumeration observers()
　　{
　　return (（Vector) observersVector.clone()).elements();
　　}
　　PRivate Vector observersVector = new java.util.Vector();
　　}
　　代碼清單2、ConcreteSubject類的源代碼。
　　抽象觀察者角色的實現實際上是最為簡單的一個，它是一個Java接口，只聲明了一個方法，即update()。這個方法被子類實現后，一被調用便刷新自己。
　　public interface Observer
　　{
　　void update();
　　}
　　代碼清單3、Observer接口的源代碼。
　　具體觀察者角色的實現其實只涉及update()方法的實現。這個方法怎么實現與應用密切相關，因此本類只給出一個框架。
　　public class ConcreteObserver implements Observer
　　{
　　public void update()
　　{
　　// Write your code here
　　}
　　}
　　代碼清單4、ConcreteObserver類的源代碼。
　　雖然觀察者模式的實現方法可以有設計師自己確定，但是因為從AWT1.1開始視窗系統的事件模型采用觀察者模式，因此觀察者模式在Java語言里的地位較為重要。正因為這個原因，Java語言給出了它自己對觀察者模式的支持。因此，本文建議讀者在自己的系統中應用觀察者模式時，不妨利用Java語言所提供的支持。
　　Java語言提供的對觀察者模式的支持
　　在Java語言的java.util庫里面，提供了一個Observable類以及一個Observer接口，構成Java語言對觀察者模式的支持。
　　Observer接口
　　這個接口只定義了一個方法，update()。當被觀察者對象的狀態發生變化時，這個方法就會被調用。這個方法的實現應當調用每一個被觀察者對象的notifyObservers()方法，從而通知所有的觀察對象。
　　　爪哇語言觀察者模式介紹（圖六）

　　圖6、java.util提供的Observer接口的類圖?！?br />　　package java.util;
　　public interface Observer
　　{
　　/**
　　* 當被觀察的對象發生變化時，這個方法會被調用。
　　*/
　　void update(Observable o, Object arg);
　　}
　　代碼清單5、java.util.Observer接口的源代碼。
　　Observable類
　　被觀察者類都是java.util.Observable類的子類。java.util.Observable提供公開的方法支持觀察者對象，這些方法中有兩個對Observable的子類非常重要：一個是setChanged()，另一個是notifyObservers()。第一個方法setChanged()被調用之后會設置一個內部標記變量，代表被觀察者對象的狀態發生了變化。第二個是notifyObservers()，這個方法被調用時，會調用所有登記過的觀察者對象的update()方法，使這些觀察者對象可以更新自己。
　　java.util.Observable類還有其它的一些重要的方法。比如，觀察者對象可以調用java.util.Observable類的addObserver()方法，將對象一個一個加入到一個列表上。當有變化時，這個列表可以告訴notifyObservers()方法那些觀察者對象需要通知。由于這個列表是私有的，因此java.util.Observable的子對象并不知道觀察者對象一直在觀察著它們。
　　　爪哇語言觀察者模式介紹（圖七）

　　圖7、Java語言提供的被觀察者的類圖?！?br />　　被觀察者類Observable的源代碼：
　　package java.util;
　　public class Observable
　　{
　　private boolean changed = false;
　　private Vector obs;
　　/** 用0個觀察者構造一個被觀察者。**/
　　
　　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）
　　* 調用本方法通知所有登記在案的觀察者，即調用它們的update()方法，
　　* 傳入this和arg作為參量。
　　*/
　　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);
　　}
　　/**
　　* 將觀察者列表清空
　　*/
　　public synchronized void deleteObservers()
　　{
　　obs.removeAllElements();
　　}
　　/**
　　* 將“已變化”設為true
　　*/
　　protected synchronized void setChanged()
　　{
　　changed = true;
　　}
　　/**
　　* 將“已變化”重置為false
　　*/
　　protected synchronized void clearChanged()
　　{
　　changed = false;
　　}
　　/**
　　* 探測本對象是否已變化
　　*/
　　public synchronized boolean hasChanged()
　　{
　　return changed;
　　}
　　/**
　　* 返還被觀察對象（即此對象）的觀察者總數。
　　*/
　　public synchronized int countObservers()
　　{
　　return obs.size();
　　}
　　}
　　代碼清單

上一篇：個案研究：聊天室UML模型一致性問題

下一篇：爪哇語言單態創立性模式介紹(下)