为什么要掌握观察者模式

首先我们需要明白，设计模式是什么。设计模式（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的实现是进行了数据是否改变的判断的。