Java观察者模式案例简析

在java内部已有内置的观察者模式，如类 java.util.Observable和类java.util.Observer，即是被观察者和观察者。
在 java.util.Observable 中，存储观察者对象的容器是Vector，此容器支持动态扩展和同步性，用法与ArrayList类似。
Observable内部方法如下所示：





观察者模式的内在原理：观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

即：通过将一组对象实例存储在一个数组容器中，在某一时刻遍历数组并调用数组内的对象方法完成更新。

被观察者Observable内部的核心方法：


public void notifyObservers(Object arg) {        /*         * a temporary array buffer, used as a snapshot of the state of         * current Observers.         */        Object[] arrLocal;        synchronized (this) {            if (!changed)                return;            arrLocal = obs.toArray();            clearChanged();        }        for (int i = arrLocal.length-1; i>=0; i--)            ((Observer)arrLocal).update(this, arg); }

加同步锁synchronized可避免线程并发问题，设置changed状态可监听更新。for循环遍历执行观察者Observer内部的方法update()。
被观察者继承Observable类，动态发布消息通知观察者更新。如：

/**
* 被观察者类 * * @author jinzifu * @create 2018/2/22 15:36 */public class ObservableClass extends Observable {    private String message;    public String getMessage() {        return message;    }    public void setMessage(String message) {        this.message = message;        //被观察者数据发生变化时，通过以下两行代码通知所有的观察者        this.setChanged();        this.notifyObservers(message);    }}
观察者实现了Observer接口，支持扩展。如：

/**
* 观察者类 * * @author jinzifu * @create 2018/2/22 15:14 */public class ObserverClass implements Observer {    private String name;    public ObserverClass(String name) {        this.name = name;    }    @Override    public void update(Observable o, Object arg) {        System.out.println(name + ":" + arg);    }}

外部测试如下：
/**
* @author jinzifu */public class Main {    public static void main(String[] args) {        ObservableClass observableClass = new ObservableClass();        ObserverClass observerClass1 = new ObserverClass("observerClass1");        ObserverClass observerClass2 = new ObserverClass("observerClass2");        ObserverClass observerClass3 = new ObserverClass("observerClass3");        ObserverClass observerClass4 = new ObserverClass("observerClass4");        observableClass.addObserver(observerClass1);        observableClass.addObserver(observerClass2);        observableClass.addObserver(observerClass3);        observableClass.addObserver(observerClass4);        observableClass.setMessage("收到通知，完成更新。");    }}
打印如下：
observerClass4:收到通知，完成更新。
observerClass3:收到通知，完成更新。observerClass2:收到通知，完成更新。observerClass1:收到通知，完成更新。