为什么要掌握观察者模式
首先我们需要明白，设计模式是什么。设计模式（Design pattern）是一套被反复使用、多数人知晓的、经过分类编目的、代码设计经验的总结。使用设计模式是为了可重用代码、让代码更容易被他人理解、保证代码可靠性。 毫无疑问，设计模式于己于他人于系统都是多赢的；设计模式使代码编制真正工程化；设计模式是软件工程的基石脉络，如同大厦的结构一样。
而其中的观察者模式，通常被用来实现事件处理系统，完美的将观察者和被观察的对象分离开。
RxJava 的异步实现，是通过一种扩展的观察者模式来实现的。
了解观察者模式
观察者模式面向的需求是：A 对象（观察者）对 B 对象（被观察者）的某种变化高度敏感，需要在 B 变化的一瞬间做出反应。举个例子，新闻里喜闻乐见的警察抓小偷，警察需要在小偷伸手作案的时候实施抓捕。在这个例子里，警察是观察者，小偷是被观察者，警察需要时刻盯着小偷的一举一动，才能保证不会漏过任何瞬间。
程序的观察者模式和这种真正的『观察』略有不同，观察者不需要时刻盯着被观察者（例如 A 不需要每过 2ms 就检查一次 B 的状态），而是采用注册(Register)或者称为订阅(Subscribe)的方式，告诉被观察者：我需要你的某某状态，你要在它变化的时候通知我。在刚才的那个例子中，就应该是警察对小偷进行一下注册或者订阅，然后就不用一直盯着小偷了，当小偷有了什么举动的时候，小偷自然就会通知警察了。不过这个例子感觉好蠢ヾ(。￣□￣)ﾂ゜゜゜
实现观察者模式
对观察者模式有了了解之后，我们就可以自己实现了。首先我们需要写出观察者，和被观察者。对比着刚才的案例:
被观察者需要有注册/订阅事件的方法，相应的也就应该有移除注册/订阅事件的方法，当然还有通知事件的方法
// 被观察者的模型
public interface Watched {
// 注册观察者
public void addWatcher(Watcher watcher);
// 移除观察者
public void removeWatcher(Watcher watcher);
// 通知观察者
public void notifyWatchers(String str);
}
// 被观察者的具体实现
public class SimpleWatched implements Watched {
private List<Watcher> list = new ArrayList<>();
@Override
public void addWatcher(Watcher watcher) {
list.add(watcher);
}
@Override
public void removeWatcher(Watcher watcher) {
list.remove(watcher);
}
@Override
public void notifyWatchers(String str) {
for (Watcher watcher : list) {
watcher.update(str);
}
}
}
观察者应该有接收通知的方法
// 观察者的模型
public interface Watcher {
// 接收到通知
public void update(String str);
}
// 观察者的具体实现
public class SimpleWatcher implements Watcher {
@Override
public void update(String str) {
System.out.println(str);
}
}
public class Test {
public static void main(String[] args) throws Exception{
Watched xiaoming = new SimpleWatched();
Watcher watcher1 = new SimpleWatcher ();
Watcher watcher2 = new SimpleWatcher ();
Watcher watcher3 = new SimpleWatcher ();
xiaoming.addWatcher(watcher1);
xiaoming.addWatcher(watcher2);
xiaoming.addWatcher(watcher3);
xiaoming.notifyWatchers("我要偷东西了");
}
}
当程序运行的时候，就会在控制台输出三次“我要偷东西了”，因为有三个观察者进行了注册
利用Java自带的观察者接口
public class SimpleObservable extends Observable {
private int data = 0;
public int getData(){
return data;
}
public void setData(int i){
if (this.data!=i){
this.data = i;
setChanged();//发生改变
notifyObservers();//通知观察者，表示状态发生改变
}
}
}
public class SimpleObserver implements Observer {
public SimpleObserver(SimpleObservable observable) {
observable.addObserver(this);
}
@Override
public void update(Observable observable, Object arg) {
System.out.println("data is changed:" + ((SimpleObservable) observable).getData());
}
}
public class MyTest {
public static void main(String[] args) throws Exception {
SimpleObservable simple = new SimpleObservable();
SimpleObserver observer = new SimpleObserver(simple);
simple.setData(1);
simple.setData(2);
simple.setData(2);
simple.setData(3);
}
}
最后在控制台打印出来的结果是
data is changed:1
data is changed:2
data is changed:3
有人可能会问，不是有两句 simple.setData(2);吗？ 不过仔细看的话，我们在SimpleObservable 中对于setData的实现是进行了数据是否改变的判断的。
