观察者模式

1.定义
定义对象间的一种一对多的依赖关系，当一个对象改变状态，所有依赖于它的对象都会得到通知并被自动更新。
2.观察者模式的四个重要角色
抽象主题：即 抽象被观察者，将所有观察者对象的引用保存在一个集合里，每个主题都可以拥有任意数量的观察者，抽象主题提供一个接口可以增加和删除观察者对象。
具体主题：当具体主题内部发生变化时，给所有注册过的观察者发出通知。
抽象观察者：定义一个更新接机，当收到主题更改通知时调用此接口。
具体观察者：实现抽象观察者，当主题状态发生变化时，调用更新接口。

观察者模式的具体实现：
定义抽象被观察者

/**
 * 被观察者接口
 */
interface Observable {

    /**
     * 注册观察者
     * @param observe
     */
    void register(Observe observe);

    /**
     * 收到消息 通知 观察者
     */
    void notifyObserve();
}

定义抽象观察者

/**
 * 抽象的观察者 当有消息发送的时候 观察者的updata方法会被回调
 */
interface Observe {
    void updata(String message);
}

实现具体被观察者

class RealObservable implements Observable {

    private List<Observe> observes;

     RealObservable() {
        observes = new ArrayList<Observe>();
    }

    @Override
    public void register(Observe observe) {
        this.observes.add(observe);
    }

    @Override
    public void notifyObserve() {
        for (int i = 0; i < observes.size(); i++) {
            observes.get(i).updata("向观察者推送消息");
        }
    }
}

实现具体观察者

class RealObserve implements Observe {

    private String name;

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

    @Override
    public void updata(String message) {
        System.out.println(name+"--"+"收到被观察者推送的消息——> "+message);
    }
}

使用：

 private static void initObserve(){
        RealObservable realObservable = new RealObservable();
        RealObserve realObserve = new RealObserve("观察者1");
        RealObserve realObserve1 = new RealObserve("观察者2");
        realObservable.register(realObserve);
        realObservable.register(realObserve1);
        realObservable.notifyObserve();
    }

结果：

观察者1--收到被观察者推送的消息——> 向观察者推送消息
观察者2--收到被观察者推送的消息——> 向观察者推送消息

实现要点：被观察者通过注册拿到观察者对象，使观察者和被观察者建立关联，当被观察者发生变化时，通过被观察者中拿到的观察者对象将消息传递给观察者。