软件设计模式之-观察者模式与被观察者模式
2016-06-11 22:13
597 查看
一、何为观察者模式?
观察者模式(有时又被称为发布/订阅模式)是软体设计模式的一种。在此种模式中,一个被观察对象管理所有相依于它的观察者对象,观察对象要在被观察对象注册。并且在它本身的状态改变时主动发出通知。这通常透过呼叫各观察者所提供的方法来实现。此种模式通常被用来实作事件处理系统。
二、使用它它有何好处?
观察者模式(Observer)完美的将观察者和被观察的对象分离开。举个例子,用户界面可以作为一个观察者,业务数据是被观察者,用户界面观察业务数据的变化,发现数据变化后,就显示在界面上。面向对象设计的一个原则是:系统中的每个类将重点放在某一个功能上,而不是其他方面。一个对象只做一件事情,并且将他做好。观察者模式在模块之间划定了清晰的界限,提高了应用程序的可维护性和重用性。
三、实现方式
观察者模式有很多实现方式,从根本上说,该模式必须包含两个角色:观察者和被观察对象。在刚才的例子中,业务数据是被观察对象,用户界面是观察者。观察者和被观察者之间存在“观察”的逻辑关联,当被观察者发生改变的时候,观察者就会观察到这样的变化,并且做出相应的响应。如果在用户界面、业务数据之间使用这样的观察过程,可以确保界面和数据之间划清界限,假定应用程序的需求发生变化,需要修改界面的表现,只需要重新构建一个用户界面,业务数据不需要发生变化。
四、JDK中的Observer接口和Observable类实现
1.在Observer接口源代码中只声明一个update()方法
成为观察者只要实现这个方法,并实现update方法
该方法让被观察者对象属性改变时回调这个方法。
2.Observable类,被观察者,消息的发出者,继承该类可以成为被观察者。下面是java 类库设计的被观察者需要继承的可观察类。内部用Vector
观察者模式(有时又被称为发布/订阅模式)是软体设计模式的一种。在此种模式中,一个被观察对象管理所有相依于它的观察者对象,观察对象要在被观察对象注册。并且在它本身的状态改变时主动发出通知。这通常透过呼叫各观察者所提供的方法来实现。此种模式通常被用来实作事件处理系统。
二、使用它它有何好处?
观察者模式(Observer)完美的将观察者和被观察的对象分离开。举个例子,用户界面可以作为一个观察者,业务数据是被观察者,用户界面观察业务数据的变化,发现数据变化后,就显示在界面上。面向对象设计的一个原则是:系统中的每个类将重点放在某一个功能上,而不是其他方面。一个对象只做一件事情,并且将他做好。观察者模式在模块之间划定了清晰的界限,提高了应用程序的可维护性和重用性。
三、实现方式
观察者模式有很多实现方式,从根本上说,该模式必须包含两个角色:观察者和被观察对象。在刚才的例子中,业务数据是被观察对象,用户界面是观察者。观察者和被观察者之间存在“观察”的逻辑关联,当被观察者发生改变的时候,观察者就会观察到这样的变化,并且做出相应的响应。如果在用户界面、业务数据之间使用这样的观察过程,可以确保界面和数据之间划清界限,假定应用程序的需求发生变化,需要修改界面的表现,只需要重新构建一个用户界面,业务数据不需要发生变化。
四、JDK中的Observer接口和Observable类实现
1.在Observer接口源代码中只声明一个update()方法
成为观察者只要实现这个方法,并实现update方法
public interface Observer { //这个方法被每当观测目标被改变了,让被观察者调用 void update(Observable o, Object arg); },这个
该方法让被观察者对象属性改变时回调这个方法。
2.Observable类,被观察者,消息的发出者,继承该类可以成为被观察者。下面是java 类库设计的被观察者需要继承的可观察类。内部用Vector
package java.util; public class Observable { private boolean changed = false; //观察者的集合 private Vector obs; /** Construct an Observable with zero Observers. */ public Observable() { obs = new Vector(); } //vector非线程安全所以这里同步下 public synchronized void addObserver(Observer o) { if (o == null) throw new NullPointerException(); if (!obs.contains(o)) { obs.addElement(o); } } public synchronized void deleteObserver(Observer o) { obs.removeElement(o); } public void notifyObservers() { notifyObservers(null); } //通知所有订阅此主题的观察者对象,arg是需要通知的信息,可以是文本, public void notifyObservers(Object arg) { Object[] arrLocal; //同步代码块 synchronized (this) { //若主题没有改变,返回 if (!changed) return; arrLocal = obs.toArray(); clearChanged();//避免重复通知 } for (int i = arrLocal.length-1; i>=0; i--) //通知观察者,调用观察者的update()方法 ((Observer)arrLocal[i]).update(this, arg); } //清空所有观察此主题的观察者 public synchronized void deleteObservers() { obs.removeAllElements(); } //被观察对象改变,设置标志位 protected synchronized void setChanged() { changed = true; } //清除标志位 protected synchronized void clearChanged() { changed = false; } //判断被观察者实例是否改变 public synchronized boolean hasChanged() { return changed; } //返回观察者的数量 public synchronized int countObservers() { return obs.size(); } }
测试用例
package Observer.test; import java.util.Date; import java.util.Observable; import java.util.Observer; public class ObserverTest { public ObserverTest() { // TODO Auto-generated constructor stub } /** * 被观察者 * * @author cindy */ static class weChatSubscription extends Observable { // 表示铁道部可以被观察 private String message;// 官方消息 private String name; public weChatSubscription(String name) { this.name = name; } public String getMessagee() { return this.message; } public void setMessgae(String message) { // 每一次修改的时候都应该引起观察者的注意 System.out.println("****************************************"); System.out.println(this.name + "\t" + new Date() + "发布官方发布消息为:" + message); super.setChanged(); // 设置变化点,设置消息改变的状态 super.notifyObservers(message);// 调用方法通知所有观察者, this.message = message; } }; /** * 观察者 ,实现observer接口 * * @author cindy * */ class weChatSubscriptionUser implements Observer { private String name; public weChatSubscriptionUser(String name) { // 设置每一个观察者的名字 this.name = name; } @Override public void update(Observable o, Object arg) { System.out.print(this.name + " 你好:"); System.out.println(arg.toString()); } }; public static void main(String args[]) { ObserverTest ot = new ObserverTest(); weChatSubscription h = new weChatSubscription("小道消息"); weChatSubscriptionUser hpo1 = ot.new weChatSubscriptionUser("vincent"); weChatSubscriptionUser hpo2 = ot.new weChatSubscriptionUser("jack"); weChatSubscriptionUser hpo3 = ot.new weChatSubscriptionUser("a laC"); // 将观察者注册到被观察者哪里 h.addObserver(hpo1); h.addObserver(hpo2); h.addObserver(hpo3); h.setMessgae("晚上好"); // 修改官方消息 h.setMessgae("大家端午节过得怎么样啊!"); // 修改官方消息 h.setMessgae(" 晚安"); // 修改官方消息 } }
相关文章推荐
- Struts2总结
- 《c陷阱与缺陷》1-3章笔记
- 网站推广
- IT项目经理概述
- 移动端上传照片 预览+Draw on Canvas's Demo(解决 iOS 等设备照片旋转 90 度的 bug)
- leetcode_c++:Word Ladder II(126)
- string &stringBuilder & stringBuffer
- 白话经典算法系列之一 冒泡排序的三种实现 【转】
- xml基础及其解析xml文档
- 编写一个程序,将a.txt文件中的单词与b.txt文件中的单词交替合并到c.txt文件中,a.txt文件中的单词用回车符分隔,b.txt文件中用回车或空格进行分隔
- Android Studio的下载和安装教程(从ADT到AS)
- unix
- 第二冲刺项目进展
- mysql—使用mysqladmin修改密码
- 一次miniSQL调试记录
- leetcode 22. Generate Parentheses
- 数据结构(树链剖分,线段树):SDOI 2016 游戏
- JavaScript---网络编程(6)-Dom和Bom模型概念讲解(节点获取,window对象)
- JavaScript---网络编程(6)-Dom和Bom模型概念讲解(节点获取,window对象)
- iOS 下的相册与图片处理