在java內(nèi)部已有內(nèi)置的觀察者模式，如類 java.util.Observable和類java.util.Observer，即是被觀察者和觀察者。
在 java.util.Observable 中，存儲(chǔ)觀察者對(duì)象的容器是Vector，此容器支持動(dòng)態(tài)擴(kuò)展和同步性，用法與ArrayList類似。
Observable內(nèi)部方法如下所示：
觀察者模式的內(nèi)在原理：觀察者模式定義了一種一對(duì)多的依賴關(guān)系，讓多個(gè)觀察者對(duì)象同時(shí)監(jiān)聽(tīng)某一個(gè)主題對(duì)象。這個(gè)主題對(duì)象在狀態(tài)上發(fā)生變化時(shí)，會(huì)通知所有觀察者對(duì)象，使它們能夠自動(dòng)更新自己。
即：通過(guò)將一組對(duì)象實(shí)例存儲(chǔ)在一個(gè)數(shù)組容器中，在某一時(shí)刻遍歷數(shù)組并調(diào)用數(shù)組內(nèi)的對(duì)象方法完成更新。
被觀察者Observable內(nèi)部的核心方法：
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可避免線程并發(fā)問(wèn)題，設(shè)置changed狀態(tài)可監(jiān)聽(tīng)更新。for循環(huán)遍歷執(zhí)行觀察者Observer內(nèi)部的方法update()。
被觀察者繼承Observable類，動(dòng)態(tài)發(fā)布消息通知觀察者更新。如：
/**
* 被觀察者類
*
* @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;
//被觀察者數(shù)據(jù)發(fā)生變化時(shí)，通過(guò)以下兩行代碼通知所有的觀察者
this.setChanged();
this.notifyObservers(message);
}
}
觀察者實(shí)現(xiàn)了Observer接口，支持?jǐn)U展。如：
/**
* 觀察者類
*
* @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);
}
}
外部測(cè)試如下：
/**
* @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同學(xué)可參考Rxjava相結(jié)合的觀察者模式：RxJava 2.x知識(shí)筆記
