觀察者模式的流程跟報紙訂閱方式一致，即：觀察者模式=出版者+訂閱者，只是名稱不一樣，出版者改稱為“主題”（Subject），訂閱者改稱為“觀察者”（Observer）。
　　觀察者定義：
　　觀察者模式定義了對象之間的一對多依賴，當一個對象改變狀態時，它的所有依賴者都會受到通知并自動更新。
　　主題接口（Subject）：對象使用此接口注冊為觀察者，或者把自己從觀察者中刪除。
　　具體主題（ConcreteSubject）：一個具體主題總是實現主題接口，除了注冊*和撤銷方法以外，具體主題還實現了notifyObserves（）方法，此方法用于在狀態改變時更新所有當前觀察者。
　　觀察者（Observer）：為那些在目標發生改變時需獲得通知的對象定義更新的接口
　　具體觀察者（ConcreteObserver）：具體觀察者實現了觀察者Observer接口，并注冊具體主題，以便接收更新。
　　觀察者模式提供了一種對象設計，讓主題和觀察者之間松耦合，當兩個對象之間松耦合，它們依然可以交互，但是不太清楚彼此的細節，主題只知道觀察者實現了Observer接口，不需要知道觀察者的具體類是誰，做了些什么其他的細節。
　　觀察者實例：
　　通過ConcreteObserver注冊兩個觀察者ConcreteObserverA和ConcreteObserverB，一旦被觀察者有更新，兩個觀察者會立刻收到更新通知。具體代碼如下：
　　聲明Subject主題接口，Subject.java：
　　publicinterfaceSubject { voidregisterObserver（Observer observer）;voidremoveObserver（Observer observer）; voidnotifyObservers（）; }
　　聲明ConcreteObserver具體主題，NetConcreteSubject.java：
　　publicclassNetConcreteSubjectimplementsSubject{privateList《Observer》 observers;privateObserverBean bean; publicNetConcreteSubject（） { observers = newArrayList《》（）; }@OverridepublicvoidregisterObserver（Observer observer） { observers.add（observer）; }@OverridepublicvoidremoveObserver（Observer observer） { intpos = observers.indexOf（observer）; if（pos 》 0） { observers.remove（pos）; } }@OverridepublicvoidnotifyObservers（） { if（bean == null） return; for（ inti = 0; i 《 observers.size（）; i++） { Observer observer = observers.get（i）; observer.update（bean）; } }publicvoidsetStatusChanged（ObserverBean bean） { this.bean = bean; notifyObservers（）; } }
　　聲明觀察者接口， Observer.java：
　　publicinterfaceObserver { voidupdate（Object obj）; }
　　聲明具體觀察者類，ConcreteObserverA.java：
　　publicclassConcreteObserverAimplementsObserver{@Overridepublicvoidupdate（Object obj） { if（obj instanceofObserverBean） { ObserverBean bean = （ObserverBean） obj; System.out.print（ “ConcreteObserverA 網絡類型：”+ bean.netType + “，網絡狀態：”+ bean.netStatus + “\n”）; } } }
　　ConcreteObserverB.java：
　　publicclassConcreteObserverBimplementsObserver{@Overridepublicvoidupdate（Object obj） { if（obj instanceofObserverBean） { ObserverBean bean = （ObserverBean） obj; System.out.print（ “ConcreteObserverB 網絡類型：”+ bean.netType + “，網絡狀態：”+ bean.netStatus + “\n”）; } } }
　　調用過程：
　　publicstaticvoidmain（String［］ args） { //初始化主題（被觀察者）NetConcreteSubject subject =newNetConcreteSubject（）; //初始化觀察者AConcreteObserverA observerA =newConcreteObserverA（）; //初始化觀察者BConcreteObserverB observerB =newConcreteObserverB（）; //注冊觀察者Asubject.registerObserver（observerA）; //注冊觀察者Bsubject.registerObserver（observerB）; //通知所有觀察者數據有更新ObserverBean bean = newObserverBean（ “wifi”， “有網”）; subject.setStatusChanged（bean）; }
　　運行結果：
　　ConcreteObserverA 網絡類型：wifi，網絡狀態：有網 ConcreteObserverB 網絡類型：wifi，網絡狀態：有網Java內置觀察者：
　　Observable.java：
　　/** * Java學習交流QQ群：589809992 我們一起學Java！ */publicclassObservable{privatebooleanchanged = false; privateVector《Observer》 obs =newVector（）; publicObservable（） { } publicsynchronizedvoidaddObserver（Observer var1） {if（var1 == null） { thrownewNullPointerException（）; } else{ if（！ this.obs.contains（var1）） {this.obs.addElement（var1）; } } } publicsynchronizedvoiddeleteObserver（Observer var1） {this.obs.removeElement（var1）; } publicvoidnotifyObservers（） {this.notifyObservers（（Object） null）; } publicvoidnotifyObservers（Object var1） { Object［］ var2; synchronized（ this） { if（！ this.changed） { return; } var2 = this.obs.toArray（）;this.clearChanged（）; } for（ intvar3 = var2.length - 1; var3 》= 0; --var3） { （（Observer）var2［var3］）.update（ this， var1）; } } publicsynchronizedvoiddeleteObservers（） {this.obs.removeAllElements（）; } protectedsynchronizedvoidsetChanged（） { this.changed =true; } protectedsynchronizedvoidclearChanged（） { this.changed = false; }publicsynchronizedbooleanhasChanged（） { returnthis.changed; }publicsynchronizedintcountObservers（） { returnthis.obs.size（）; } }
　　Observer.java：
　　publicinterfaceObserver { voidupdate（Observable var1， Object var2）; }
　　上面的Observer和Observable類都位于java.util目錄中，是JDK中已經寫好的，那么我們可以直接拿來用了：
　　主題類NetSubject.java：
　　publicclassNetSubjectextendsObservable{publicvoidsetNetChanged（ObserverBean bean）{ setChanged（）; notifyObservers（bean）; } }
　　觀察者SystemObserverA.java：
　　publicclassSystemObserverAimplementsObserver{@Overridepublicvoidupdate（Observable observable， Object o） { if（o instanceofObserverBean && observable instanceofNetSubject） { ObserverBean bean = （ObserverBean） o; System.out.print（ “ConcreteObserverA 網絡類型：”+ bean.netType + “，網絡狀態：”+ bean.netStatus + “\n”）; } } }
　　觀察者SystemObserverB.java：
　　/** * Java學習交流QQ群：589809992 我們一起學Java！ */publicclassSystemObserverBimplementsObserver{@Overridepublicvoidupdate（Observable observable， Object o） { if（o instanceofObserverBean && observable instanceofNetSubject） { ObserverBean bean = （ObserverBean） o; System.out.print（ “ConcreteObserverB 網絡類型：”+ bean.netType + “，網絡狀態：”+ bean.netStatus + “\n”）; } } }
　　執行程序：
　　//初始化主題（被觀察者）NetSubject subject = newNetSubject（）; //初始化觀察者ASystemObserverA observerA = newSystemObserverA（）; //初始化觀察者BSystemObserverB observerB = newSystemObserverB（）; //注冊觀察者Asubject.addObserver（observerA）; //注冊觀察者Bsubject.addObserver（observerB）; //通知觀察者有更新ObserverBean bean = newObserverBean（ “4G流量”， “有網”）; subject.setNetChanged（bean）;
　　運行結果：
　　ConcreteObserverB 網絡類型：4G流量，網絡狀態：有網 ConcreteObserverA 網絡類型：4G流量，網絡狀態：有網

普通下載普通下載

相關電子資料下載

• 一文詳解ZGC關鍵技術 26
• SpringBoot物理線程、虛擬線程、Webflux性能比較 37
• Rust語言為什么這么卷？ 21
• 什么是分布式鎖 Redis的五種分布式鎖方案 32
• Guava中這些Map的操作，讓我的代碼量減少了50% 70
• java實現定時器的四種方式 83
• 基于OkHttp 3.10.0的源碼案例解析 26
• 如何用Rust通過JNI和Java進行交互 120
• JVM指針壓縮的工作原理 66
• 什么是SQL注入？Java項目防止SQL注入方式 37