在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[i]).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:收到通知,完成更新。
Android同学可参考Rxjava相结合的观察者模式:RxJava 2.x知识笔记