观察者模式

观察者模式又叫做发布-订阅(Publish/Subscribe)模式。观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

观察者模式的结构图

观察者模式中的角色：

• Subject：抽象主题(抽象被观察者)。抽象主题角色把所有观察者对象保存在一个集合里，每个主题都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察者对象。
• ConcreteSubject：具体主题(具体被观察者)。该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。
• Observe：抽象观察者，是观察者的观察类。它定义了一个更新接口，使得在得到主题更改通知时更新自己。
• ConcreteObserver：具体观察者，实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态。

观察者模式的简单实现

（1）抽象观察者

public interface Observer {
    public void update(String message);
}

（2）具体观察者

public class ConcreteObserver implements Observer {

    private String name;

    public ConcreteObserver(String name) {
        this.name = name;
    }

    @Override
    public void update(String message) {
        System.out.println(name + "新消息：" + message);
    }
}

（3）抽象被观察者

public interface Subject {

    public void attach(Observer observer);

    public void detach(Observer observer);

    public void notify(String message);
}

（4）具体被观察者

public class ConcreteSubject implements Subject {

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

    @Override
    public void attach(Observer observer) {
        observerList.add(observer);
    }

    @Override
    public void detach(Observer observer) {
        observerList.remove(observer);
    }

    @Override
    public void notify(String message) {
        for (Observer observer : observerList) {
            observer.update(message);
        }
    }
}

（5）客户端调用

public class Client {

    public static void main(String[] args) {
        ConcreteSubject concreteSubject = new ConcreteSubject();

        ConcreteObserver concreteObserver = new ConcreteObserver("yuzhiyi");
        ConcreteObserver concreteObserver1 = new ConcreteObserver("AAAA");
        ConcreteObserver concreteObserver2 = new ConcreteObserver("BBBB");

        concreteSubject.attach(concreteObserver);
        concreteSubject.attach(concreteObserver1);
        concreteSubject.attach(concreteObserver2);

        concreteSubject.notify("测试");
    }
}

（6）输出

yuzhiyi新消息：测试
AAAA新消息：测试
BBBB新消息：测试

观察者模式的使用场景

使用场景：
关联行为场景。关联行为是可拆分的，而不是组合关系。
事件多级出发场景。
跨系统的消息交换场景，如消息队列、事件总线的处理规则。

观察者模式的优缺点

优点：
观察者和被观察者之间是抽象耦合，容易扩展。
方便建立一套触发机制。

缺点：
在应用观察者模式时需要考虑以下开发效率和运行效率的问题。程序中包括一个被观察者、多个观察者，开发、调试等内容会比较复杂，而且在 Java 中消息的通知一般是顺序执行的，那么一个观察者卡顿，会影响整体的执行效率，在这个情况下，一般会采用异步方式。