設計模式走一遍---觀察者模式(下)

上篇咱們講解了觀察者模式的一些知識，並且自定義觀察者模式的經典代碼，(傳送們：設計模式走一遍—-觀察者模式(上))

這篇簡單講一下JDK自帶的觀察者模式實現代碼。

對於觀察者模式，JDK中提供了一個Observer接口(觀察者)，一個Observable類(主題對象)。

注：被觀察者又被稱爲主題對象，目標對象。

具體咱們來看下源碼。

1.觀察者接口

public interface Observer {
    /**
     * This method is called whenever the observed *object is changed. 
     *當被觀察者發生變化時，該方法將會被調用
     * @param   o     the observable object.
     * @param   arg   an argument passed to the <code>notifyObservers</code>
     *                 method.
     */
    void update(Observable o, Object arg);
}

該接口至關於觀察者，裏面有一個update(Observable o, Object arg)方法，Observable參數是指主題對象，該參數指明該觀察者是屬於哪個主題對象的。

arg參數能夠是任意對象，假如主題對象在發送通知時，想要傳遞什麼數據給觀察者，那麼就能夠把數據對象傳遞給arg參數。

2.主題對象類(方法有點多，我就不放英文解釋了)

//主題對象能夠是接口、抽象類、具體類，咱們上節說
//通常採用抽象類，不過JDK這裏使用的是具體類
public class Observable {
    //標記主題對象的狀態是否改變
    private boolean changed = false;
    //存放觀察者集合，之因此用Vector而不用ArrayList
    //主要是Vector是線程安全的
    private Vector<Observer> obs;

    public Observable() {
        obs = new Vector<>();
    }

    //添加一個觀察者
    public synchronized void addObserver(Observer o) {
        if (o == null)
            throw new NullPointerException();
        if (!obs.contains(o)) {
            obs.addElement(o);
        }
    }

    //刪除一個觀察者
    public synchronized void deleteObserver(Observer o) {
        obs.removeElement(o);
    }

    //標記該對象的狀態是否發送了改變
    protected synchronized void setChanged() {
        changed = true;
    }

    //指示該對象不會再發生改變，或者它已經通知了
    //全部觀察者
    protected synchronized void clearChanged() {
        changed = false;
    }


    //測試對象是否發生了改變。當且僅當在此對象最近
    //調用了setChange()方法
    public synchronized boolean hasChanged() {
        return changed;
    }

    //若是hasChanged()方法指示此對象發送了改變，
    //則通知全部觀察者，而且調用clearChanged()方法
    //指示此對象再也不改變
    public void notifyObservers() {
        notifyObservers(null);
    }

    //與上面沒有參數的同名方法相同，只是若是這個方
    //法的arg參數能夠接受主題對象想要傳遞觀察者的數據對象
    public void notifyObservers(Object arg) {
        //臨時保存全部觀察者
        Object[] arrLocal;

        synchronized (this) {
            if (!changed)
                return;
            arrLocal = obs.toArray();
            clearChanged();
        }

        for (int i = arrLocal.length-1; i>=0; i--)
            ((Observer)arrLocal[i]).update(this, arg);
    }

    //刪除全部觀察者
    public synchronized void deleteObservers() {
        obs.removeAllElements();
    }

    //返回觀察者的數量
    public synchronized int countObservers() {
        return obs.size();
    }
}

該具體類Observable至關於主題對象，實現的主要功能就是當本身的狀態發送改變時，通知觀察者，觀察者再根據通知，在update方法作出相應的反應。

簡單寫個Demo測試下。

public class Test {
    public static void main(String[] args){
        //建立一個主題對象
        AnimalSubject animalSubject = new AnimalSubject();
        animalSubject.addObserver(new DogObsever());
        animalSubject.addObserver(new LionObsever());
        //狀態發生改變
        animalSubject.setChanged();
        //通知觀察者
        animalSubject.notifyObservers();
    }
}

//動物主題，弄子類方便拓展主題對象功能
class AnimalSubject extends Observable{
    //不過我就不新增代碼、方法了

    //不覆蓋下的話，上面的測試調用不了setChange()方法
    //爲了方便測試，覆蓋重寫下
    @Override
    protected synchronized void setChanged() {
        super.setChanged();
    }
}
class DogObsever implements Observer{
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("收到通知，小狗觀察者正在作出相應處理");
    }
}

class LionObsever implements Observer{
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("收到通知，獅子觀察者正在作出相應處理");
    }
}

打印結果

收到通知，獅子觀察者正在作出相應處理
收到通知，小狗觀察者正在作出相應處理

從上面的代碼中咱們能夠發現JDk內置的觀察者模式中的主題對象是一個具體類，而不是一個抽象類或接口，並且setChange()方法還被保護起來了(被定義爲protected)，這就意味着，要在別的類中調用該方法，那麼咱們必須繼承在子類中重寫覆蓋該方法。顯然，我以爲這很不友好…..

可能這也是JDK內置的觀察者模式不多被拿來使用 的緣由吧，通常都是本身來自定義觀察者模式。

但願你們可以動手寫一下這些代碼，可能會碰到一些你沒想到的問題。

完

關注公個人衆號：苦逼的碼農，獲取更多原創文章，後臺回覆禮包送你一份時下熱門的資源大禮包。同時也感謝把文章介紹給更多須要的人

​