观察者模式
在 《Head First 设计模式》的定义为：
观察者模式定义了对象之间的一对多依赖，这样一来，当一个对象的状态发生改变的时候，它的所有依赖着都会收到通知并自动更新。
下面来是一个简单的例子：
####先看看类图： 
<br> ##### 观察者模式所涉及的角色有：
-
抽象主题（Subject）：一般为接口，提供一些公用的方法，如注册观察者，删除观察者和通知观察者等。每个主题都有多个观察者。
-
具体主题：实现抽象主题接口，当主题状态发生变化的时候，负责向观察者发出通知。当我们实现好一个具体主题后，在以后向其中注册观察者的时候，这个代码一般不用修改。
-
抽象观察者（Observer）：一般也为接口，定义所有观察者的共有的方法，向主题注册观察者的时候，一般以接口的形式，而不是以具体观察者的形式。
-
具体观察者：当主题状态发生改变的时候，进行更新，具体观察者一般保持一个具体主题对象的引用。
<br> ##### 代码：
抽象主题接口：
/** * 主题 * [@author](https://my.oschina.net/arthor) tsmyk * */public interface Subject { /** * 注册观察者 * [@param](https://my.oschina.net/u/2303379) observer 观察者 */ void registerObserver(Observer observer); /** * 删除观察者 * [@param](https://my.oschina.net/u/2303379) observer */ void removeObserver(Observer observer); /** * 通知观察者 * 当主题状态改变的时候，这个方法会被调用，以通知所有的观察者 */ void notifyObservers();} <br> **`具体的主题实现：`**
/** * 具体的主题实现 * [@author](https://my.oschina.net/arthor) tsmyk * */public class WetherData implements Subject{ private List observers = null; private String status; public WetherData(){ observers = new ArrayList<>(); } [@Override](https://my.oschina.net/u/1162528) public void registerObserver(Observer observer) { observers.add(observer); } @Override public void removeObserver(Observer observer) { if(observers.contains(observer)){ observers.remove(observer); } } @Override public void notifyObservers() { for(Observer o : observers){ o.update(status); } } /** * 当主题改变的时候，会自动通知所有的观察者 * @param status */ public void changeSataus(String status){ this.status = status; notifyObservers(); }} <br> **`抽象观察者：`**
/** * 抽象观察者 * @author tsmyk * */public interface Observer { void update(String msg);} <br> **`具体的观察者：`**
public class Observer_01 implements Observer{ private Subject subject; public Observer_01(Subject subject){ this.subject = subject; subject.registerObserver(this); } @Override public void update(String msg) { System.out.println("观察者1收到主题的改变：" + msg); }} <br>
public class Observer_02 implements Observer{ private Subject subject; public Observer_02(Subject subject){ this.subject = subject; subject.registerObserver(this); } @Override public void update(String msg) { System.out.println("观察者2收到主题的改变：" + msg); }} <br>
测试
/** * 测试 * @author tsmyk * */public class Main { public static void main(String[] args) { WetherData sub = new WetherData(); Observer o1 = new Observer_01(sub); Observer o2 = new Observer_02(sub); sub.changeSataus("主题状态发生改变了...."); }} <br> 结果：
观察者1收到主题的改变：主题状态发生改变了....观察者2收到主题的改变：主题状态发生改变了....
<br> 当创建观察者对象的时候，把主题当作参数，此时会把当前的观察者对象自动注入到主题的一个观察者集合中，当主题调用通知观察者的方法时，会遍历观察者集合，会依次调用观察者的**`update()`**方法来进行更新观察者的状态。
<br> ####观察者的两种模型 在观察者模式中，又分为推模型和拉模型两种方式。
###推模型 当主题状态发生变化的时候， 主题对象会自动的向观察者推送主题的变化信息，不管观察者是否需要，推送的信息通常是主题对象的全部或部分数据。
上面的例子就是一个推模型的实例。
###拉模型 当主题状态发生变化，通知观察者的时候并不会将全部的变化信息传递给观察者，只是传递少量信息给观察者，如果观察者需要更多的信息，则由观察者主动到主题对象里面获取，相当与观察者从主题中拉去信息。
下面是一个拉模型的例子：
拉模型一般把主题对象当作参数传递
抽象主题
/** * 抽象主题 * @author tsmyk * */public interface Subject { /** * 注册观察者 * @param observer 观察者 */ void registerObserver(Observer observer); /** * 删除观察者 * @param observer */ void removeObserver(Observer observer); /** * 通知观察者 * 当主题状态改变的时候，这个方法会被调用，以通知所有的观察者 */ void notifyObservers();} <br> **`具体的主题：`**
/** * 具体的主题 * @author tsmyk * */public class WetherData implements Subject{ private List observers = null; private String status; public WetherData(){ observers = new ArrayList<>(); } @Override public void registerObserver(Observer observer) { observers.add(observer); } @Override public void removeObserver(Observer observer) { if(observers.contains(observer)){ observers.remove(observer); } } //把主题对象当作参数传递给观察者 @Override public void notifyObservers() { for(Observer o : observers){ o.update(this); } } /** * 当主题改变的时候，会自动通知所有的观察者 * @param status */ public void changeSataus(String status){ this.status = status; notifyObservers(); } public String getStatus() { return status; }} <br>
抽象观察者：
/** * 抽象观察者 * @author tsmyk * */public interface Observer { //把主题当作参数 void update(Subject subject);} <br> **`具体的观察者：`**
public class Observer_01 implements Observer{ public Observer_01(Subject subject){ subject.registerObserver(this); } @Override public void update(Subject subject) { WetherData o1 = (WetherData)subject; //观察者自己去主题里面拉去消息 String msg = o1.getStatus(); System.out.println("观察者1自己去拉取主题的状态：" + msg); }} <br>
public class Observer_02 implements Observer{ public Observer_02(Subject subject){ subject.registerObserver(this); } @Override public void update(Subject subject) { WetherData o2 = (WetherData)subject; String msg = o2.getStatus(); System.out.println("观察者2自己去拉取主题的状态：" + msg); }} <br> 测试：
public class Main { public static void main(String[] args) { WetherData wd = new WetherData(); Observer o1 = new Observer_01(wd); Observer o2 = new Observer_02(wd); wd.changeSataus("hello"); }} <br> 结果：
观察者1自己去拉取主题的状态：hello观察者2自己去拉取主题的状态：hello
<br> ### 两种模型的比较
推模型是不管观察者是否需要主题变化的数据，都会把数据传递给观察者
拉模型是由观察者自动到主题中按需获取。
推模型可能会使得观察者对象难以复用，因为观察者的update()方法是按需要定义的参数，可能无法兼顾没有考虑到的使用情况。这就意味着出现新情况的时候，就可能提供新的update()方法，或者是干脆重新实现观察者；
而拉模型就不会造成这样的情况，因为拉模型下，update()方法的参数是主题对象本身，这基本上是主题对象能传递的最大数据集合了，基本上可以适应各种情况的需要。
<br>
###java 对观察者模式的支持 在java.util中，提供了一个**Observable类以及一个Observer**接口，构成JAVA语言对观察者模式的支持。