标签：
观察者模式，又被称为发布—订阅模式、源—收听者模式，是软件设计模式的一种。在此种模式中，一个目标物件管理所有相依与它的观察者物件，并且在它本身的状态改变时主动发出同时，此种模式通常被用来实现事件处理系统。
观察者模式一般包含以下四种角色：
抽象主题角色Watched：把所有对观察者对象的引用保存在一个集合中，每个抽象主题角色都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察这角色。
抽象观察者角色Watcher：为所有具体的观察者定义一个接口，在得到主题的通知更新自己。
具体主题角色ConcreteWatched：在具体主题内部状态改变时，给所有登记过的观察者发出通知。
具体观察者角色ConcreteWatcher：该角色实现抽象观察者角色所要求的更新接口，以便使自身的状态与主题的状态相协调。
观察者模式有很多实现方式，从根本上说，该模式必须包含两个角色，观察者和被观察对象。比较直观的一种是使用“注册”—“通知”—“撤销通知”的形式。
观察者将自己注册到被观察对象中，被观察者将观察者放在一个容器中。
被观察者对象发生某种变化时，从容器中得到所有被注册过的观察者，将变化通知观察者。
观察者将自己注册到被观察者的容器时，被观察者不应该过问观察者的具体类型，而是应该使用观察者的接口。这样的好处是：假定程序还有别的观察者，那么只要这个观察者也是相同的接口即可。一个被观察者可以对应多个观察者，当被观察者发生变化的时候，他可以将消息一一通知给所有的观察者。如下图所示：
具体到一个应用场景就是：读者订阅新闻，每一个读者都可以通过regist来订阅新闻，通过remove来取消订阅，当有新闻到来时，使用sendNews来通知每一位订阅的读者来收取新闻。
下面用代码来实现上面的实例：
抽象主题角色Watched：新闻接口，定义订阅、取消订阅和推送新闻三个方法
public interface Watched { //订阅新闻 void registeSubscriber(Watcher f_subscriber); //取消订阅 void removeSubscriber(Watcher f_subscriber); //推送新闻 void sendNews(); }
抽象观察者角色Watcher:读者接口，定义了获取新闻的方法
public interface Watcher { //获取新闻 void updateNews(); }
具体主题角色ConcreteWatched，即被观察者，实现了Watched接口：
import java.util.ArrayList; import java.util.List; /* * 具体被观察者 * 新闻发布者 */ public class ConcreteWatched implements Watched { private List<Watcher> subList=new ArrayList<Watcher>(); @Override public void registeSubscriber(Watcher f_subscriber) { subList.add(f_subscriber); } @Override public void removeSubscriber(Watcher f_subscriber) { subList.remove(f_subscriber); } @Override public void sendNews() {
System.out.println("开始本轮新闻推送！"); for (Watcher watcher : subList) { watcher.updateNews(); } System.out.println("本次新闻推送结束！"); } }
具体观察者角色ConcreteWatcher，即观察者对象
/* * 具体的观察者 * 读者 */ public class ConcreteWatcher implements Watcher { private String username; public ConcreteWatcher(String username) { super(); this.username = username; } @Override public void updateNews() { System.out.println(username+"获取到最新的新闻了！"); } }
下面是一个测试用例：
import org.junit.Test; public class WatchTest { @Test public void test() { ConcreteWatched concreteWatched=new ConcreteWatched(); Watcher watcher1=new ConcreteWatcher("读者A"); Watcher watcher2=new ConcreteWatcher("读者B"); Watcher watcher3=new ConcreteWatcher("读者C"); //订阅新闻 concreteWatched.registeSubscriber(watcher1); concreteWatched.registeSubscriber(watcher2); concreteWatched.registeSubscriber(watcher3); //推送新闻 concreteWatched.sendNews(); //读者A取消订阅 concreteWatched.removeSubscriber(watcher1); //再次推送新闻 concreteWatched.sendNews(); } }
执行结果：
1、http://www.cnblogs.com/mengdd/archive/2013/02/07/2908929.html
标签：
原文地址：http://www.cnblogs.com/xujian2014/p/5557612.html
