观察者模式是一种行为设计模式， 允许你定义一种订阅机制， 可在对象事件发生时通知多个 “观察” 该对象的其他对象，定义对象间一种一对多的依赖关系，使得每当一个对象改变状态，则所有依赖于它的对象都会得到通知并自动更新，也叫做发布订阅模式Publish/Subscribe。

应用刨析

假如你有两种类型的对象：顾客和 商店 。 顾客对某个特定品牌的产品非常感兴趣（例如最新型号的 iPhone 手机），而该产品很快将会在商店里出售。顾客可以每天来商店看看产品是否到货。 但如果商品尚未到货时， 绝大多数来到商店的顾客都会空手而归。

另一方面， 每次新产品到货时， 商店可以向所有顾客发送邮件（可能会被视为垃圾邮件）。这样， 部分顾客就无需反复前往商店了，但也可能会惹恼对新产品没有兴趣的其他顾客。我们似乎遇到了一个矛盾： 要么让顾客浪费时间检查产品是否到货， 要么让商店浪费资源去通知没有需求的顾客。

应用场景

• 消息通知里面：邮件通知、广播通知、微信朋友圈、微博私信等，就是监听观察事件

• 当一个对象的改变需要同时改变其它对象，且它不知道具体有多少对象有待改变的时候，考虑使用观察者模式

角色

• Subject主题：持有多个观察者对象的引用，抽象主题提供了一个接口可以增加和删除观察者对象；有一个观察者数组，并实现增、删及通知操作

• Observer抽象观察者：为具体观察者定义一个接口，在得到主题的通知时更新自己

• ConcreteSubject具体主题：将有关状态存入具体观察者对象，在具体主题内部状态改变时，给所有登记过的观察者发出通知

• ConcreteObserver具体观察者：实现抽象观察者角色所要求的更新接口，以便使本身的状态与主题的状态保持一致

业务需求

雷军技术比较厉害，因此上班不想那么辛苦，领导又在周围，所以选了个好位置，方便监听老板的到来，当领导即将出现时雷军可以立马观察到，赶紧工作。用观察者模式帮助雷军实现这个需求

编码实现

创建一个观察者抽象接口

public interface Observer {

    /**
     * 观察到消息进行的操作
     */
    void update();
}

消息发送者

public class Subject {

    private List<Observer> observerList = new ArrayList<>();

    // 新增观察者
    public void addObserver(Observer observer) {
        this.observerList.add(observer);
    }

    // 删除观察者
    public void deleteObserver(Observer observer) {
        this.observerList.remove(observer);
    }

    public void notifyAllObserver(){
        observerList.forEach(Observer::update);
    }
}

创建老板类，老板负责做事情

public class BossConcreteSubject extends Subject {

    public void doSomething() {
        System.out.println("老板完成任务");
        System.out.println("老板视察公司情况");
        // 通知所有观察者
        super.notifyAllObserver();
    }
}

创建观察者

public class LJConcreteObserver implements Observer {
    @Override
    public void update() {
        System.out.println("雷军发现领导，开始工作");
    }
}

public class XAConcreteObserver implements Observer {
    @Override
    public void update() {
        System.out.println("小爱同学发现领导，开始工作");
    }
}

使用：

public static void main(String[] args) {
    // 创建一个主题，老板
    BossConcreteSubject subject = new BossConcreteSubject();

    // 创建观察者，就是摸鱼的同事
    Observer LJObserver = new LJConcreteObserver();
    Observer XAObserver = new XAConcreteObserver();

    // 建立关系，老板这个主题，被同事观察
    subject.addObserver(LJObserver);
    subject.addObserver(XAObserver);

    // 老板活动，相当于发布消息
    subject.doSomething();
}

控制台

老板完成任务
老板视察公司情况
雷军发现领导，开始工作
小爱同学发现领导，开始工作

优缺点

优点：降低了目标与观察者之间的耦合关系，目标与观察者之间建立了一套触发机制，观察者和被观察者是抽象耦合的

缺点：观察者和观察目标之间有循环依赖的话，会触发它们之间进行循环调用，可能导致系统崩溃；一个被观察者对象有很多的直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间