一、定义
观察者模式,又称为发布订阅模式
根据《设计模式》上对该模式的定义就是——一种一对多的关系,让多个观察者对象同时监听某一个主题对象,这个主题对象在状态发生变化时,会通知所有的观察者对象,使得他们能够自动更新自己。
其实,就相当于,校园广播一样,当校长说周一升旗仪式因为下雨而取消,这时候,安装了喇叭的教室班级全部收到了这个通知,而没有安装的自然就收不到这个通知。安装了喇叭的教室班级就相当于观察者,它随时随地监听来自广播室的通知,一旦有个通知公告,就可以立刻受到。
二、模式结构图
这里,为了便于理解,我设定是老师充当主题对象,他负责通知学生一些事情。学生就是具体的观察者。
简单说明:
(1)Subject类是 主题或者抽象通知者,一般用一个抽象类或者接口实现,它把所有对观察者对象的引用保存在一个聚集(集合)里,提供了两个方法,增加或者删除观察者对象。
(2)Observer类就是观察者类,抽象的观察者,为所有的具体观察者定义一个接口或者抽象类,在得到主题的通知时更新自己;
之所以通知发布者与观察者都需要先定义为一个抽象类或者接口类,是为了减少代码耦合,如果具体地写明教师为主题通知类,学生为具体观察者类,未尝不可,只是当情况有改变时候,需要变动的代码就多了。比如说,我需要增加一个后勤阿姨作为观察者,那么就需要同时去修改教师类了。
三、具体实现
(1)Subject类 ,抽象类
<pre name="code" class="java">package ObserverMode; import java.util.List; import java.util.ArrayList; /** * 主题或者抽象通知者,一般用一个抽象类或者接口实现,它把所有对观察者对象的 * 引用保存在一个聚集(集合)里,提供了两个方法,增加或者删除观察者对象。 * @author snail */ public abstract class Subject { private List<Observer> list = new ArrayList<Observer>(); //add observer public void Attach(Observer observer){ list.add(observer); } //delete observer public void Detach(Observer observer){ if (list.contains(observer)) { list.remove(observer); return ; }else{ return ; } } //notify public void Notify(){ for (Observer observer : list) { observer.Update(); } } }
(2)Observer类,接口类,每一个具体的观察者都必须实现该接口
/** * 抽象观察者,为所有的具体观察者定义一个接口或者抽象类,在得到主题的通知时更新自己 * @author snail * @time 2014-7-27上午10:59:38 * TODO */ public interface Observer { public void Update(); }
(3)TeacherSubject类,具体的主题通知者,必须继承Subject抽象类。
package ObserverMode; /** * 具体通知者,将有关状态存入具体观察者对象,在具体主题的内部状态改变时, 给所有登记过的观察者发出通知 * * @author snail * @time 2014-7-27下午03:21:53 */ public class TeacherSubject extends Subject { private String updateContent;//发布的通知内容 public String getUpdateContent() { return updateContent; } public void setUpdateContent(String updateContent) { this.updateContent = updateContent; } }
(4)StudentObserver类,具体的观测者,必须实现Observer接口,不然无法收到来自老师的通知
/** * 具体观察者,这里以学校的具体某个学生为例子 * @author snail * @time 2014-7-27下午03:23:57 * TODO */ public class StudentObserver implements Observer{ private String studentName ; protected TeacherSubject subject; public StudentObserver(String studentName,TeacherSubject subject){ this.studentName = studentName; this.subject = subject; } @Override public void Update() { System.out.println(studentName+"收到通知:"+subject.getUpdateContent()); if (subject.getUpdateContent().equals("下午三点开会")) { System.out.println(studentName+"说:不好意思,我请假,因为我下午三点有考试"); } } }
(5)测试该模式
public class Main { public static void main(String[] args){ //老师充当一个发布通知管理者,现在负责通知两个学生 TeacherSubject subject = new TeacherSubject(); subject.Attach(new StudentObserver("大明", subject)); subject.Attach(new StudentObserver("小敏", subject)); subject.setUpdateContent("下午三点开会"); subject.Notify(); System.out.println("第一次通知发送完毕"); subject.setUpdateContent("既然有考试,那改为下午5点开会"); subject.Notify(); System.out.println("第二次通知发送完毕"); } }
(6)结果
说明:此笔记学习受益于《大话设计模式》与《head first 设计模式》
原文地址:http://blog.csdn.net/linfeng24/article/details/38173025