设计模式之:解剖观察者模式
[size=9]论坛上很多人都讲设计模式,也讲了很多设计模式,现在也来说说我对一些设计模式的理解,对于一些简单的模式就不多说了,一切都在我以前写的例子中使用到了,比如说在velocity和freemarker的比较那篇文章里用到了单例,工厂,方法模板,在java邮件,在简单和复杂之间那篇文章里用到了策略,适配,在easywebwork中也使用了几种设计模式,在哪些文章我没有对设计模式进行详细的讲解是因为我觉得那些都是些常用的模式,大家肯定经常见到,一看就明白了,根本用不着讲解,而在那篇《解惑:在spring+hibernate中,只读事务是如何被优化的。http://www.iteye.com/topic/95124 》的文章中我提到了hibernate中的观察者模式的使用,但是仅仅是一张图而已,今天我就来详细的把对观察者模式的理解阐述出来,希望大家批评指正,欢迎大家拍砖。
在ibm的技术文章中也有一个老外详细讲解了如何使用aop来增强观察者模式(文章地址见:http://www.ibm.com/developerworks/cn/java/j-aopwork6/ )。
为了便于理解,首先我举一个现实生活中的例子:在快乐男生比赛过程其实就是观察者的一个体现,可以这样说吉杰是一个被观察者,而杨二,包小柏,还有巫启贤就是3个观察者,被观察者操作(唱歌)时,观察者们就开始操作(评分),被观察者唱歌就是通知观察者们进行评分。
GoF说道:Observer模式的意图是“定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新”。从这段话里我们可以得到两个信息,如下:
1,观察者(具体执行操作的对象,有多个)
2,被观察者(顾名思义是被观察的对象,如果该对象发生某些变化则通知观察者执行对应的操)
接下来我们看一下附件中的图(请下载附件中的图 http://www.iteye.com/topics/download/eed23def-b8a8-43dc-a753-73d740a3ded0 ),这个图是观察者模式的真实体现,在这个图中有两个类,java.util.Observable,在我们实现观察者模式的时候,我们的被观察者应该继承这个类,这个observable类把持住了被观察者所持有的观察者列表:
public class Observable { private boolean changed = false; private Vector obs; //创建被观察者时就创建一个它持有的观察者列表,注意,这个列表是需要同步的。 public Observable() {obs = new 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); } /** * 与上面的那个通知方法不同的是,这个方法接受一个参数,这个参数一直传到观察者里,以供观察者使用 */ 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--) ((Observer)arrLocal[i]).update(this, arg); }}
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);}}
/** * @author 张荣华(ahuaxuan)* @version $Id$ */public class MailObserver implements Observer{/** * 这个类取名为MailObserver,顾名思义,她是一个用来发送邮件的观察者 */public void update(Observable o, Object arg) {System.out.println("发送邮件的观察者已经被执行");}}
/** * @author 张荣华(ahuaxuan) * @version $Id$ */public class JMSObserver implements Observer{public void update(Observable o, Object arg) {System.out.println("发送消息给jms服务器的观察者已经被执行");}}
/** * @author 张荣华(ahuaxuan)* @version $Id$ */public class Subject extends Observable{/** * 业务方法,一旦执行某个操作,则通知观察者 */public void doBusiness(){if (true) {super.setChanged();}notifyObservers("现在还没有的参数");}public static void main(String [] args) {//创建一个被观察者Subject subject = new Subject();//创建两个观察者Observer mailObserver = new MailObserver();Observer jmsObserver = new JMSObserver();//把两个观察者加到被观察者列表中subject.addObserver(mailObserver);subject.addObserver(jmsObserver);//执行业务操作subject.doBusiness();}}