阅读 287

RxJava源码设计思路

在探索了RxJava的源码之后,在这里做一次总结。源码大致的执行流程。

1 创建Observable,然后使用操作符转换或者处理Observable,每一个操作符,都会产生一种对应类型的Observable。我们知道Observable是链式调用的,比如:

        Flowable<String> observable = Flowable
        				// 创建FlowableJust对象
                .just("hello", "world")
                // 创建创建FlowableMap对象,并且在创建的时候将上一步创建的对象传入FlowableMap中
                .map(String::toUpperCase)
                ;
复制代码

首先我创建了A对象,在A对象的基础之上进行下一步操作产生B对象,在创建B对象的时候,可以将自己作为参数传递给B对象,那么B对象的source就是A对象。

2 创建消费者,我们写的消费者本质上是RxJava框架封装到最后非常方便使用的,就是一个单纯的Observer类。

3 调用subscribe方法,将上面的步骤进行串联起来。比如说我们创建了A,链式调用又创建了B,然后B又创建了C,这个时候C有B的引用,B有A的引用。

但是在最后真正调用subscribe方法的时候,爆出的对象是C对象,即用C去调用subscribe方法。

这时:

  • 我们写的消费者是源头Observer
  • 调用C的subscribe方法传入的是源头Observer,C创建自己的Observer,比如CObserver,参数为源头Observer,并且将其设置为downstrem。
  • C持有B对象,调用B对象的subscribe方法,传入的Observer为CObserver,然后B对象接受到CObserver创建自己的观察者,包装CObserver为自己的downstream
  • B对象持有A,做与上一步相同的操作,直到Observable对象没有持有其它的Observable(也可以说没有上有Observable)。

先整理下,这个时候分别创建了:AObserver,BObserver,CObserver,源头Observer(我们自己写的),并且

AObserver:

  • downstream: BObserver

BObserver:

  • downstream: CObserver

CObserver:

  • downstream: 源头Observer

而对于Observable来说,则与上面相反。

CObservable:

  • source: BObservable

BObservable:

  • source: AObservable

AObservable:

  • source: 自己,或者我们写的数据生产逻辑

image-20191218075825357

4 当Observer传递到AObserver,即最开始产生数据哪里时,其调用自身Observer的onSubscribe方法,因为每个自身的Observer都有downstream的Observer,再逐次调用downstream的onSubscribe方法。

在调用onSubscribe方法时,将自身传递进去,这时BObserver的upstream为AObserver。依次类推

  • 先设置自己的upstream
  • 在调用downstream的onSubscribe,并且将自身传递过去,作为downstream的upstream。
        @Override
        public void onSubscribe(Subscription s) {
            if (SubscriptionHelper.validate(this.upstream, s)) {

								this.upstream = s;
                downstream.onSubscribe(this);
                s.request(Long.MAX_VALUE);
            }
        }
复制代码

5 我们知道最终调用的是首先创建的AObserveable,AObservable的subscribeActual方法中,在调用onSubscribe之后,将生产的数据与Observer联合起来,再运行。

AObserver运行完自己的观察者逻辑后,交由自己的downstream继续进行onNext方法,直到我们自己的消费者调用onNext方法。

最后

说起来有点绕,但是大体上就是在创建观察者和消费者的时候,使用某种方式将其关联起来。

  • 被观察者,数据源不管进行多少次封装总有一个最终的source
  • 而观察者,不管upstream或者downstream多少次,都有最终的消费者
    • downstream是由于调用subscribe方法时,从最下游的数据处理网上传递,因次层层的downstream
    • 在调用onSubscribe方法时,最上游又将自己传给下发,作为upstream。
    • 最上游接着发送数据,交给观察者处理,观察者处理完之后交给downstream继续处理。
关注下面的标签,发现更多相似文章
评论