觀察者模式

觀察者模式定義了對象之間的一對多依賴,這樣一來,當(dāng)一個對象改變狀態(tài)時,它的所有依賴者都會受到通知并自動更新。
通俗的講,觀察者先告訴被觀察者我需要觀察的你的某些屬性,當(dāng)這些屬性發(fā)生變化時就主動通知我。

栗子:不同的讀者可以在書店進行訂閱服務(wù),當(dāng)有新書到來時,就讓書店主動通知這些訂閱者。
在這個例子中,書店就屬于被觀察者(主題),讀者就屬于觀察者,觀察的內(nèi)容為是否有新書到來。
要實現(xiàn)這樣的一種機制,那么首先,讀者需要在書店進行訂閱,然后書店需要有一份訂閱者的名單,然后在有新書到來時就通知讀者。
我們需要在書店類中定義一個讀者的集合,在讀者訂閱時添加,取消訂閱時就移除,當(dāng)有新書到來時就遍歷集合通知讀者。
由于讀者有各種類型的人,因此就將這些讀者的共同點抽象出來,他們都需要的是訂閱服務(wù)并受到通知,那么我們就可以定義一個讀者接口,其中定義的方法是接受書店傳來的通知,不同的讀者只需要實現(xiàn)這個接口,然后在受到書店的通知后自己再進行處理即可。
而書店方面,為了讓各種類型的書店都能夠有這樣一種服務(wù),我們就把書店的這種訂閱服務(wù)也抽象出來定義成一個接口,其中定義方法是注冊、取消注冊、通知觀察者。

代碼:
首先是抽象出的書店的訂閱服務(wù)接口

//主題接口,即書店提供的訂閱服務(wù)
public interface Subject {
    //注冊
    void register(Observer observer);
    //取消注冊
    void unRegister(Observer observer);
    //通知
    void notifyObservers();
}

然后是書店的具體實現(xiàn)類,書店不需要管具體的讀者是那種類型的,只需要知道,讀者是需要訂閱服務(wù)的,因此在注冊時傳入的是讀者實現(xiàn)的訂閱服務(wù)的接口

//書店類,實現(xiàn)了訂閱服務(wù)具體的邏輯
public class BookStore implements Subject{
    private List<Observer> observerLsit = new ArrayList<>();
    @Override
    public void register(Observer observer) {
        if(!observerLsit.contains(observer)){
            observerLsit.add(observer);
        }
    }
    @Override
    public void unRegister(Observer observer) {
        if(observerLsit.contains(observer)){
            observerLsit.remove(observer);
        }
    }
    public void onNewBookArrived(){
        notifyObservers();
    }
    @Override
    public void notifyObservers() {
        for(Observer o : observerLsit){
            o.update();
        }
    }
}

然后是讀者的接口:

public interface Observer {
    void update();
}

最后是兩個讀者實現(xiàn)類:

public class Boy implements Observer {
    private Subject subject;
    public Boy(Subject subject){
        this.subject = subject;
        subject.register(this);
    }
    @Override
    public void update() {
        System.out.println("boy----->receive newBookArrived!");
    }
}

public class Girl implements Observer {
    private Subject subject;
    public Girl(Subject subject){
        this.subject = subject;
        subject.register(this);
    }
    @Override
    public void update() {
        System.out.println("girl----->receive newBookArrived!");
    }
}

讀者在實現(xiàn)類中,需要持有一個書店(被觀察者)的接口對象,用來注冊和取消注冊,并分別具體實現(xiàn)了在收到新書之后的動作。
Test:

public static void main(String[] args) {
    BookStore bookStore = new BookStore();
    Boy boy = new Boy(bookStore);
    Girl girl = new Girl(bookStore);
    bookStore.onNewBookArrived();
}
Paste_Image.png

這里我為了簡單起見,直接將注冊的行為放在了構(gòu)造方法里,不過將注冊和取消注冊單獨作為一個方法會更好,這樣會更靈活,讀者可以隨時進行注冊或取消注冊。

這種觀察者模式其實是屬于“推”,即在屬性發(fā)生改變的情況下,被觀察者主動向觀察者推送消息。

還有一種是“拉”,即觀察者在需要的時候,再主動獲取被觀察者的特定屬性的狀態(tài),省的被觀察者老是推送消息。
“拉”模式的實現(xiàn)就是在被觀察者中定義需要被觀察的屬性的get方法,然后觀察者因為持有被觀察者的引用,就可以在需要時主動來獲取需要的狀態(tài)信息了。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容