Java觀察者模式

概述

觀察者模式是對(duì)象的行為模式,又叫發(fā)布-訂閱(Publish/Subscribe)模式宙帝、模型-視圖(Model/View)模式丧凤、源-監(jiān)聽器(Source/Listener)模式或從屬者(Dependents)模式。

觀察者模式定義了一種一對(duì)多的依賴關(guān)系步脓,讓多個(gè)觀察者對(duì)象同時(shí)監(jiān)聽某一個(gè)主題對(duì)象愿待。這個(gè)主題對(duì)象在狀態(tài)上發(fā)生變化時(shí),會(huì)通知所有觀察者對(duì)象靴患,使它們能夠自動(dòng)更新自己仍侥。

觀察者模式的結(jié)構(gòu)

一個(gè)軟件系統(tǒng)里面包含了各種對(duì)象,就像一片欣欣向榮的森林充滿了各種生物一樣鸳君。在一片森林中农渊,各種生物彼此依賴和約束,形成一個(gè)個(gè)生物鏈或颊。一種生物的狀態(tài)變化會(huì)造成其他一些生物的相應(yīng)行動(dòng)砸紊,每一個(gè)生物都處于別的生物的互動(dòng)之中。

同樣囱挑,一個(gè)軟件系統(tǒng)常常要求在某一個(gè)對(duì)象的狀態(tài)發(fā)生變化的時(shí)候醉顽,某些其他的對(duì)象做出相應(yīng)的改變。做到這一點(diǎn)的設(shè)計(jì)方案有很多平挑,但是為了使系統(tǒng)能夠易于復(fù)用游添,應(yīng)該選擇低耦合度的設(shè)計(jì)方案。減少對(duì)象之間的耦合有利于系統(tǒng)的復(fù)用通熄,但是同時(shí)設(shè)計(jì)師需要使這些低耦合度的對(duì)象之間能夠維持行動(dòng)的協(xié)調(diào)一致唆涝,保證高度的協(xié)作。觀察者模式是滿足這一要求的各種設(shè)計(jì)方案中最重要的一種棠隐。

下面以一個(gè)簡單的示意性實(shí)現(xiàn)為例石抡,討論觀察者模式的結(jié)構(gòu)。


觀察者模式所涉及的角色有:

1.抽象主題(Subject)角色:

抽象主題角色把所有對(duì)觀察者對(duì)象的引用保存在一個(gè)聚集(比如ArrayList對(duì)象)里助泽,每個(gè)主題都可以有任何數(shù)量的觀察者啰扛。抽象主題提供一個(gè)接口嚎京,可以增加和刪除觀察者對(duì)象,抽象主題角色又叫做抽象被觀察者(Observable)角色。

2.具體主題(ConcreteSubject)角色:

將有關(guān)狀態(tài)存入具體觀察者對(duì)象;在具體主題的內(nèi)部狀態(tài)改變時(shí)方援,給所有登記過的觀察者發(fā)出通知分衫。具體主題角色又叫做具體被觀察者(Concrete Observable)角色。

3.抽象觀察者(Observer)角色:

為所有的具體觀察者定義一個(gè)接口珠叔,在得到主題的通知時(shí)更新自己,這個(gè)接口叫做更新接口。

4.具體觀察者(ConcreteObserver)角色:

存儲(chǔ)與主題的狀態(tài)自恰的狀態(tài)蚓曼。具體觀察者角色實(shí)現(xiàn)抽象觀察者角色所要求的更新接口,以便使本身的狀態(tài)與主題的狀態(tài) 像協(xié)調(diào)钦扭。如果需要纫版,具體觀察者角色可以保持一個(gè)指向具體主題對(duì)象的引用。

源碼

自己編寫的觀察者模式的代碼

/**
 * 抽象的主題(被觀察)角色
 */
public abstract class Subject {

    /**
     * 保存的觀察者集合
     */
    private List<Observer> observerList;

    public Subject(){
        observerList = new ArrayList();
    }

    /**
     * 注冊(cè)觀察者
     * @param observer
     */
    public void registerObserver(Observer observer) {
        observerList.add(observer);
    }

    /**
     * 刪除觀察者
     * @param observer
     */
    public void removeObserver(Observer observer) {
        observerList.remove(observer);
    }

    /**
     * 通知方法客情,通知所有觀察者
     * @param newState
     */
    public void notifyObservers(String newState){
        for(Observer observer: observerList){
            observer.update(newState);
        }
    }

    public abstract void change(String newState);

}
/**
 * 具體的主題對(duì)象
 */
public class ConcreteSubject extends Subject {

    /**
     * 狀態(tài)
     */
    private String state;

    public String getState() {
        return state;
    }

    /**
     * 狀態(tài)改變方法其弊,通知所有的觀察者
     * @param newState
     */
    @Override
    public void change(String newState){
        this.state = newState;
        System.out.println("主題角色狀態(tài)改變:" + newState);
        super.notifyObservers(newState);
    }

}
/**
 * 抽象的觀察者角色
 */
public interface Observer {

    /**
     * 更新的接口,由主題角色調(diào)用膀斋,當(dāng)主題角色狀態(tài)發(fā)生改變時(shí)梭伐,
     * 將調(diào)用所有訂閱者的update方法,并將更新后的狀態(tài)作為參數(shù)傳入
     * @param state
     */
    public void update(String state);

}
/**
 * 具體的觀察者對(duì)象
 */
public class ConcreteObserver implements Observer {

    private String state;

    @Override
    public void update(String newState) {
        state = newState;
        System.out.println("觀察者對(duì)象改變:" + newState);
    }
}

/**
 * 具體的觀察者對(duì)象
 */
public class ConcreteObserver2 implements Observer {

    private String state;

    @Override
    public void update(String newState) {
        state = newState;
        System.out.println("觀察者對(duì)象改變2:" + newState);
    }
}
/**
 * 客戶端
 */
public class Client {

    public static void main(String[] args) {
        //新建主題對(duì)象
        Subject subject = new ConcreteSubject();

        //觀察者1
        Observer observer1 = new ConcreteObserver();

        //觀察者2
        Observer observer2 = new ConcreteObserver();

        //觀察者3
        Observer observer3 = new ConcreteObserver2();

        //訂閱
        subject.registerObserver(observer1);
        subject.registerObserver(observer2);
        subject.registerObserver(observer3);

        //主題對(duì)象狀態(tài)改變
        subject.change("狀態(tài)1");

        System.out.println("------------------");

        //移除觀察者1
        subject.removeObserver(observer1);

        subject.change("狀態(tài)2");
    }

}

推模型和拉模型

在觀察者模式中仰担,又分為推模型和拉模型兩種方式糊识。

  • 推模型
    主題對(duì)象向觀察者推送主題的詳細(xì)信息,不管觀察者是否需要惰匙,推送的信息通常是主題對(duì)象的全部或部分?jǐn)?shù)據(jù)技掏。

  • 拉模型
    主題對(duì)象在通知觀察者的時(shí)候,只傳遞少量信息项鬼。如果觀察者需要更具體的信息哑梳,由觀察者主動(dòng)到主題對(duì)象中獲取,相當(dāng)于是觀察者從主題對(duì)象中拉數(shù)據(jù)绘盟。一般這種模型的實(shí)現(xiàn)中鸠真,會(huì)把主題對(duì)象自身通過update()方法傳遞給觀察者,這樣在觀察者需要獲取數(shù)據(jù)的時(shí)候龄毡,就可以通過這個(gè)引用來獲取了吠卷。

兩種模式的比較

  • 推模型是假定主題對(duì)象知道觀察者需要的數(shù)據(jù);而拉模型是主題對(duì)象不知道觀察者具體需要什么數(shù)據(jù)沦零,沒有辦法的情況下祭隔,干脆把自身傳遞給觀察者,讓觀察者自己去按需要取值路操。

  • 推模型可能會(huì)使得觀察者對(duì)象難以復(fù)用疾渴,因?yàn)橛^察者的update()方法是按需要定義的參數(shù)千贯,可能無法兼顧沒有考慮到的使用情況。這就意味著出現(xiàn)新情況的時(shí)候搞坝,就可能提供新的update()方法搔谴,或者是干脆重新實(shí)現(xiàn)觀察者;而拉模型就不會(huì)造成這樣的情況桩撮,因?yàn)槔P拖露氐冢瑄pdate()方法的參數(shù)是主題對(duì)象本身,這基本上是主題對(duì)象能傳遞的最大數(shù)據(jù)集合了店量,基本上可以適應(yīng)各種情況的需要芜果。

JAVA提供的對(duì)觀察者模式的支持

在JAVA語言的java.util庫里面,提供了一個(gè)Observable類以及一個(gè)Observer接口垫桂,構(gòu)成JAVA語言對(duì)觀察者模式的支持师幕。

Observer接口

這個(gè)接口只定義了一個(gè)方法粟按,即update()方法诬滩,當(dāng)被觀察者對(duì)象的狀態(tài)發(fā)生變化時(shí),被觀察者對(duì)象的notifyObservers()方法就會(huì)調(diào)用這一方法灭将。

Observable類

被觀察者類都是java.util.Observable類的子類疼鸟。java.util.Observable提供公開的方法支持觀察者對(duì)象,這些方法中有兩個(gè)對(duì)Observable的子類非常重要:一個(gè)是setChanged()庙曙,另一個(gè)是notifyObservers()空镜。第一方法setChanged()被調(diào)用之后會(huì)設(shè)置一個(gè)內(nèi)部標(biāo)記變量,代表被觀察者對(duì)象的狀態(tài)發(fā)生了變化捌朴。第二個(gè)是notifyObservers()吴攒,這個(gè)方法被調(diào)用時(shí),會(huì)調(diào)用所有登記過的觀察者對(duì)象的update()方法砂蔽,使這些觀察者對(duì)象可以更新自己洼怔。

源碼分析
/**
 * 主題對(duì)象,繼承Observable類
 */
public class ConcreteSubject extends Observable {


    private String data;

    public String getData() {
        return data;
    }

    public void setData(String data) {
        this.data = data;
        setChanged();
        notifyObservers();
    }
}
/**
 * 具體的觀察者左驾,實(shí)現(xiàn)Observer接口
 */
public class ConcreteObserver implements Observer {

    /**
     * 構(gòu)造方法中訂閱主題
     * @param observable
     */
    public ConcreteObserver(Observable observable){
        observable.addObserver(this);
    }



    @Override
    public void update(Observable o, Object arg) {
        System.out.println("觀察者觀察到狀態(tài)改變镣隶,為:" + ((ConcreteSubject)o).getData());
    }
}
/**
 * 客戶端
 */
public class Client {

    public static void main(String[] args) {
        //新增主題
        ConcreteSubject subject = new ConcreteSubject();

        //新增觀察者
        ConcreteObserver observer = new ConcreteObserver(subject);

        //主題對(duì)象狀態(tài)改變
        subject.setData("test2");
        subject.setData("test3");
    }

}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市诡右,隨后出現(xiàn)的幾起案子安岂,更是在濱河造成了極大的恐慌,老刑警劉巖帆吻,帶你破解...
    沈念sama閱讀 221,635評(píng)論 6 515
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件域那,死亡現(xiàn)場離奇詭異,居然都是意外死亡猜煮,警方通過查閱死者的電腦和手機(jī)次员,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,543評(píng)論 3 399
  • 文/潘曉璐 我一進(jìn)店門样眠,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人翠肘,你說我怎么就攤上這事檐束。” “怎么了束倍?”我有些...
    開封第一講書人閱讀 168,083評(píng)論 0 360
  • 文/不壞的土叔 我叫張陵被丧,是天一觀的道長。 經(jīng)常有香客問我绪妹,道長甥桂,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 59,640評(píng)論 1 296
  • 正文 為了忘掉前任邮旷,我火速辦了婚禮黄选,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘婶肩。我一直安慰自己办陷,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 68,640評(píng)論 6 397
  • 文/花漫 我一把揭開白布律歼。 她就那樣靜靜地躺著民镜,像睡著了一般。 火紅的嫁衣襯著肌膚如雪险毁。 梳的紋絲不亂的頭發(fā)上制圈,一...
    開封第一講書人閱讀 52,262評(píng)論 1 308
  • 那天,我揣著相機(jī)與錄音畔况,去河邊找鬼鲸鹦。 笑死,一個(gè)胖子當(dāng)著我的面吹牛跷跪,可吹牛的內(nèi)容都是我干的馋嗜。 我是一名探鬼主播,決...
    沈念sama閱讀 40,833評(píng)論 3 421
  • 文/蒼蘭香墨 我猛地睜開眼域庇,長吁一口氣:“原來是場噩夢啊……” “哼嵌戈!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起听皿,我...
    開封第一講書人閱讀 39,736評(píng)論 0 276
  • 序言:老撾萬榮一對(duì)情侶失蹤熟呛,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后尉姨,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體庵朝,經(jīng)...
    沈念sama閱讀 46,280評(píng)論 1 319
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,369評(píng)論 3 340
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了九府。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片椎瘟。...
    茶點(diǎn)故事閱讀 40,503評(píng)論 1 352
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖侄旬,靈堂內(nèi)的尸體忽然破棺而出肺蔚,到底是詐尸還是另有隱情,我是刑警寧澤儡羔,帶...
    沈念sama閱讀 36,185評(píng)論 5 350
  • 正文 年R本政府宣布宣羊,位于F島的核電站,受9級(jí)特大地震影響汰蜘,放射性物質(zhì)發(fā)生泄漏仇冯。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,870評(píng)論 3 333
  • 文/蒙蒙 一族操、第九天 我趴在偏房一處隱蔽的房頂上張望苛坚。 院中可真熱鬧,春花似錦色难、人聲如沸泼舱。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,340評(píng)論 0 24
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽柠掂。三九已至,卻和暖如春依沮,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背枪狂。 一陣腳步聲響...
    開封第一講書人閱讀 33,460評(píng)論 1 272
  • 我被黑心中介騙來泰國打工危喉, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人州疾。 一個(gè)月前我還...
    沈念sama閱讀 48,909評(píng)論 3 376
  • 正文 我出身青樓辜限,卻偏偏與公主長得像,于是被迫代替她去往敵國和親严蓖。 傳聞我的和親對(duì)象是個(gè)殘疾皇子薄嫡,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,512評(píng)論 2 359

推薦閱讀更多精彩內(nèi)容

  • 1 場景問題# 1.1 訂閱報(bào)紙的過程## 來考慮實(shí)際生活中訂閱報(bào)紙的過程,這里簡單總結(jié)了一下颗胡,訂閱報(bào)紙的基本流程...
    七寸知架構(gòu)閱讀 4,631評(píng)論 5 57
  • 一毫深、 概述 觀察者模式是對(duì)象的行為模式,又叫發(fā)布-訂閱(Publish/Subscribe)模式毒姨、模型-視圖(Mo...
    步積閱讀 1,286評(píng)論 0 1
  • 本篇文章介紹一種設(shè)計(jì)模式——觀察者模式哑蔫。觀察者模式在Android中有著很多的應(yīng)用,如按鈕監(jiān)聽,接口回調(diào)以及很多流...
    Ruheng閱讀 2,988評(píng)論 6 30
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理闸迷,服務(wù)發(fā)現(xiàn)嵌纲,斷路器,智...
    卡卡羅2017閱讀 134,701評(píng)論 18 139
  • 如若上一次天還能再回來腥沽,你敢不敢逮走?我敢。 如若上一次天不能再回來今阳,你敢不敢言沐?我敢。 如若上一次天不確定能否再回來酣栈,...
    天堂里的魚閱讀 171評(píng)論 1 1