大家好，你還在面向 for 回圈編程嗎？
還有誰不會用觀察者模式嗎？
本篇堆疊長帶來《觀察者模式》理論及實戰～
什么是觀察者模式？
觀察者模式（Observer Pattern）定義了物件間的一種一對多的依賴關系，這樣只要一個物件的狀態發生改變，其依賴的所有相關物件都會得到通知并自動更新，
在觀察者模式中，發生改變的物件叫做觀察目標，而被通知更新的物件稱為觀察者，一個觀察目標對應多個觀察者，觀察者一般是一個串列集合，可以根據需要動態增加和洗掉，易于擴展，
使用觀察者模式的優點在于觀察目標和觀察者之間是抽象松耦合關系，降低了兩者之間的耦合關系，
發布-訂閱模式
觀察者模式很多地方也叫發布－訂閱模式（Publish/Subscribe），其實也可以這么理解，不過兩者之間還是略有不同，
觀察者模式中的觀察者是直接系結觀察目標，觀察目標要維護一套觀察者串列，兩者是有一個基于介面的組合依賴關系的，所以說觀察者模式雖然是松耦合的，但并不是完全解耦的，
而發布－訂閱模式中的發布者和訂閱者兩者并沒有任何聯系，發布者通過中間方發布一個主題（Topic），訂閱者通過中間方（調度中心）訂閱一個主題（Topic），發布者狀態的變更也并不會直接通知訂閱者，而要通過中間方進行通知，或者訂閱者自行從中間方拉取，所以說發布－訂閱模式是完全解耦的，
一圖搞懂它們的關系：
從圖片看兩者是有差別的，統一都叫觀察者模式，也沒毛病，
觀察者模式輪子
因觀察者模式應用比較廣泛，所以 JDK 工具包從 1.0 版本里面自帶了觀察者模式模板套裝，我們根據其模板很方便就能實作觀察者模式，不需要再重復造輪子了，
觀察者目標類：
java.util.Observable
里面兩個最重要的變數：
- changed：觀察目標狀態是否變更，默認為：false；
- obs：觀察者串列（observers），一個執行緒安全的串列集合：Vector，默認為空集合；
里面的重要的方法都是和觀察目標狀態和觀察者相關的，一看就清楚，這里就不介紹了，
觀察者介面：
java.util.Observable
public interface Observer {
/**
* This method is called whenever the observed object is changed. An
* application calls an <tt>Observable</tt> object's
* <code>notifyObservers</code> method to have all the object's
* observers notified of the change.
*
* @param o the observable object.
* @param arg an argument passed to the <code>notifyObservers</code>
* method.
*/
void update(Observable o, Object arg);
}
觀察者介面只有一個 update 方法，用來通知觀察者自己更新，
觀察者模式實戰
OK，知道了 JDK 自帶了這兩個東東，現在就來實作一個簡單的觀察者模式的應用場景，模擬公眾號文章推送，觀察目標是堆疊長我，觀察者是你們大家，我在公眾號Java技術堆疊推一篇文章，你們都能接收到更新通知并能閱讀，
新增觀察目標類：
import lombok.Getter;
import java.util.Observable;
/**
* 觀察目標：堆疊長
* 來源微信公眾號：Java技術堆疊
*/
@Getter
public class JavaStackObservable extends Observable {
private String article;
/**
* 發表文章
* @param article
*/
public void publish(String article){
// 發表文章
this.article = article;
// 改變狀態
this.setChanged();
// 通知所有觀察者
this.notifyObservers();
}
}
觀察目標的邏輯是先發表文章，再改變觀察目標的狀態，再通知所有觀察者，
我們來重點看 notifyObservers 方法的原始碼：
先獲取同步鎖，判斷狀態是否更新，如已更新則清空觀察目標狀態，然后再使用 for 回圈遍歷所有觀察者，一一呼叫觀察者的更新方法通知觀察者更新，
新增觀察者類：
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import java.util.Observable;
import java.util.Observer;
/**
* 觀察者：讀者粉絲
* 來源微信公眾號：Java技術堆疊
*/
@RequiredArgsConstructor
public class ReaderObserver implements Observer {
@NonNull
private String name;
private String article;
@Override
public void update(Observable o, Object arg) {
// 更新文章
updateArticle(o);
}
private void updateArticle(Observable o) {
JavaStackObservable javaStackObservable = (JavaStackObservable) o;
this.article = javaStackObservable.getArticle();
System.out.printf("我是讀者：%s，文章已更新為：%s\n", this.name, this.article);
}
}
觀察者的邏輯是獲取到觀察者目標實體物件，然后再用觀察目標物件的文章資訊更新為自己的文章資訊，最后輸出某某某的文章已更新，
觀察者只要實作 Observer 這個介面的 update 方法即可，用于觀察目標進行呼叫通知，
本節教程所有實戰原始碼已上傳到這個倉庫：https://github.com/javastacks/javastack
觀察目標和觀察者類結構圖如下：
新增測驗類：
/**
* 觀察者：讀者粉絲
* 來源微信公眾號：Java技術堆疊
*/
public class ObserverTest {
public static void main(String[] args) {
// 創建一個觀察目標
JavaStackObservable javaStackObservable = new JavaStackObservable();
// 添加觀察者
javaStackObservable.addObserver(new ReaderObserver("小明"));
javaStackObservable.addObserver(new ReaderObserver("小張"));
javaStackObservable.addObserver(new ReaderObserver("小愛"));
// 發表文章
javaStackObservable.publish("什么是觀察者模式？");
}
}
觀察目標、觀察者的創建并沒有先后順序要求，重點是發表文章通知觀察者之前，觀察目標要添加觀察者串列這一步不能少，
輸出結果：
通過這個簡單的文章推送實踐，大家應該對觀察者模式有一個基本的認知了，在實際作業當中也可以有很多場景拿去用，就一對多的依賴關系都可以考慮使用觀察者模式，
總結
不容易啊，陸陸續續又肝了大半天，你學會觀察者模式了嗎？
觀察者模式的優點是為了給觀察目標和觀察者解耦，而缺點也很明顯，從上面的例子也可以看出，如果觀察者物件太多的話，有可能會造成記憶體泄露，
另外，從性能上面考慮，所有觀察者的更新都是在一個回圈中排隊進行的，所以觀察者的更新操作可以考慮做成執行緒異步（或者可以使用執行緒池）的方式，以提升整體效率，
本節教程所有實戰原始碼已上傳到這個倉庫：
https://github.com/javastacks/javastack
好了，今天的分享就到這里了，后面堆疊長我會更新其他設計模式的實戰文章，公眾號Java技術堆疊第一時間推送，Java技術堆疊《設計模式》系列文章陸續更新中，請大家持續關注哦！
最后，覺得我的文章對你用識訓的話，動動小手，給個在看、轉發，原創不易，堆疊長需要你的鼓勵，
著作權申明：本文系公眾號 "Java技術堆疊" 原創，原創實屬不易，轉載、參考本文內容請注明出處，禁止抄襲、洗稿，請自重，尊重他人勞動成果和知識產權，
轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/270951.html
標籤：設計模式
上一篇：PHP設計模式—模板方法模式
下一篇：醫惠集成平臺調研方案分析（二）