快捷導(dǎo)航

Java通俗易懂系列設(shè)計模式之觀察者模式

更新時間：2021年04月23日 10:05:13 作者：JaJian

這篇文章主要介紹了Java通俗易懂系列設(shè)計模式之觀察者模式,對設(shè)計模式感興趣的同學(xué)，一定要看一下

介紹

觀察者模式是行為設(shè)計模式之一。當(dāng)您對對象的狀態(tài)感興趣并希望在有任何更改時收到通知時，觀察者設(shè)計模式非常有用。在觀察者模式中，監(jiān)視另一個對象狀態(tài)的對象稱為Observer，正在被監(jiān)視的對象稱為Subject。

根據(jù)GoF，觀察者設(shè)計模式的意圖是;

定義對象之間的一對多依賴關(guān)系，以便當(dāng)一個對象更改狀態(tài)時，將自動通知和更新其所有依賴項。

Subject包含一個觀察者列表，用于通知其狀態(tài)的任何變化，因此它應(yīng)該提供觀察者可以注冊和注銷自己的方法。Subject還包含一種方法，用于通知所有觀察者任何更改，并且可以在通知觀察者時發(fā)送更新，或者它可以提供另一種方法來獲取更新。

Observer應(yīng)該有一個方法來設(shè)置要監(jiān)視的對象，以及Subject將使用的另一個方法來通知它們?nèi)魏胃隆?br /> Java提供了內(nèi)置平臺，用于通過java.util.Observable類和java.util.Observer接口實現(xiàn)Observer模式。但是它沒有被廣泛使用，因為實現(xiàn)非常簡單，并且大多數(shù)時候我們不希望最終擴(kuò)展類只是為了實現(xiàn)Observer模式，因為java不在類中提供多重繼承。

Java消息服務(wù)（JMS）使用Observer設(shè)計模式以及Mediator模式，允許應(yīng)用程序訂閱數(shù)據(jù)并將數(shù)據(jù)發(fā)布到其他應(yīng)用程序。

模型 - 視圖 - 控制器（MVC）框架也使用Observer模式，其中Model是Subject，而Views是觀察者，可以注冊以獲得對模型的任何更改的通知。

觀察者模式Java示例

對于我們的觀察者模式j(luò)ava程序示例，我們將實現(xiàn)一個簡單的Subject，觀察者可以注冊到這個Subject。每當(dāng)有任何新消息發(fā)布到Subject時，將通知所有寄存器觀察者并且他們可以使用該消息。

根據(jù)Subject的要求，這里是基礎(chǔ)Subject接口，它定義了由任何具體Subject實現(xiàn)的契約方法。

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);
	
}

接下來我們將為Observer創(chuàng)建契約，將有一個方法將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);
}

現(xiàn)在我們的契約準(zhǔn)備好了，讓我們繼續(xù)我們Subject的具體實施。

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");
		synchronized (MUTEX) {
		if(!observers.contains(obj)) observers.add(obj);
		}
	}

	@Override
	public void unregister(Observer obj) {
		synchronized (MUTEX) {
		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();
	}

}

注冊和取消注冊觀察者的方法實現(xiàn)非常簡單，額外的方法是postMessage()，戶端應(yīng)用程序?qū)⑹褂盟鼘tring消息發(fā)布到主題。請注意布爾變量，以跟蹤主題狀態(tài)的變化并用于通知觀察者。此變量是必需的，因此如果沒有更新并且某人調(diào)用notifyObservers()，則它不會向觀察者發(fā)送錯誤通知。

還要注意在notifyObservers()方法中使用同步，以確保僅將通知發(fā)送給在將消息發(fā)布到主題之前注冊的觀察者。

以下是將觀察主題的觀察者的實施。

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()方法的實現(xiàn)，它調(diào)用Subject getUpdate()方法來獲取要使用的消息。我們可以通過將message作為參數(shù)傳遞給update()方法來避免這種調(diào)用。

這是一個簡單的測試程序，用于使用我們的Subject主題實現(xiàn)。

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");
	}

}

當(dāng)我們運行上面的程序時，我們得到以下輸出。