Android技能树 - Rxjava源码(1) 之 初步结构

前言

之前写相关的RxJava的文章比较少，也就下面二篇：

目需求讨论 — 手把手带你写RxPermission

RxJava小考题 -- Rxjava源码分析(一)

用了这么久的RxJava，因此想要作个总结，因此打算也写一个RxJava源码分析 的系列（因此不是简单的说明如何使用RxJava步骤，看以前也最好会使用RxJava）：

Android技能树 - Rxjava源码系列(1) 之 初步结构

Android技能树 - Rxjava源码系列(2) 之 Observable和Observer(待写)

Android技能树 - Rxjava源码系列(3) 之 线程切换(待写)

Android技能树 - Rxjava源码系列(4) 之 经常使用操做符(待写)

正文

咱们仍是经过基础的例子来进行讲解，好比你有个快递，你很想知道快递是否已经到小区，你可能想要在快递刚到你的小区的时候就立刻知道，而后立刻就能享受拆快递所带来的乐趣，毕竟等待快递的时候实在太煎熬了。

那咱们有什么方式来肯定快递是否到了小区呢？

1. 轮询 和 更新发送

1.1 轮询

咱们能够每隔1分钟，就打个电话给快递小哥，问他个人快递是否是已经送到了，这样当快递小哥刚送货到你的小区的时候，你都最多能在不超过一分钟内知道快递已经到小区了。(缺点也很明显，电话费很贵，同时你不怕小哥打死你的话，你也能够用这种方式)

1.2 更新发送

当快递小哥把快递送到你的小区的时候，通常都是二种方式：1. 他可能直接打你的电话通知你下来拿快递；2. 统一放在快递货柜中，而后你会收到货柜的短信通知，根据开柜号码去拿快递。

明显这种数据更新后主动通知的方式，咱们更容易接受，你们都开心，小哥也不会打死你。可是上面咱们也说了快递小哥通知你的方式有二种：直接通知你/货柜接收快递，货柜再通知你

快递员到了小区后，通知你的二种方式又分别对应了什么模式？

2.观察者模式和发布订阅模式

咱们上面已经提到了快递小哥到了你小区，有二种方式通知你，其实这里对应了 观察者模式和发布订阅模式这二种模式。其实我之前也老是把这二个模式弄混，感受都差很少，因此在和别人讨论的时候都是混着说着这个名词，后来看了网上相关的文章，发现这两者仍是有点不一样的，正对应了上面你收到快递的信息同样的区别。

2.1 观察者模式

对应的就是咱们的快递员把快递送到了小区后，直接打电话给你，说你快下来拿下快递；这时候快递员是直接跟你本人直接沟通的

2.2 发布订阅模式

对应的就是咱们的快递员把快递送到小区后，把快递放在快递柜中，而后快递员只要把你的手机号码输入到快递柜，而后把快递放入到具体的某个快递柜的格子中，就能够直接走人了，等会会由快递柜这边通知你快递到了，而后过来取快递。

两者最大的区别是什么？

我直接引用网上的其余文章的内容：两种模式都存在订阅者和发布者（具体观察者可认为是订阅者、具体目标可认为是发布者），可是观察者模式是由具体目标调度的，而发布/订阅模式是统一由调度中心调的，因此观察者模式的订阅者与发布者之间是存在依赖的，而发布/订阅模式则不会。

那RxJava是属于上面的二种的哪种呢？

咱们直接看GitHub上的RxJava介绍：

看不懂的咱们直接谷歌翻译走起：

咱们能够看到介绍，说是扩展了观察者模式，因此说明咱们的Rxjava是直接把观察者注册到了发布者。而没有中间的调度中心。因此也就是咱们上面的快递员直接打电话通知你下来拿快递的方式。

3.Rxjava的具体分析

咱们使用RxJava最基础的方式是什么?

咱们刚开始学如何使用的时候，估计百分之99的都是先学会使用create操做符：

Observable.create(new ObservableOnSubscribe<Object>() {
        @Override
        public void subscribe(ObservableEmitter<Object> emitter) throws Exception {

        }
    }).subscribe(new Observer<Object>() {
        @Override
        public void onSubscribe(Disposable d) {
            
        }

        @Override
        public void onNext(Object o) {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    });
复制代码

其实这个最基础的了解了后，看其余的什么just,fromArray等就都理解了；固然咱们既然是RxJava系列的第一篇初步结构，因此我也不会立刻就讲解各类源码，咱们能够先模仿一个简单的，好比：

Observable.just(1)
    .subscribe(new Observer<Integer>() {
        @Override
        public void onSubscribe(Disposable d) {
            
        }

        @Override
        public void onNext(Integer integer) {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    });
复制代码

咱们能够这样先模仿这个简单的，写个效果同样的伪代码，了解一下基本的东西便可。

因此若是咱们写了一个简单的版本的RxJava应该是这样的：

Observer.java:

public class Observer<T> {

    @Override
    public void onSubscribe(Disposable d) {
    }

    public void onNext(T obj) {
    }

    public void onError(Throwable e) {
    }

    public void onComplete() {
    }
}

复制代码

Observable.java:

public class Observable<T> {

    T value;
    Observer<? super T> observer;
    
    //just传进来的数值，等会要发送给Observer
    public void just(T value) {
        this.value = value;
    }

    public final void subscribe(Observer<? super T> observer) {
        //把Observer注册到Observable中，其实就等于Observable拿了Observer的对象，等会好调用它相应的方法
        this.observer = observer;
        
        //生成Disposable对象，调用observer的onSubscribe方法
        Disposable a = xxxxxxx;
        observer.onSubscribe(a);
        
        //咱们已经拿到了Observer对象，能够作相关逻辑了
        start();
    }

    private void start() {
        try {
            //咱们把just传进的数值，经过已经拿到的Observer对象，调用onNext把数值给它
            observer.onNext(value);
            //发送完了以后执行onComplete()方法说明结束了。
            observer.onComplete();
        } catch (Exception e) {
            //若是中间出现异常，就调用Observer的onError方法
            observer.onError(e);
        }
    }
}
复制代码

是否是感受，卧槽，原来这么简单吗？没错，这样看来咱们也的确是Observable直接持有了Observer的对象，也的确符合上面咱们说的Rxjava使用的是观察者模式，而不是发布订阅模式。

因此如今初步来看RxJava目前来看三步走：

结语

由于只是第一篇初步结构，因此内容也十分简单，后续会具体分析相关的源码内容。