定義了對象之間的一對多的依賴,這樣一來,當一個對象改變時,它的全部的依賴者都會收到通知並自動更新。java
被觀察者要繼承: Observable類 實現消息推送 、setChanged notifyObservers();ide
觀察者要繼承: Observer類 實現updata(); 註冊 this
package 觀察者模式; import java.util.Observable; import java.util.Observer; /** * * @author 紅塵Dream * 觀察者模式: 一對多的模式 * 當被觀察者發生變化時, 觀察者會受到通知自動更新 * 服務被觀察者 : 推送消息 通知觀察者 * 觀察者: 訂閱主題 自動更新消息 */ public class Test { public static void main(String[] args) { Service s = new Service(); //建立被觀察者 服務者 Observerl o = new Observerl(); //建立觀察者 Observerl o1 = new Observerl(); //建立觀察者 Observerl o2 = new Observerl(); //建立觀察者 Observerl o3 = new Observerl(); //建立觀察者 Observerl o4 = new Observerl(); //建立觀察者 o.registerService(s);//訂閱服務 o1.registerService(s); o2.registerService(s); o3.registerService(s); o4.registerService(s); //取消訂閱 o1.unRegisterService(s); s.setMsg("今天新聞熱點"); } } /** * 服務類 被觀察者 用於推送消息 */ class Service extends Observable { private String msg; public String getMsg() { return msg+"(來自服務者(被觀察者))"; } /** * * 推送消息 */ public void setMsg(String msg) { this.msg = msg; setChanged();//設置改變 notifyObservers();// 通知觀察者 } }
/**
* 被觀察者 類
*/ class Observerl implements Observer { /** * 訂閱 服務 * */ public void registerService(Observable observable) { observable.addObserver(this); } /** * 取消訂閱 */ public void unRegisterService(Observable observable) { observable.deleteObserver(this); } /** * 實現觀察者的更新方法 */ @Override public void update(Observable arg0, Object arg1) { if(arg0 instanceof Service) { Service s = (Service) arg0; System.out.println("觀察者更新:"+s.getMsg()); } } }
執行結果:spa
觀察者更新:今天新聞熱點(來自服務者(被觀察者))
觀察者更新:今天新聞熱點(來自服務者(被觀察者))
觀察者更新:今天新聞熱點(來自服務者(被觀察者))
觀察者更新:今天新聞熱點(來自服務者(被觀察者))