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

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

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

访问流程以下

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 是在订阅的时候就发送了数据

一般能够用观察者模式的状况

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