在Java中我們通過Observable類和Observer接口實作了觀察者模式。Observer對象是觀察者,Observable對象是被觀察者。
1. 實作觀察者模式
實作觀察者模式非常簡單,
[1]建立被觀察者類, 讓它繼承自java.util.Observable類; [2]建立觀察者類, 它實作java.util.Observer接口; 注意他們分别是繼承被觀察者類和實作觀察者接口,
[3]對于被觀察者類,
添加它的觀察者:
void addObserver(Observer o) // 我們需要為被觀察者注冊他的監督者,也就是觀察者
addObserver()方法把觀察者對象添加到觀察者對象清單中。
當被觀察事件發生時,執行: 一定要注意下面兩個重要
setChanged();
notifyObservers();
setChange()方法用來設定一個内部标志位注明資料發生了變化;notifyObservers()方法會去調用觀察者對象清單中所有的Observer的update()方法,通知它們資料發生了變化。
隻有在setChange()被調用後,notifyObservers()才會去調用update()。update()方法是我們實作觀察者Oberver接口唯一複寫的方法,也是我們當被觀察者發生時間後,最終我們觀察者要調用的方法。 update()方法應該是觀察者監聽被觀察者發生事件變化時,采取的行動
[4]對于觀察者類,實作Observer接口的唯一方法update
void update(Observable o, Object arg)
形參Object arg,對應一個由notifyObservers(Object arg);傳遞來的參數,當執行的是notifyObservers();時,arg為null。
2.執行個體一
NumObserable是一個被觀察者,當它的成員變量data的數值發生變化時,會通知所有的觀察者。
NumObserable.java
package com.zj.observer;
import java.util.Observable;
public class NumObservable extends Observable {
private int data = 0;
public int getData() {
return data;
}
public void setData(int i) { // 定義了我們發生資料修改和指派時,通知觀察者,實作了對資料修改的監聽
data = i;
setChanged();
notifyObservers(); // 觀察者和被觀察者内部就是通過這兩個方法實作了回調和同步
}
}
NumObserver是觀察者。當它的被觀察者(NumObserable)執行了notifyObservers()後,它會執行update()方法。
NumObserver.java
package com.zj.observer;
import java.util.Observable;
import java.util.Observer;
public class NumObserver implements Observer{
public void update(Observable o, Object arg) {
NumObservable myObserable=(NumObservable) o;
System.out.println("Data has changed to " +myObserable.getData()); // 當update()方法是當被觀察者已經發生變化時,回調過來要走的方法,裡面的兩個參數,分别是我們被觀察者對象和監聽的被觀察者屬性
}
}
測試類SingleTest,在這裡将觀察者加入到被觀察者的觀察清單中。
SingleTest.java
package com.zj.observer;
public class SingleTest {
public static void main(String[] args) {
NumObservable number = new NumObservable();
number.addObserver(new NumObserver());
number.setData(1);
number.setData(2);
number.setData(3);
}
}
結果:
Data has changed to 1
Data has changed to 2
Data has changed to 3
3.執行個體二
這個執行個體中,還是對data進行觀察,擁有兩個觀察者,分别觀察奇數和偶數的變化,通過notifyObservers(arg)中的參數arg來識别通知資訊。
被觀察者NumsObservable.java
package com.zj.observers;
import java.util.Observable;
public class NumsObservable extends Observable {
public final static Integer ODD = 1;
public final static Integer EVEN = 2;
private int data = 0;
public int getData() {
return data;
}
public void setData(int i) {
data = i;
Integer flag = EVEN;
if ((data & 0x0001) == 1)
flag = ODD;
setChanged();
notifyObservers(flag); // 該方法可以傳遞任意參數,傳遞的值就是我們需要監聽的屬性值,目的是使得觀察者拿到變化的屬性對象
}
}
奇數觀察者OddObserver.java
package com.zj.observers;
import java.util.Observable;
import java.util.Observer;
public class OddObserver implements Observer {
public void update(Observable o, Object arg) {
if (arg == NumsObservable.ODD) {
NumsObservable myObserable = (NumsObservable) o;
System.out.println("OddObserver:Data has changed to " + myObserable.getData());
}
}
}
偶數觀察者EvenObserver.java
package com.zj.observers;
import java.util.Observable;
import java.util.Observer;
// 分開定義了兩個觀察者 分别接受奇數和偶數的變化 ,其實這個時候被觀察者已經發生了變化,我們隻是判斷需要接受哪一個變化
public class EvenObserver implements Observer {
public void update(Observable o, Object arg) {
if (arg == NumsObservable.EVEN) {
NumsObservable myObserable = (NumsObservable) o;
System.out.println("EvenObserver:Data has changed to " + myObserable.getData());
}
}
}
測試類MultiTest.java
package com.zj.observers;
public class MultiTest {
public static void main(String[] args) {
NumsObservable number = new NumsObservable();
number.addObserver(new OddObserver());
number.addObserver(new EvenObserver());
number.setData(1);
number.setData(2);
number.setData(3);
}
}
結果:
OddObserver:Data has changed to 1
EvenObserver:Data has changed to 2
OddObserver:Data has changed to 3