观察者模式与它在源码中的运用

观察者模式定义对象间的一种一对多的依赖关系，当被观察的对象发生变化时，所有的观察者都将得到通知进行相应的操作

过马路的时候我们都会看红绿灯，此时我们就是观察者，红绿灯由红变成绿的时候，行人和车辆观察到这个变化，开始穿越马路，这里的红绿灯变化就是可观察的对象

访问流程如下

Subject这里就是被观察的对象，Observer就是观察者

红绿灯Observer的可运行源码可以戳这里

RxJava中对观察者模式的运用

RxJava学习路径戳这里

Disposable disposable = Observable.just(1).subscribe(new Consumer<Integer>() {
            @Override
            public void accept(Integer integer) throws Exception {
                LOG.info("accept:{}", integer);
            }
        });

完整可以运行的源码可以戳这里,查看 justVerify

• Disposable 提供 dispose()方法，可以解除订阅关系 (类比detach)
• Observable 从名字上可以看出来，它是一个可被观察的对象(类比 Subject)
• subscribe 实现订阅的操作 (类比 attach)
• Consumer 中的accept 即对观察到的对象实行的操作(类比 logicHandle)
• Observer 代码中没有出现，但是rxjava自己在内部会通过在调用subscribe的时候，创建 Observer，然后同样在内部实现调用 onNext (类比Observer与notify)

详细的源码追踪请戳这里。另值得注意的是 RxJava 是在订阅的时候就发送了数据

通常可以用观察者模式的情况

一个对象的改变需要需要周知到其它对象，做出相应的行为。但是却不知道具体有多少对象有待改变或根本不知道具体的对象是谁