前言

生活中我们经常使用手机订阅功能，用来订阅一些我们感兴趣的东西，比如体育赛况、股票行情等等。每当这些订阅的事务有重大变化发生时，我们都能收到相关通知信息，当然我们也能对失去兴趣的事情取消订阅，这样我们便不会收到相关推送了。这就是Observer观察者模式的一种典型应用场景。

Observer观察者模式

在对象之间定义了一对多的依赖，这样一来，当一个对象改变状态，依赖它的对象会收到通知并自动更新。

主题Subject是观察者模式中有一个抽象的概念，代表订阅方订阅的实体。

public interface Subject {
    void addObserver(Observer observer);

    void removeObserver(Observer observer);

    void notifyObserver();
}

以此派生出一个具体主题ConcreteSubject，

public class ConcreteSubject implements Subject{
    private List<Observer> list;

    public ConcreteSubject(){
        this.list = new ArrayList<Observer>();
    }

    public void attach(Observer observer) {
        this.list.add(observer);
    }

    public void detach(Observer observer) {
        this.list.remove(observer);
    }

    public void notifyObserver() {
        for (Observer o : this.list){
            o.update();
        }
    }
}

对于订阅方而言，也需要有个抽象的概念——订阅方Observer，当收到通知时改变自身状态，

public interface Observer {
    void update();
}

同样，以此派生出一个具的订阅方ConcreteObserver，

public class ConcreteObserver implements Observer{
    public void update() {
        System.out.println("I've been notified!");
    }
}

示例代码：

public class ObserverTest {
    public static void main(String[] args) {
        Subject sbj = new ConcreteSubject();
        Observer obs01 = new ConcreteObserver("A");
        Observer obs02 = new ConcreteObserver("B");
        Observer obs03 = new ConcreteObserver("C");

        sbj.addObserver(obs01);
        sbj.addObserver(obs02);
        sbj.addObserver(obs03);

        sbj.notifyObserver();

        System.out.println("====================");

        sbj.removeObserver(obs02);
        sbj.notifyObserver();
    }
}

运行结果：