《一天一模式》— 觀察者模式

時間 2020-05-27

標籤一天一模式觀察者模式简体版

原文原文鏈接

1、觀察者模式的概念

觀察者模式（又被稱爲發佈-訂閱（Publish/Subscribe）模式，屬於行爲型模式的一種，它定義了一種一對多的依賴關係，讓多個觀察者對象同時監聽某一個主題對象。這個主題對象在狀態變化時，會通知全部的觀察者對象，使他們可以自動更新本身。 java

2、何時使用觀察者模式

當一個對象被修改，或者發生某些變化時，須要自動通知依賴它的一些對象，則可使用觀察者模式。編程

例如：當汽車熄火時，須要更新汽車的定位、發送熄火的通知、生成本次的行程，就可使用觀察者模式，這個例子中發生變化的位置是熄火，那麼發生熄火須要通知依賴它的一些對象，就是定位、通知和行程。spa

下面來看看，如何用Java語言實現觀察者模式。設計

3、怎麼使用觀察者模式

3.1 不適用觀察者模式的弊端

用上面說的業務場景爲例，若是不使用觀察者模式來實現，能夠看下面的僞代碼：code

public class EngineOffEvent() {

    public void engineOff() {
        Location localtion = new Localtion();
        Notification notification = new Notification();
        Trip trip = new Trip();

        localtion.update();
        notification.notify();
        trip.createTrip();
    }
}

這種作法有以下兩個主要弊端：server

耦合度高：能夠看到EngineOffEvent類耦合了全部其餘的業務類，形成維護困難；
擴展性差：當須要在熄火時作新業務時，須要修改engineOff方法內的代碼，違反了開閉原則；
靈活度低：不能控制通知的對象個數；

3.2 如何用觀察者模式解決問題

根據上面的需求，用觀察者模式進行設計，下面看看類圖和代碼：對象

代碼以下：blog

/**
 * 觀察者接口。
 * */
public interface Observer {
    /**
     * 當氣象監測數據改變時，主題會把這些狀態值看成方法的參數，傳送給觀察者。
     * */
    void update(String data);
}

public class LocaltionObserver implements Observer{
    public void update(String data) {
        System.out.println(data + "：更新位置。");
    }
}

public class NotificationObserver implements Observer{
    public void update(String data) {
        System.out.println(data + "：發送通知。");
    }
}

public class TripObserver implements Observer {
    public void update(String data) {
        System.out.println(data + "：生成行程。");
    }
}

/**
 * 主題接口。
 * */
public interface Subject {
    /**
     * registerObserver和removeObserver方法都須要一個觀察者做爲變量，該觀察者是用來註冊或被刪除的。
     * */
    void registerObserver(Observer ob);

    void removeObserver(Observer ob);

    /**
     * 當主題的狀態改變時，這個方法會被調用，已通知全部的觀察者。
     * */
    void notifyObservers(String data);

}

// 熄火事件
public class EngineOffEvent implements Subject {

    // 觀察者對象集合
    private List<Observer> observers;

    public EngineOffEvent() {
        observers = new ArrayList<Observer>();
    }

    // 註冊觀察者
    public void registerObserver(Observer ob) {
        observers.add(ob);
    }

    // 移除觀察者
    public void removeObserver(Observer ob) {
        int index = observers.indexOf(ob);
        if (index >= 0)
            observers.remove(index);
    }

    // 發生變化進行通知
    public void notifyObservers(String data) {
        // 通知所有觀察者
        for (Observer ob : observers) {
            ob.update(data);
        }
    }

}

// 使用
public class Client {

    public static void main(String[] args) {
        Subject subject = new EngineOffEvent();
        subject.registerObserver(new LocaltionObserver());
        subject.registerObserver(new NotificationObserver());
        subject.registerObserver(new TripObserver());
        subject.notifyObservers("京A88888熄火");
    }

}

//京A88888熄火：更新位置。
//京A88888熄火：發送通知。
//京A88888熄火：生成行程。

觀察者模式主要分爲兩部分：繼承