觀察者模式：探索消息推送與註冊中心

1、引入話題-發散思考

一、若是你是安卓開發工程師，是否常常遇到給全部的用戶或者特定的用戶推送消息的業務場景呢？例如：我曾經作的一款APP就是用極光推送一個消息，下載該APP的用戶都能收到消息提示。

 

二、若是你瞭解zookeeper分佈式調節框架？假設一個集羣有1000臺機器Master-Slave結構，我想給這個集羣修改配置文件，都是如出一轍的文件在不一樣機器上，難道咱們一臺一臺機器修改？答案是固然不能。那怎麼解決？那配置文件註冊到zookeeper上，而後集羣機器監聽配置文件的變化，當配置文件改變之後，觀察者就能知道，而且對配置文件做出對應的配置。若是興趣想詳細瞭解看我zookeeper文章介紹。

2、簡介

觀察者模式：定義了對象之間的一對多依賴，這樣一來，當一個對象改變狀態時，它的全部依賴者都會接受到通知而且自動更新。

 

應用場景：

• 消息推送（廣播）
• 註冊中心/消息訂閱

場景描述：

     假設觀察者們都是電燈泡，當他們的state爲1的時候，全部的電燈泡都點亮，若是state爲0的時候，全部的電燈泡都熄滅。那麼假設有一個電燈泡註冊中心，也就是總開關，全部的電燈泡的控制權都需在電燈泡註冊中心手上，當註冊中心設置燈泡的開關爲1的時候，全部的電燈泡都會收到一個消息，那麼就會根據消息數據作出相應的反應。

 

2、自定義接口實現

//主題接口
public interface Subject { void registerObserver(Observer observer); void removeObject(Observer observer); void notifyObservers(); } //主題具體實現類
public class ConcreteSubject implements Subject{ List<Observer> observers=new ArrayList<Observer>(); private int state; //註冊觀察者 
 @Override public void registerObserver(Observer observer) { observers.add(observer); } //移除觀察者
 @Override public void removeObject(Observer observer) { int index=observers.indexOf(observer); if(index>=0){ observers.remove(index); return; } } //通知觀察者：相似消息推送
 @Override public void notifyObservers() { for(Observer observer:observers){ observer.update(this); } } public int getState() { return state; } public void setState(int state) { this.state = state; notifyObservers(); } } //觀察者接口
public interface Observer { void update(Subject subject); } //觀察者實現類
public class ConcreteObserver implements Observer{ private int state; //同步主題的狀態
 @Override public void update(Subject subject) { this.state=((ConcreteSubject)subject).getState(); } public int getState() { return state; } public void setState(int state) { this.state = state; } } //客戶端測試類
public class Client { public static void main(String[] args) { Subject subject=new ConcreteSubject(); ConcreteObserver observerA=new ConcreteObserver(); ConcreteObserver observerB=new ConcreteObserver(); subject.registerObserver(observerA); subject.registerObserver(observerB); ((ConcreteSubject)subject).setState(10); System.out.println("觀察者A(訂閱者A)："+observerA.getState()); System.out.println("觀察者B(訂閱者B)："+observerB.getState()); } } 運行結果： 觀察者A(訂閱者A)：10 觀察者B(訂閱者B)：10

3、Java提供API

//具體主題類（繼承自主題類Observable）
public class ConcreteSubject extends Observable{ private int state; public void setState(int state) { this.state = state; setChanged(); notifyObservers(); } public int getState() { return state; } } //具體觀察者（實現javaAPI Observer）
public class ConcreteObserver implements Observer{ private int state; @Override public void update(Observable o, Object arg) { this.state=((ConcreteSubject)o).getState(); } public int getState() { return state; } } //客戶端
public class Client { public static void main(String[] args) { ConcreteSubject subject=new ConcreteSubject(); ConcreteObserver observerA=new ConcreteObserver(); ConcreteObserver observerB=new ConcreteObserver(); subject.addObserver(observerA); subject.addObserver(observerB); subject.setState(123); System.out.println("觀察者A(訂閱者A)："+observerA.getState()); System.out.println("觀察者B(訂閱者B)："+observerB.getState()); } } 運行結構： 觀察者A(訂閱者A)：123 觀察者B(訂閱者B)：123

4、版權聲明

　　做者：邱勇Aaron

　　出處：http://www.cnblogs.com/qiuyong/

　　您的支持是對博主深刻思考總結的最大鼓勵。

　　本文版權歸做者全部，歡迎轉載，但未經做者贊成必須保留此段聲明，且在文章頁面明顯位置給出原文鏈接，尊重做者的勞動成果。

　　參考：Head First 設計模式