設計模式——觀察者模式 Java源代碼 · 學習設計模式

本程序改編自《Head First Design Patterns》上關于氣象站的例子，我將例子進行了化簡。總共7個java源文件一個Subject接口一個Observer接口一個DisplayElement接口一個Subject具體類，實現Subject接口兩個Observer具體類，實現Observer和DisplayElement接口一個Main類，用于測試觀察者模式類圖 ![這里寫圖片描述](https://box.kancloud.cn/2016-02-22_56cab10ce9590.jpg "") 圖：我用插件畫的類圖 The Observation Pattern defines a one-to-many dependency。這里的one就是Subject， many就是Observers；one就是發布者，many就是訂閱者；one就是事件源，many就是監聽者。 # Talk is cheap, show me the code ### 一個Subject接口 ~~~ package observer; public interface Subject { public void registerObserver(Observer o); public void removeOvserver(Observer o); public void notifyObservers(); } ~~~ ### 一個Observer接口 ~~~ package observer; public interface Observer { public void update(double temperature, double humidity, String condition); } ~~~ ### 一個DisplayElement接口這個接口只有display( )一個抽象方法，其實如果放在Observer里面的話，僅從代碼層面考慮的話，也可以。但是如果從邏輯層面考慮的話，最好還是分開。畢竟這個display和觀察者是”兩碼事“，不要耦合在一起。《Head First Design Pattern》上面的例子代碼這樣寫，是為了描繪出一個生動形象的”氣象站“的例子，來幫助大家理解觀察者模式。 ~~~ package observer; public interface DisplayElement { public void display(); } ~~~ ### 一個Subject具體類 ~~~ package observer; import java.util.ArrayList; // Subject收集天氣信息，然后通知Observers public class WeatherData implements Subject { private ArrayList<Observer> observers; private double temperature; private double humidity; private String condition; public WeatherData() { observers = new ArrayList<Observer>(); } @Override public void registerObserver(Observer o) { observers.add(o); } @Override public void removeOvserver(Observer o) { int i = observers.indexOf(o); if(i>=0) { observers.remove(i); } } @Override public void notifyObservers() { for(Observer observer : observers) { observer.update(temperature, humidity, condition); } } public void measurementsChanged() { notifyObservers(); } public void setMeasurements(double temperature, double humidity, String condition) { this.temperature = temperature; this.humidity = humidity; this.condition = condition; measurementsChanged(); } public double getTemperature() { return temperature; } public double getHumidity() { return humidity; } public String getPressure() { return condition; } } ~~~ ### 兩個Observer具體類 ~~~ package observer; // 顯示當前天氣情況 public class CurrentDisplay implements Observer, DisplayElement { private double temperature; private double humidity; private String condition; public CurrentDisplay(Subject weatherData) { weatherData.registerObserver(this); } @Override public void display() { System.out.println("Current Conditions: "+ temperature + " C degrees and " + humidity + "% humidity " + condition ); } @Override public void update(double temperature, double humidity, String condition) { this.temperature = temperature; this.humidity = humidity; this.condition = condition; display(); } public String toString() { return "This is Current Condition Display"; } } ~~~ ~~~ package observer; // 顯示歷史統計數據 public class StatisticDisplay implements Observer, DisplayElement { private double maxTemperature = 0; private double minTemperature = 100; private double temperatureSum = 0; private int totalUpdating = 0; public StatisticDisplay(Subject weatherData) { weatherData.registerObserver(this); } @Override public void display() { System.out.println("Avg/Max/Min temperture: " + temperatureSum/totalUpdating + "/" + maxTemperature + "/" + minTemperature); } @Override public void update(double temperature, double humidity, String condition) { temperatureSum += temperature; totalUpdating++; if(temperature > maxTemperature) { maxTemperature = temperature; } if(temperature < minTemperature) { minTemperature = temperature; } display(); } public String toString() { return "This is Statictic Display"; } } ~~~ ### 一個Main測試類 ~~~ package observer; public class Main { public static void main(String[] args) { WeatherData weatherStation = new WeatherData(); // 一個氣象站作為Subject CurrentDisplay currentDisplay = new CurrentDisplay(weatherStation); // 注冊Observer1 System.out.println(currentDisplay); // 這個是為了不讓eclipse報出warning StatisticDisplay statisticDisplay = new StatisticDisplay(weatherStation); // 注冊Observer2 System.out.println(statisticDisplay); // 這個是為了不讓eclipse報出warning weatherStation.setMeasurements(20, 30, "晴天"); // 氣象站測量出了新的天氣，在第一時間通知所有的觀察者 weatherStation.setMeasurements(16, 50, "多云"); weatherStation.setMeasurements(12, 60, "大風"); weatherStation.setMeasurements(12, 90, "小雨"); weatherStation.setMeasurements(11, 98, "大雨"); } } ~~~ # 運行結果直接從eclipse復制過來 ~~~ This is Current Condition Display This is Statictic Display Current Conditions: 20.0 C degrees and 30.0% humidity 晴天 Avg/Max/Min temperture: 20.0/20.0/20.0 Current Conditions: 16.0 C degrees and 50.0% humidity 多云 Avg/Max/Min temperture: 18.0/20.0/16.0 Current Conditions: 12.0 C degrees and 60.0% humidity 大風 Avg/Max/Min temperture: 16.0/20.0/12.0 Current Conditions: 12.0 C degrees and 90.0% humidity 小雨 Avg/Max/Min temperture: 15.0/20.0/12.0 Current Conditions: 11.0 C degrees and 98.0% humidity 大雨 Avg/Max/Min temperture: 14.2/20.0/11.0 ~~~ # 總結這個觀察者模式，多個觀察者(Observer)“圍觀”一個被觀察者(Subject)，被觀察者是萬眾矚目的焦點。觀察者如果想得到Subject的“觀察權”，首先需要向Subject **申請注冊**，如果惹Subject生氣了，不讓你觀察了，就把你**踢開**。Subject一旦發生了變化，就立刻**通知**所有觀察者，引起觀察者的**更新**。黑體字就是Subject接口中的三個和Observer接口中的一個關鍵的抽象方法，必須實現：申請注冊：registerObserver() 踢開 ?????：removeObserver() 通知 ?????：notifyObservers() 更新 ?????：update() 值得注意的是：update()方法傳遞的參數，可以傳遞整個subject對象，也可以只傳遞部分有用的數據成員。實驗樓網站課程中的例子就是傳遞整個subject對象，《Head First Design Pattern》就是傳遞部分有用的數據成員。無論無何，最關鍵的是： Subject對象中的數據成員發生改變 → 觸發Subject.notifyObservers()方法 → 觸發所有Observer.update() 方法。萬變離不開這個鏈條。 Java中有一個java.util.Observable類（被觀察者，Subject）；還有一個java.util.Observer接口（觀察者，Obserer）。看來觀察者模式很常用，以至于都寫進到java類庫里面去了。 [更多設計模式，在新標簽頁中打開這里](http://blog.csdn.net/u013390476/article/details/50333763)