从一个小故事讲解观察者模式~

定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。

什么是观察者模式？

观察者模式在我们的日常生活中极其常见。

先来看看观察者模式的定义：

观察者模式定义了对象之间一对多的依赖，当这样一来，当一个对象状态改变时，它的所有依赖者都会收到通知并自动更新。

这个模式在我们日常生活中可以说是太常见了！

比如手机上的天气预报，一旦气象局的信息进行了更新，手机上的天气信息就会相应的变化；

比如10086群发的消息，其实也是一个观察者模式的例子，每当10086发送一条消息时，所有的移动手机都会收到这个消息。而且一般消息中都会附带一个提醒“退订请回复T”，一旦回复了T，以后就不会接收到显10086对应的短信了。

比如麦当劳吃炸鸡时，当一份食物准备好，就会通知“3045、3045、3045”请取餐，大家都能听到，但是可能只有一个人会去取餐，因为订阅者可以自行决定接收到消息之后动不动，或者说做什么；又比如…

观察者模式描述的就是订阅者和发布者之间的联系。其UML类图如下：

在这个下面给出订阅者和发布者的一个例子。

应用实例

借鉴《大话设计模式》的看门放哨的例子，我们来设计这样一个场景：

“一堂自习课时，小红、小蓝、小绿三人无心学习，各玩各的。坐在门口小黄在门口放哨，一旦看到班主任的身影，就敲一下桌子，其他三人应声而动，赶忙拿出书进行学习。当班主任走远了，小黄敲两下桌子，大家又开始愉快的玩耍…”

主体接口

主体接口，又称为被观察者，采用接口的方式可以给具体的主体类实现自己的逻辑，如采用链表、数组、或者Map等结构存储观察者。

public interface Subject {// 增加观察者public void attach(Observer observer);// 删除观察者public void detach(Observer observer);// 通知所有观察者public void notifyObservers();// 主体(被观察者)状态public void setAction(String action);public String getAction();
}

通知者接口

通知者接口主要是定义了一个接口，不同的通知者实现自己的消息逻辑：

public abstract class Observer {protected String name;protected Subject subject;public Observer(String name, Subject subject) {this.name = name;this.subject = subject;}public abstract void update();
}

实际观察者（小红、小蓝、小绿）

分别实现三个同学：

public class Xiaohong extends Observer {public Xiaohong(String name, Subject subject) {super(name, subject);}@Overridepublic void update() {System.out.println(subject.getAction() + "\n" + name + "把小说藏起来！继续学习！");}
}

public class Xiaolan extends Observer {public Xiaolan(String name, Subject subject) {super(name, subject);}@Overridepublic void update() {System.out.println(subject.getAction() + "\n" + name + "把手机收起来！继续学习！");}
}

public class Xiaolv extends Observer {public Xiaolv(String name, Subject subject) {super(name, subject);}@Overridepublic void update() {System.out.println(subject.getAction() + "\n" + name + "把游戏机收起来！继续学习！");}
}

实际发布者（小黄）

小黄观察老师的到来，通知大家：

public class Xiaohuang implements Subject {// 需要通知的同学列表private final List<Observer> observers = new LinkedList<>();private String action;// 添加通知同学@Overridepublic void attach(Observer observer) {observers.add(observer);}// 删除通知同学@Overridepublic void detach(Observer observer) {observers.remove(observer);}// 通知所有同学@Overridepublic void notifyObservers() {for (Observer observer : observers) {observer.update();}}// 获取通知状态@Overridepublic String getAction() {return action;}// 设置通知状态@Overridepublic void setAction(String action) {this.action = action;}
}

运行客户端

public class App {public static void main(String[] args) {// 前台为通知者Xiaohuang xiaohuang = new Xiaohuang();Xiaohong observer1 = new Xiaohong("小红", xiaohuang);Xiaolv observer2 = new Xiaolv("小绿", xiaohuang);Xiaolan observer3 = new Xiaolan("小蓝", xiaohuang);// 需要通知三个xiaohuang.attach(observer1);xiaohuang.attach(observer2);xiaohuang.attach(observer3);// 设置通知状态xiaohuang.setAction("小心！Boss回来了！");// 发送通知xiaohuang.notifyObservers();}
}

结果如下：