第四章 觀察者模式

當對象間存在一對多關系時，則使用觀察者模式（Observer Pattern）。比如，當一個對象被修改時，則會自動通知依賴它的對象。觀察者模式屬于行為型模式

4.1 介紹

• 意圖：定義對象間的一種一對多的依賴關系，當一個對象的狀態(tài)發(fā)生改變時，所有依賴于它的對象都得到通知并被自動更新

• 主要解決：一個對象狀態(tài)改變給其他對象通知的問題，而且要考慮到易用和低耦合，保證高度的協作

• 何時使用：一個對象（目標對象）的狀態(tài)發(fā)生改變，所有的依賴對象（觀察者對象）都將得到通知，進行廣播通知

• 如何解決：使用面向對象技術，可以將這種依賴關系弱化

• 關鍵代碼：在抽象類里有一個 ArrayList 存放觀察者們

• 應用實例：

  1. 拍賣的時候，拍賣師觀察最高標價，然后通知給其他競價者競價
  2. 西游記里面悟空請求菩薩降服紅孩兒，菩薩灑了一地水招來一個老烏龜，這個烏龜就是觀察者，他觀察菩薩灑水這個動作

• 優(yōu)點：

  1. 觀察者和被觀察者是抽象耦合的
  2. 建立一套觸發(fā)機制

• 缺點：

  1. 如果一個被觀察者對象有很多的直接和間接的觀察者的話，將所有的觀察者都通知到會花費很多時間
  2. 如果在觀察者和觀察目標之間有循環(huán)依賴的話，觀察目標會觸發(fā)它們之間進行循環(huán)調用，可能導致系統崩潰
  3. 觀察者模式沒有相應的機制讓觀察者知道所觀察的目標對象是怎么發(fā)生變化的，而僅僅只是知道觀察目標發(fā)生了變化

• 使用場景：

  • 一個抽象模型有兩個方面，其中一個方面依賴于另一個方面。將這些方面封裝在獨立的對象中使它們可以各自獨立地改變和復用
  • 一個對象的改變將導致其他一個或多個對象也發(fā)生改變，而不知道具體有多少對象將發(fā)生改變，可以降低對象之間的耦合度
  • 一個對象必須通知其他對象，而并不知道這些對象是誰
  • 需要在系統中創(chuàng)建一個觸發(fā)鏈，A對象的行為將影響B對象，B對象的行為將影響C對象……，可以使用觀察者模式創(chuàng)建一種鏈式觸發(fā)機制

• 注意事項：

  1. JAVA 中已經有了對觀察者模式的支持類
  2. 避免循環(huán)引用
  3. 如果順序執(zhí)行，某一觀察者錯誤會導致系統卡殼，一般采用異步方式

4.2 UML

觀察者模式使用三個類 Subject、Observer 和 Client。Subject 對象帶有綁定觀察者到 Client 對象和從 Client 對象解綁觀察者的方法。我們創(chuàng)建 Subject 類、Observer 抽象類和擴展了抽象類 Observer 的實體類

觀察者模式.png

4.3 代碼

1. 創(chuàng)建抽象觀察者

   public interface Observer {
   
     void update(String desc);
   }
   

2. 創(chuàng)建具體觀察者

   class ConcreteObserver1 implements Observer {
     public void update(String desc) {
       System.out.println("觀察者1：" + desc);
     }
   }
   
   public class ConcreteObserver2 implements Observer {
     public void update(String desc) {
       System.out.println("觀察者2：" + desc);
     }
   }
   
   public class ConcreteObserver3 implements Observer {
     public void update(String desc) {
       System.out.println("觀察者3：" + desc);
     }
   }
   

3. 創(chuàng)建抽象主題角色

   public interface Subject {
   
     void add(Observer observer);
   
     void remove(Observer observer);
   
     void notifyAllObservers();
   }
   

4. 創(chuàng)建具體主題

   public class ConcreteSubject implements Subject   {
   
     private List<Observer> observerList;
     private String desc;
   
     public void setDesc(String desc) {
       this.desc = desc;
       /*更新完數據后，通知所有的它的觀察者*/
       this.notifyAllObservers();
     }
   
     public ConcreteSubject() {
       this.observerList = new ArrayList<Observer>();
     }
   
     public void add(Observer observer) {
       observerList.add(observer);
     }
   
     public void remove(Observer observer) {
       observerList.remove(observer);
     }
   
     public void notifyAllObservers() {
       for (int i = 0; i < observerList.size(); i++) {
         observerList.get(i).update(desc);
       }
     }
   }
   

5. 創(chuàng)建測試類

   public class Client {
     public static void main(String[] args) {
   
       Observer observer1 = new ConcreteObserver1();
       Observer observer2 = new ConcreteObserver2();
       Observer observer3 = new ConcreteObserver3();
   
       ConcreteSubject subject = new ConcreteSubject();
       subject.add(observer1);
       subject.add(observer2);
       subject.add(observer3);
   
       subject.setDesc("我打開了電視");
     }
   }
   

6. 結果

   觀察者1：我打開了電視
   觀察者2：我打開了電視
   觀察者3：我打開了電視