Java觀察者設(shè)計模式詳解
觀察者模式(有時又被稱為發(fā)布(publish )-訂閱(Subscribe)模式、模型-視圖(View)模式、源-收聽者(Listener)模式或從屬者模式)是軟件設(shè)計模式的一種。在此種模式中,一個目標(biāo)物件管理所有相依于它的觀察者物件,并且在它本身的狀態(tài)改變時主動發(fā)出通知。這通常透過呼叫各觀察者所提供的方法來實(shí)現(xiàn)。此種模式通常被用來實(shí)現(xiàn)事件處理系統(tǒng)。
觀察者模式(Observer)完美的將觀察者和被觀察的對象分離開。舉個例子,用戶界面可以作為一個觀察者,業(yè)務(wù)數(shù)據(jù)是被觀察者,用戶界面觀察業(yè)務(wù)數(shù)據(jù)的變化,發(fā)現(xiàn)數(shù)據(jù)變化后,就顯示在界面上。面向?qū)ο笤O(shè)計的一個原則是:系統(tǒng)中的每個類將重點(diǎn)放在某一個功能上,而不是其他方面。一個對象只做一件事情,并且將他做好。觀察者模式在模塊之間劃定了清晰的界限,提高了應(yīng)用程序的可維護(hù)性和重用性。
觀察者設(shè)計模式定義了對象間的一種一對多的依賴關(guān)系,以便一個對象的狀態(tài)發(fā)生變化時,所有依賴于它的對象都得到通知并自動刷新。
實(shí)現(xiàn)方式:
觀察者模式有很多實(shí)現(xiàn)方式,從根本上說,該模式必須包含兩個角色:觀察者和被觀察對象。在剛才的例子中,業(yè)務(wù)數(shù)據(jù)是被觀察對象,用戶界面是觀察者。觀察者和被觀察者之間存在“觀察”的邏輯關(guān)聯(lián),當(dāng)被觀察者發(fā)生改變的時候,觀察者就會觀察到這樣的變化,并且做出相應(yīng)的響應(yīng)。如果在用戶界面、業(yè)務(wù)數(shù)據(jù)之間使用這樣的觀察過程,可以確保界面和數(shù)據(jù)之間劃清界限,假定應(yīng)用程序的需求發(fā)生變化,需要修改界面的表現(xiàn),只需要重新構(gòu)建一個用戶界面,業(yè)務(wù)數(shù)據(jù)不需要發(fā)生變化。
1、觀察者
(Observer)將自己注冊到被觀察對象(Subject)中,被觀察對象將觀察者存放在一個容器(Container)里。
2、被觀察
被觀察對象發(fā)生了某種變化(如圖中的SomeChange),從容器中得到所有注冊過的觀察者,將變化通知觀察者。
3、撤銷觀察
觀察者告訴被觀察者要撤銷觀察,被觀察者從容器中將觀察者去除。
觀察者將自己注冊到被觀察者的容器中時,被觀察者不應(yīng)該過問觀察者的具體類型,而是應(yīng)該使用觀察者的接口。這樣的優(yōu)點(diǎn)是:假定程序中還有別的觀察者,那么只要這個觀察者也是相同的接口實(shí)現(xiàn)即可。一個被觀察者可以對應(yīng)多個觀察者,當(dāng)被觀察者發(fā)生變化的時候,他可以將消息一一通知給所有的觀察者?;诮涌冢皇蔷唧w的實(shí)現(xiàn)——這一點(diǎn)為程序提供了更大的靈活性。
示范代碼:
定義被觀察的角色抽象類:
package test.edu.mainrole;
import java.util.ArrayList;
public abstract class AbsRole {
private ArrayList<IObserver> list = new ArrayList<IObserver>();
public void add(IObserver observer) {
list.add(observer);
}
public void delete(IObserver observer) {
list.remove(observer);
}
public void nodifyObservers(String newState) {
for (IObserver observer : list) {
observer.update(newState);
}
}
}
被觀察角色子類:
package test.edu.mainrole;
public class Role extends AbsRole {
private String state;
public String getState() {
return state;
}
public void change(String nupdate) {
state = nupdate;
this.nodifyObservers(state);
}
}
定義觀察者接口:
package test.edu.mainrole;
public interface IObserver {
public void update(String newState);
}
具體的觀察者:
package test.edu.mainrole;
public class ObserverObj1 implements IObserver{
private String observerState;
@Override
public void update(String state) {
observerState = state;
System.out.println("觀察者1的狀態(tài)為:" + observerState);
}
}
package test.edu.mainrole;
public class ObserverObj2 implements IObserver {
private String observerState;
@Override
public void update(String state) {
observerState = state;
System.out.println("觀察者2的狀態(tài)為:" + observerState);
}
}
測試客戶端:
package test.edu.mainrole;
public class Client {
/**
* @param args
*/
public static void main(String[] args) {
Role subject = new Role();
IObserver observer1 = new ObserverObj1();
IObserver observer2 = new ObserverObj2();
subject.add(observer1);
subject.add(observer2);
subject.change("update!");
}
}
運(yùn)行結(jié)果:
觀察者1的狀態(tài)為:update! 觀察者2的狀態(tài)為:update!
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所啟發(fā)。
相關(guān)文章
關(guān)于注解式的分布式Elasticsearch的封裝案例
這篇文章主要介紹了關(guān)于注解式的分布式Elasticsearch的封裝案例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-01-01
利用Jmeter發(fā)送Java請求的實(shí)戰(zhàn)記錄
JMeter是Apache組織的開放源代碼項目,它是功能和性能測試的工具,100%的用java實(shí)現(xiàn),下面這篇文章主要給大家介紹了關(guān)于如何利用Jmeter發(fā)送Java請求的相關(guān)資料,需要的朋友可以參考下2021-09-09

