設計模式學習-觀察者模式

来源:http://www.cnblogs.com/zhaoyanghoo/archive/2016/08/04/5734776.html
-Advertisement-
Play Games

1.定義 定義對象間一種一對多的依賴關係,使得當每一個對象改變狀態,則所有依賴於它的對象都會得到通知並自動更新。 2.類圖 3.代碼示例 我們定義一個場景:熱水壺在燒開水,小孩和媽媽都關註燒開水的過程,各自有其處理方法。用while死迴圈一直輪詢雖然可以實現這樣的場景,但性能上讓人無法接受。 為方便 ...


1.定義

定義對象間一種一對多的依賴關係,使得當每一個對象改變狀態,則所有依賴於它的對象都會得到通知並自動更新。

2.類圖

3.代碼示例

我們定義一個場景:熱水壺在燒開水,小孩和媽媽都關註燒開水的過程,各自有其處理方法。用while死迴圈一直輪詢雖然可以實現這樣的場景,但性能上讓人無法接受。

為方便大家copy源碼放在本機測試,我將代碼寫進一個java類中,其它參與類都是非public的。

  1 package com.zhaoyangwoo.observer;
  2 
  3 import java.util.ArrayList;
  4 import java.util.List;
  5 
  6 /**
  7  * Created by john on 16/8/3.
  8  */
  9 //定義被觀察者介面
 10 interface Subject {
 11 
 12     void attachObv(Observer o);
 13 
 14     void detachObv(Observer o);
 15 
 16     void notifyObvs();
 17 }
 18 
 19 //定義觀察者介面
 20 interface Observer {
 21     void update(Subject subject);
 22 }
 23 
 24 //定義具體被觀察者
 25 public class WaterHeater implements Subject {
 26 
 27     //存儲觀察者
 28     private static List<Observer> observerList = new ArrayList<>();
 29 
 30     public int getTemperature() {
 31         return temperature;
 32     }
 33 
 34     public void setTemperature(int temperature) {
 35         this.temperature = temperature;
 36     }
 37 
 38     private int temperature = 0;
 39 
 40     @Override
 41     public void attachObv(Observer o) {
 42         observerList.add(o);
 43     }
 44 
 45     @Override
 46     public void detachObv(Observer o) {
 47         observerList.remove(o);
 48 
 49     }
 50 
 51     @Override
 52     public void notifyObvs() {
 53         observerList.forEach(r -> r.update(this));
 54     }
 55 
 56     //模擬燒開水的過程
 57     public void heat() {
 58         temperature = 0;
 59         for (int i = 0; i < 100; i++) {
 60             temperature++;
 61             this.notifyObvs();
 62             try {
 63                 //停100ms
 64                 Thread.sleep(100);
 65             } catch (InterruptedException e) {
 66                 e.printStackTrace();
 67             }
 68         }
 69     }
 70 
 71 
 72     //場景類
 73     public static void main(String[] args) {
 74         WaterHeater waterHeater = new WaterHeater();
 75         Mother mother = new Mother();
 76         Child child = new Child();
 77         waterHeater.attachObv(mother);
 78         waterHeater.attachObv(child);
 79         waterHeater.heat();
 80         waterHeater.detachObv(child);
 81         waterHeater.heat();
 82         System.out.println("燒水結束");
 83     }
 84 }
 85 
 86 //具體觀察者
 87 class Child implements Observer {
 88 
 89     @Override
 90     public void update(Subject subject) {
 91         WaterHeater waterHeater = (WaterHeater) subject;
 92         System.out.println("現在的水溫是" + waterHeater.getTemperature() + "度,人家還是個寶寶,跟我沒關係");
 93     }
 94 }
 95 
 96 //具體觀察者
 97 class Mother implements Observer {
 98 
 99     @Override
100     public void update(Subject subject) {
101         WaterHeater waterHeater = (WaterHeater) subject;
102         if (waterHeater.getTemperature() > 99) {
103             System.out.println("現在的水溫是" + waterHeater.getTemperature() + "度,水燒開了,我要把水裝進熱水瓶");
104         }
105     }
106 }

 

4.應用場景舉例

  • 一個類的狀態變化需要通知其他類知曉,並且這些其他類是可以動態配置的
  • 可以實現訂閱/發佈模型

5.JDK源碼中的模式實現

JDK原生對觀察者模式支持。通過java.util.Observable和java.util.Observer兩個類,很容易實現觀察者模式。通過閱讀其源碼,可以發現原理都是一樣的。當然源碼里的實現是線程安全的。我們用這兩個類重寫我們的場景:

 1 // jdk版本的被觀察者,不需要自己實現調用通知/註冊之類的操作
 2 class WaterHeaterJava extends Observable {
 3     public int getTemperature() {
 4         return temperature;
 5     }
 6 
 7     public void setTemperature(int temperature) {
 8         this.temperature = temperature;
 9     }
10 
11     private int temperature = 0;
12 
13     public void heat() {
14         temperature = 0;
15         for (int i = 0; i < 100; i++) {
16             temperature++;
17             //這裡一定要註意,如果要notifyObservers生效,一定要調用setChanged告知已經發生了change,可以通知觀察者了.否則notifyObservers不工作
18             super.setChanged();
19             super.notifyObservers();
20             try {
21                 Thread.sleep(100);
22             } catch (InterruptedException e) {
23                 e.printStackTrace();
24             }
25         }
26     }
27 
28     //場景類
29     public static void main(String[] args) {
30         WaterHeaterJava waterHeater = new WaterHeaterJava();
31         MotherJava mother = new MotherJava();
32         ChildJava child = new ChildJava();
33         waterHeater.addObserver(mother);
34         waterHeater.addObserver(child);
35         waterHeater.heat();
36         waterHeater.deleteObserver(child);
37         waterHeater.heat();
38         System.out.println("Java版燒水結束");
39     }
40 }
41 
42 class ChildJava implements java.util.Observer {
43 
44     @Override
45     public void update(Observable o, Object arg) {
46         WaterHeaterJava waterHeater = (WaterHeaterJava) o;
47         System.out.println("現在的水溫是" + waterHeater.getTemperature() + "度,人家還是個寶寶,跟我沒關係");
48     }
49 }
50 
51 class MotherJava implements java.util.Observer {
52 
53     @Override
54     public void update(Observable o, Object arg) {
55         WaterHeaterJava waterHeater = (WaterHeaterJava) o;
56         if (waterHeater.getTemperature() > 99) {
57             System.out.println("現在的水溫是" + waterHeater.getTemperature() + "度,水燒開了,我要把水裝進熱水瓶");
58         }
59     }
60 }
View Code

關於setChanged,看看它的源碼就明白了

 1 public void notifyObservers(Object arg) {
 2         /*
 3          * a temporary array buffer, used as a snapshot of the state of
 4          * current Observers.
 5          */
 6         Object[] arrLocal;
 7 
 8         synchronized (this) {
 9             /* We don't want the Observer doing callbacks into
10              * arbitrary code while holding its own Monitor.
11              * The code where we extract each Observable from
12              * the Vector and store the state of the Observer
13              * needs synchronization, but notifying observers
14              * does not (should not).  The worst result of any
15              * potential race-condition here is that:
16              * 1) a newly-added Observer will miss a
17              *   notification in progress
18              * 2) a recently unregistered Observer will be
19              *   wrongly notified when it doesn't care
20              */
21 
22             //看這裡
23             if (!changed)
24                 return;
25             arrLocal = obs.toArray();
26             clearChanged();
27         }
28 
29         for (int i = arrLocal.length-1; i>=0; i--)
30             ((Observer)arrLocal[i]).update(this, arg);
31     }    
View Code

 

6.思考

思考如下兩個問題

  • 性能問題 

  如果註冊的觀察者較多,或者觀察者處理能力弱、耗時長,那麼很可能出現性能問題,畢竟只是簡單的遍歷調用。

  • 訂閱/發佈

  當然,對於訂閱/發佈模型的支持有更好的開源框架,各種mq實現了這種模型,並且是非同步架構,性能也有保障。 

  • 推或拉

  大家都喜歡說推模式和拉模式。其實本質上來說都是推模式,這也是使用觀察者模式帶來的好處。拉模式只不過推了一個引用,可以通過這個引用拿到更多的信息而已。

7.參考

1.《JAVA與模式》之觀察者模式
 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 簡訊驗證碼 簡訊下行 簡訊下行的使用場景 簡訊驗證碼就是最常用的一個簡訊下行的例子,相對於傳統的圖片驗證碼,簡訊驗證碼最大的好處就是提升了賬號的有效性,註冊這一般都是使用自己的手機號嗎。當然了,除此之外簡訊驗證碼還可以用於登陸,方便快捷。 簡訊下行的設計 簡訊下行的驗證方式,較上行驗證碼簡單很多,這 ...
  • 一、NumPy 是什麼 NumPy 是 Python 科學計算的基礎包,它專為進行嚴格的數字處理而產生。在之前的隨筆里已有更加詳細的介紹,這裡不再贅述。 利用 Python 進行數據分析(一)簡單介紹 二、ndarray 是什麼 ndarray 是一個多維的數組對象,具有矢量算術運算能力和複雜的廣播 ...
  • 原題鏈接http://acm.hust.edu.cn/vjudge/contest/121397#problem/A 題意:t組數據,每組一個n 求 1+1/2+1/3+1/4 ......+1/n的和 方法:打表 沒100個存一個,不夠100的跑一趟 #include <iostream>#inc ...
  • 解析優化 參見之前介紹的DNS過程,如下圖: 基於可控和容災的需要,移動端代碼一般不會hardcode 推流、播放的伺服器IP地址,而選用功能變數名稱代替。在IP出現宕機或網路中斷的情況下,還可以通過變更DNS來實現問題IP的剔除。而功能變數名稱的解析時間需要幾十毫秒至幾秒不等,對於新生成熱度不高的功能變數名稱,一般的平均 ...
  • QStatusBa,狀態欄是位於主視窗的最下方,提供一個顯示工具提示等信息的地方。QMainWindow類裡面就有一個statusBar()函數,用於實現狀態欄的調用。以下例子都在QMainWindow的視窗前提下運行。 1.狀態欄添加 QLabel QLabel *msgLabel = new Q ...
  • QWhatsThis,為任何widget提供簡單的描述,回答"What's This?"這個問題。 示例:(在MainWindow下運行) 定義全局變數 QAction *newAct; QMenu *fileMenu; void MainWindow::creatActions() { newAc ...
  • 開發和測試向來就是一對冤家,再加上產品再添一把火,不吵才是奇跡呢。所以一般我們開發的時候儘可能的減少一些小的失誤,比如說獲取的數值為空,判定條件不充分、當然還有面對測試人員測試時將軟體暴力測試,出現一些網路解析數據的延遲有時也是無法避免的。可是這些確實是一些困擾。但是為了提高開發的效率,犯這些小錯誤 ...
  • 本文為原創文章,轉載請註明出處,謝謝 數據的發佈與訂閱 1、應用 服務端監聽數據改變,客戶端創建/更新節點數據,客戶端提供數據,服務端處理 2、原理 客戶端監控節點數據改變事件(例如配置信息,下圖的config節點),啟動時在伺服器節點下創建臨時節點(圖中servers下節點) 服務端監聽工作伺服器 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...