觀察者模式是一種行為設計模式。觀察者模式的用途是，當你對一個物件的狀態感興趣，希望在它每次發生變化時獲得通知。在觀察者模式中，觀察另外一個物件狀態的物件叫做Observer觀察者，被觀察的物件叫著Subject被觀察者。根據GoF規則，觀察者模式的意圖是：
複製代碼代碼如下:
定義物件之間一對多的依賴關係，一個物件狀態改變，其他相關聯的物件就會被通知並被自動更新。
Subject(被觀察者)包含了一些需要在其狀態改變時通知的觀察者。因此，他應該提供給觀察者可以register(註冊)自己和unregister(註銷)自己的方法。當Subject(被觀察者)改變的時候，也需要包含一個方法來通知所有觀察者。當通知觀察者的時候，可以推播更新內容，或提供另一種方法來獲得更新內容。
觀察者應該有一種方法，這種方法能夠設定觀察者物件並且可以由被觀察者使用來通知其更新。
JAVA提供了內建的方式來實現觀察者模式，java.util.Observable和java.util.Observer介面。然而他們用的不是很廣泛。因為此實作太簡單，大多數時候我們都不想最後擴充的類別只是實作了觀察者模式，因為JAVA類別不能多繼承。
Java Messages Service(JMS)訊息服務使用觀察者模式與命令模式來實作不同的程式之間的資料的發布和訂閱。
MVC模型-視圖-控制架構也使用觀察者模式，把模型當作被觀察者，視圖視為觀察者。視圖能夠註冊自己到模型上來獲得模型的改變。
觀察者模式例子
在此例中，我們將完成一個簡單的主題討論，觀察者能夠註冊此主題。任何在此主題上的內容提交導致的變更都會通知所有在註冊的觀察者。
基於Subject被觀察者的需求，這個是實現一個基本的Subject接口，此接口定了一系列具體的方法需要在隨後實現接口的具體類中被實現。
複製代碼代碼如下:
package com.journaldev.design.observer;
public interface Subject {
//methods to register and unregister observers
public void register(Observer obj);
public void unregister(Observer obj);
//method to notify observers of change
public void notifyObservers();
//method to get updates from subject
public Object getUpdate(Observer obj);
}
現在創建一個相關聯的觀察者。它需要有一個方法能讓Subject附屬於一個觀察者。另外的方法能夠接受Subject的變更通知。
複製代碼代碼如下:
package com.journaldev.design.observer;
public interface Observer {
//method to update the observer, used by subject
public void update();
//attach with subject to observe
public void setSubject(Subject sub);
}
這種關聯已經建立。現在實現具體的主題。
複製代碼代碼如下:
package com.journaldev.design.observer;
import java.util.ArrayList;
import java.util.List;
public class MyTopic implements Subject {
private List<Observer> observers;
private String message;
private boolean changed;
private final Object MUTEX= new Object();
public MyTopic(){
this.observers=new ArrayList<>();
}
@Override
public void register(Observer obj) {
if(obj == null) throw new NullPointerException("Null Observer");
if(!observers.contains(obj)) observers.add(obj);
}
@Override
public void unregister(Observer obj) {
observers.remove(obj);
}
@Override
public void notifyObservers() {
List<Observer> observersLocal = null;
//synchronization is used to make sure any observer registered after message is received is not notified
synchronized (MUTEX) {
if (!changed)
return;
observersLocal = new ArrayList<>(this.observers);
this.changed=false;
}
for (Observer obj : observersLocal) {
obj.update();
}
}
@Override
public Object getUpdate(Observer obj) {
return this.message;
}
//method to post message to the topic
public void postMessage(String msg){
System.out.println("Message Posted to Topic:"+msg);
this.message=msg;
this.changed=true;
notifyObservers();
}
}
註冊與註銷觀察者方法的實作非常簡單，額外的方法postMessage()將被客戶端應用來提交一個字串訊息給此主題。注意，布林變數用於追蹤主題狀態的變化並且通知觀察者此種變化。這個變數是必須的，因為如果沒有更新，但是有人呼叫notifyObservers()方法，他就不能傳送錯誤的通知資訊給觀察者。
另外要注意的是，notifyObservers()中使用synchronization同步的方式來確保在訊息發佈給主題之前，通知只能被傳送到註冊的觀察者處。
此處是觀察者的實現。他們將一直關注subject物件。
複製代碼代碼如下:
package com.journaldev.design.observer;
public class MyTopicSubscriber implements Observer {
private String name;
private Subject topic;
public MyTopicSubscriber(String nm){
this.name=nm;
}
@Override
public void update() {
String msg = (String) topic.getUpdate(this);
if(msg == null){
System.out.println(name+":: No new message");
}else
System.out.println(name+":: Consuming message::"+msg);
}
@Override
public void setSubject(Subject sub) {
this.topic=sub;
}
}
注意，update()方法的實作使用了被觀察者的getUpdate()來處理更新的訊息。此處應避免把訊息當作參數傳遞給update()方法。
一下為簡單地測試程式來驗證話題類別的實作。
複製代碼代碼如下:
package com.journaldev.design.observer;
public class ObserverPatternTest {
public static void main(String[] args) {
//create subject
MyTopic topic = new MyTopic();
//create observers
Observer obj1 = new MyTopicSubscriber("Obj1");
Observer obj2 = new MyTopicSubscriber("Obj2");
Observer obj3 = new MyTopicSubscriber("Obj3");
//register observers to the subject
topic.register(obj1);
topic.register(obj2);
topic.register(obj3);
//attach observer to subject
obj1.setSubject(topic);
obj2.setSubject(topic);
obj3.setSubject(topic);
//check if any update is available
obj1.update();
//now send message to subject
topic.postMessage("New Message");
}
}
此處為上述輸出內容：
複製代碼代碼如下:
Obj1:: No new message
Message Posted to Topic:New Message
Obj1:: Consuming message::New Message
Obj2:: Consuming message::New Message
Obj3:: Consuming message::New Message</pre>
觀察者模式的UML圖
觀察者模式也被叫做發布訂閱模式。 JAVA中的一些具體應用如下：
1.Swing 中的java.util.EventListener
2.javax.servlet.http.HttpSessionBindingListener
3.javax.servlet.http.HttpSessionAttributeListener
以上為全部的觀察者模式。希望你已經喜歡上它了。在評論中分享你的感受或請分享給其他人。