觀察者模式角色如下：

抽象主題（Subject）角色 ：抽象主題角色提供維護一個觀察者對象聚集的操作方法，對聚集的增加、刪除等。

具體主題（ConcreteSubject）角色 ：將有關狀態存入具體的觀察者對象；在具體主題的內部狀態改變時，給所有登記過的觀察者發出通知。具體主題角色負責實現抽象主題中聚集的管理方法。

抽象觀察者（Observer）角色 ：為具體觀察者提供一個更新接口。

具體觀察者（ConcreteObserver）角色 ：存儲與主題相關的自洽狀態，實現抽象觀察者提供的更新接口。

?

仔細觀察上面的類圖，發現具體主題角色和抽象觀察者之間的連線，是因為具體主題角色維護了一個觀察者引用的聚集，如果有多個具體主題角色，意味著每個具體角色都要維護一個觀察者的聚集，那么能不能將聚集提升到抽象主題里面呢？這個就需要考慮場景，如果多個主題實現在管理上都有很大差異，那么就不能提升到抽象角色中，但是絕大多數情況下，這些聚集管理方法本身就是所有具體主題所共有的，所以大多數情況下都是可以將聚集和聚集的管理都移入到抽象主題中的，因為notifyObserver()方法是依賴于聚集的，所以將notifyObserver()也移入抽象主題中，這樣就形成了如下的另一種觀察者模式結構：

? 我們這里簡單用代碼描述如下：

Java代碼??

1. package ?observer.desc;??
2. /** ?
3. ?*? ?
4. ?*作者：alaric ?
5. ?*時間：2013-8-13下午8:05:08 ?
6. ?*描述：抽象觀察者 ?
7. ?*/ ??
8. public ? interface ?Observer?{??
9. ??????
10. ???? public ? void ?update();??
11. ??????
12. }??

?

Java代碼??

1. package ?observer.desc;??
2. /** ?
3. ?*? ?
4. ?*作者：alaric ?
5. ?*時間：2013-8-13下午8:05:34 ?
6. ?*描述：具體觀察者 ?
7. ?*/ ??
8. public ? class ?ConcreteObserver? implements ?Observer{??
9. ??
10. ???? @Override ??
11. ???? public ? void ?update()?{??
12. ???????? //?寫業務邏輯 ??
13. ????}??
14. ??
15. }??

?

Java代碼??

1. package ?observer.desc;??
2. /** ?
3. ?*? ?
4. ?*作者：alaric ?
5. ?*時間：2013-8-13下午8:05:55 ?
6. ?*描述：抽象主題 ?
7. ?*/ ??
8. public ? interface ?Subject?{??
9. ??
10. ???? public ? void ?attach(Observer?observer);??
11. ??
12. ???? public ? void ?detach(Observer?observer);??
13. ??
14. ???? void ?notifyObservers();??
15. }??

?

Java代碼??

1. package ?observer.desc;??
2. ??
3. import ?java.util.Enumeration;??
4. import ?java.util.Vector;??
5. /** ?
6. ?*? ?
7. ?*作者：alaric ?
8. ?*時間：2013-8-13下午8:09:21 ?
9. ?*描述：具體主題類 ?
10. ?*/ ??
11. public ? class ?ConcreteSubject? implements ?Subject?{??
12. ???? private ?Vector<Observer>observersVector?=? new ?Vector<Observer>();??
13. ???? public ? void ?attach(Observer?observer)?{??
14. ????????observersVector.addElement(observer);??
15. ????}??
16. ??
17. ???? public ? void ?detach(Observer?observer)?{??
18. ????????observersVector.removeElement(observer);??
19. ????}??
20. ??
21. ???? public ? void ?notifyObservers()?{??
22. ????????Enumeration<Observer>enumeration?=?observers();??
23. ???????? while ?(enumeration.hasMoreElements())?{??
24. ????????????((Observer)?enumeration.nextElement()).update();??
25. ????????}??
26. ????}??
27. ??
28. ???? @SuppressWarnings ( "unchecked" )??
29. ???? public ?Enumeration<Observer>?observers()?{??
30. ???????? return ?((Vector<Observer>)?observersVector.clone()).elements();??
31. ????}??
32. ??
33. }???

jdk1.6中API文檔如下描述：

public interface Observer

一個可在觀察者要得到 observable 對象更改通知時可實現 Observer 接口的類。

從以下版本開始：

JDK1.0

另請參見：

Observable

?

public class Observableextends Object

此類表示模型視圖范例中的 observable 對象，或者說“數據”。可將其子類化，表示應用程序想要觀察的對象。

一個 observable 對象可以有一個或多個觀察者。觀察者可以是實現了 Observer 接口的任意對象。一個 observable 實例改變后，調用 Observable 的 notifyObservers 方法的應用程序會通過調用觀察者的 update 方法來通知觀察者該實例發生了改變。

?

未指定發送通知的順序。Observable 類中所提供的默認實現將按照其注冊的重要性順序來通知 Observers，但是子類可能改變此順序，從而使用非固定順序在單獨的線程上發送通知，或者也可能保證其子類遵從其所選擇的順序。

?

注意，此通知機制與線程無關，并且與 Object 類的 wait 和 notify 機制完全獨立。 新創建一個 observable 對象時，其觀察者集是空的。當且僅當 equals 方法為兩個觀察者返回 true 時，才認為它們是相同的。

?

從以下版本開始：

JDK1.0

另請參見：?

notifyObservers(), notifyObservers(java.lang.Object), Observer, Observer.update(java.util.Observable, java.lang.Object)

?

Java代碼??

1. package ?observer;??
2. ??
3. import ?java.util.List;??
4. import ?java.util.Observable;??
5. import ?java.util.Observer;??
6. /** ?
7. ?*? ?
8. ?*作者：alaric ?
9. ?*時間：2013-8-13下午9:32:40 ?
10. ?*描述：警察張三 ?
11. ?*/ ??
12. public ? class ?Police? extends ?Observable?{??
13. ??
14. ???? private ?String?time?;??
15. ???? public ?Police(List<Observer>?list)?{??
16. ???????? super ();??
17. ???????? for ?(Observer?o:list)?{??
18. ????????????addObserver(o);??
19. ????????}??
20. ????}??
21. ???? public ? void ?change(String?time){??
22. ???????? this .time?=?time;??
23. ????????setChanged();??
24. ????????notifyObservers( this .time);??
25. ????}??
26. }??

?

Java代碼??

1. package ?observer;??
2. ??
3. import ?java.util.Observable;??
4. import ?java.util.Observer;??
5. /** ?
6. ?*? ?
7. ?*作者：alaric ?
8. ?*時間：2013-8-13下午9:32:59 ?
9. ?*描述：臥底A ?
10. ?*/ ??
11. public ? class ?UndercoverA? implements ?Observer?{??
12. ??
13. ???? private ?String?time;??
14. ???? @Override ??
15. ???? public ? void ?update(Observable?o,?Object?arg)?{??
16. ????????time?=?(String)?arg;??
17. ????????System.out.println( "臥底A接到消息，行動時間為：" +time);??
18. ????}??
19. ??
20. ??
21. }??

?

Java代碼??

1. package ?observer;??
2. ??
3. import ?java.util.Observable;??
4. import ?java.util.Observer;??
5. /** ?
6. ?*? ?
7. ?*作者：alaric ?
8. ?*時間：2013-8-13下午9:33:14 ?
9. ?*描述：臥底B ?
10. ?*/ ??
11. public ? class ?UndercoverB? implements ?Observer?{??
12. ???? private ?String?time;??
13. ???? @Override ??
14. ???? public ? void ?update(Observable?o,?Object?arg)?{??
15. ????????time?=?(String)?arg;??
16. ????????System.out.println( "臥底B接到消息，行動時間為：" +time);??
17. ????}??
18. ??
19. ??
20. ??
21. }??

?

Java代碼??

1. package ?observer;??
2. ??
3. import ?java.util.ArrayList;??
4. import ?java.util.List;??
5. import ?java.util.Observer;??
6. /** ?
7. ?*? ?
8. ?*作者：alaric ?
9. ?*時間：2013-8-13下午9:32:26 ?
10. ?*描述：測試 ?
11. ?*/ ??
12. public ? class ?Client?{??
13. ??
14. ???? /** ?
15. ?????*?@param?args ?
16. ?????*/ ??
17. ???? public ? static ? void ?main(String[]?args)?{??
18. ????????UndercoverA?o1?=? new ?UndercoverA();??
19. ????????UndercoverB?o2?=? new ?UndercoverB();??
20. ????????List<Observer>?list?=? new ?ArrayList<>();??
21. ????????list.add(o1);??
22. ????????list.add(o2);??
23. ????????Police?subject?=? new ?Police(list);??
24. ????????subject.change( "02:25" );??
25. ????????System.out.println( "===========由于消息敗露，行動時間提前=========" );??
26. ????????subject.change( "01:05" );??
27. ??????????
28. ????}??
29. ??
30. }??

?測試運行結果：

臥底B接到消息，行動時間為：02:25

臥底A接到消息，行動時間為：02:25

===========由于消息敗露，行動時間提前=========

臥底B接到消息，行動時間為：01:05

臥底A接到消息，行動時間為：01:05