摘要：簡介學(xué)習(xí)本篇博文，我們知道在什么場景下使用觀察者模式。觀察者模式給我們在今后開發(fā)中什么思想。為什么需要觀察者模式從定義中我們可以知道觀察者模式當(dāng)對象改變時(shí)，其他依賴的對象都會收到改變信息的狀態(tài)。

1.學(xué)習(xí)本篇博文，我們知道在什么場景下使用觀察者模式。
2.觀察者模式的優(yōu)缺點(diǎn)。
3.觀察者模式給我們在今后開發(fā)中什么思想。

某家科技公司目前在開發(fā)一個(gè)項(xiàng)目，設(shè)計(jì)小組需要上報(bào)項(xiàng)目的進(jìn)度給部門經(jīng)理，主要有兩個(gè)模塊更新原有的業(yè)務(wù)模塊進(jìn)度和添加新業(yè)務(wù)的模塊完成進(jìn)度。
那么部門經(jīng)理需要什么途徑能最快的得到進(jìn)度的信息呢？或者可能是項(xiàng)目總監(jiān)也想?yún)⑴c，去獲取到最新的進(jìn)展情況呢？我們改如何去考慮這個(gè)業(yè)務(wù)呢？

很多時(shí)候我們就會想到繼承去解決這一情況，畢竟OO編寫思想時(shí)刻影響這一我們，但是如果某天項(xiàng)目經(jīng)理出差了，他不想看項(xiàng)目進(jìn)度了，那我們又改怎么辦呢？

我們能不能就是設(shè)計(jì)一個(gè)業(yè)務(wù)，讓能想知道該進(jìn)度的人，不管什么時(shí)候，只要有開發(fā)者上報(bào)進(jìn)度的時(shí)候就一下他就得到進(jìn)度的信息，而他無需去關(guān)系這個(gè)過程。

你是否能想到合適的解決方案呢？

答案就在下文中，你準(zhǔn)備好了嗎？

觀察者模式定義一系列對象之間的一對多關(guān)系，當(dāng)一個(gè)對象改變、更新狀態(tài)時(shí)，依賴它的都會收到通知改變或者更新。

從定義中我們可以知道觀察者模式當(dāng)對象改變時(shí)，其他依賴的對象都會收到改變信息的狀態(tài)。

從本例分析項(xiàng)目經(jīng)理想知道進(jìn)度情況，他只需要綁定進(jìn)度，他就可以知道進(jìn)度信息了，而無需關(guān)心如何操作，如果再增加一個(gè)想知道進(jìn)度信息老板呢？也很容易，也讓老板綁定進(jìn)度信息數(shù)據(jù)就好了，不想知道的時(shí)候就解除綁定，就不在獲取進(jìn)度信息了。

所以在本案例場景中，觀察者是我們這個(gè)場景非常合適的設(shè)計(jì)。

我們先來看一下這個(gè)UML類圖進(jìn)行分析

具體實(shí)現(xiàn)步驟

1.構(gòu)造一個(gè)主題Subject或者是一個(gè)被觀察者Observeable，這是一個(gè)接口或者是抽象類

  public interface Subject {
   //注冊觀察者
   void registerObserver(Observer observe);
   //解除綁定觀察者
   void unRegisterObserver(Observer observe);
   //更新數(shù)據(jù)
   void notifyObservers();
 }

2.構(gòu)建一個(gè)被觀察者實(shí)現(xiàn)該主題接口如本例的 DevelopmentProgressData.class，這里是進(jìn)度信息數(shù)據(jù)
在registerObserver(Observer o);//方法中將觀察者添加到注冊列表中
在unRegisterObserve(Observer o);//刪除觀察者

public class DevelopmentProgressData implements Subject {
 @Override
   public void registerObserver(Observer observer) {
       //將觀察者添加到列表中
       arrayObserve.add(observer);
   }

   @Override
   public void unRegisterObserver(Observer observer) {
       int i = arrayObserve.indexOf(observer);
       if (i >= 0) {
           //將觀察者從列表中解除
           arrayObserve.remove(i);
       }

   }
   //通知所以觀察者數(shù)據(jù)更新了
   @Override
   public void notifyObservers() {

       for (int i = 0; i < arrayObserve.size(); i++) {
           Observer o = (Observer) arrayObserve.get(i);
           o.update(completeProgress, updateProgress);
       }
   }
}

3.構(gòu)建一個(gè)觀察者接口Observer

 public interface Observer {
    //更新數(shù)據(jù)
    void update(int completeProgress, int updateProgress);
 }

4.可構(gòu)建一個(gè)展示數(shù)據(jù)的接口（可忽略）
有展示數(shù)據(jù)的方法，觀察者要實(shí)現(xiàn)這個(gè)方法 查看本例的 DisplaySchedule

public interface DisplaySchedule {
   void display();
}

5.定義觀察者(模擬該類就是產(chǎn)品經(jīng)理觀察者)，需實(shí)現(xiàn)接口Observes、DisplaySchedule(可忽略)，
<1>、將主題Subject設(shè)置為觀察者的屬性，并將其作為觀察者的構(gòu)造函數(shù)如 ProductManagerObserver.class
調(diào)用 developmentProgressSubject.registerObserver(this);將觀察者注冊到觀察列表中

public class ProductManagerObserver implements Observer, DisplaySchedule {

    private int completeProgress;//完成進(jìn)度
    private int updateProgress;//更新進(jìn)度
    //將主題當(dāng)成觀察者的屬性
    private Subject developmentProgressSubject;

    public ProductManagerObserver(Subject developmentProgressSubject) {
        this.developmentProgressSubject = developmentProgressSubject;
        //注冊該觀察者
        developmentProgressSubject.registerObserver(this);
    }

    @Override
    public void display() {
        System.out.println("產(chǎn)品經(jīng)理管理者顯示當(dāng)前數(shù)據(jù) 完成進(jìn)度為: " + completeProgress + "更新修改進(jìn)度為:" + updateProgress);
    }

    @Override
    public void update(int completeProgress, int updateProgress) {
        this.completeProgress = completeProgress;
        this.updateProgress = updateProgress;
        display();
    }
}

測試

RunTest.class

public class RunTest {

    public static void main(String[] args) {

        DevelopmentProgressData developmentProgressData = new DevelopmentProgressData();
        ProductManagerObserver productManagerObserver = new ProductManagerObserver(developmentProgressData);
        ProjectManagerObserver projectManagerObserver = new ProjectManagerObserver(developmentProgressData);
        developmentProgressData.setCurrentData(34, 45);
        //當(dāng)項(xiàng)目經(jīng)理出差了，不觀察項(xiàng)目進(jìn)度了就取消訂閱了
        developmentProgressData.unRegisterObserver(projectManagerObserver);
        //當(dāng)前只有產(chǎn)品經(jīng)理獲取到數(shù)據(jù)
        developmentProgressData.setCurrentData(46, 90);
    }
}

輸出結(jié)果

C:Javajdk1.8.0_161in...
產(chǎn)品經(jīng)理管理者顯示當(dāng)前數(shù)據(jù) 完成進(jìn)度為: 34更新修改進(jìn)度為:45
項(xiàng)目管理真顯示當(dāng)前數(shù)據(jù)完成進(jìn)度為: 34更新修改進(jìn)度為:45
產(chǎn)品經(jīng)理管理者顯示當(dāng)前數(shù)據(jù) 完成進(jìn)度為: 46更新修改進(jìn)度為:90

Process finished with exit code 0

具體實(shí)現(xiàn)步驟

1.首先觀察者需要實(shí)現(xiàn)java.util.Observer,然后將其被觀察者=>java.util.Observaerable作為其觀察者的構(gòu)造函數(shù)

<1>、通過observeable.addObserver(this)添加觀察者

public class BossMngObserver implements Observer, DisplayIllustrate {

 private Observable observable;
 private int valuableProductNum; //庫存有貴重產(chǎn)品
 private int normalProductNum;   //普通產(chǎn)品

 public BossMngObserver(Observable observable) {
     this.observable = observable;
     observable.addObserver(this);
 }

 @Override
 public void disPlay() {
     System.out.println("總經(jīng)理觀察數(shù)據(jù)改變:貴重產(chǎn)品數(shù)量: " + valuableProductNum + "普通產(chǎn)品數(shù)量： " + normalProductNum);
 }
//<2>、實(shí)現(xiàn) Observer更新數(shù)據(jù)方法
//看本例的包下的observe的三個(gè)類
 @Override
 public void update(Observable o, Object arg) {
     if (o instanceof InventoryData) {
         InventoryData inventoryData = (InventoryData) o;
         this.valuableProductNum = inventoryData.getValuableProductNum();
         this.normalProductNum = inventoryData.getNormalProductNum();
         disPlay();
     }
 }
  }

2.被觀察者需要繼承java.util.Observerable,

<1>、然后先調(diào)用setChanged()方法

<2>、在進(jìn)行調(diào)用notifyObserves()更新數(shù)據(jù)

  public class InventoryData extends Observable {

    private int valuableProductNum; //庫存有貴重產(chǎn)品
    private int normalProductNum;   //普通產(chǎn)品

    public void setCurrentData(int valuableProductNum, int normalProductNum) {
        this.valuableProductNum = valuableProductNum;
        this.normalProductNum = normalProductNum;
        statusChange();
    }

    private void statusChange() {
    //先調(diào)用 setChanged();
        setChanged();
        notifyObservers();
    }
 }

測試

3.Test.class

public class Test {
    public static void main(String[] args) {

        InventoryData inventoryData = new InventoryData();

        ValuableInfoMngObserver io = new ValuableInfoMngObserver(inventoryData);

        //io.deleteObserve();
        inventoryData.setCurrentData(20, 30);

        NormalInfoMngObserver no = new NormalInfoMngObserver(inventoryData);

        //no.deleteObserver();
        inventoryData.setCurrentData(15, 27);

        BossMngObserver bossMngObserver = new BossMngObserver(inventoryData);

        inventoryData.setCurrentData(10, 50);
    }
}

觀察者模式案例代碼

觀察者模式的讓我們知道了在設(shè)計(jì)開發(fā)的時(shí)候一定要“多用組合，少用繼承”。

我們設(shè)計(jì)開發(fā)是應(yīng)該是針對接口變成，而不針對實(shí)現(xiàn)編程。

在java.util.*下的Observer和Observable可以實(shí)現(xiàn)觀察者，但是Observable是一個(gè)類，這樣我們是不違背了“多用組合少用繼承”的OO編程思想，是的沒錯在java.util.Observable類違背了該規(guī)則。

大家可以進(jìn)入這里學(xué)習(xí)設(shè)計(jì)模式