Rxjava2的学习和理解

Rxjava系列其实就是对于响应式编程的一种实现。
在安卓层面，如何更好的使用Rxjava2呢？
这里写的内容，权是对自己技术路线学习的一个记录，不对外部产生建议。

如何集成Rxjava2呢？
在app的mudule的build.gradle中添加引用依赖：

    implementation 'io.reactivex.rxjava2:rxjava:2.1.9'
    implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'

学习Rxjava2 ,还是有必要了解Rxjava1的，我在写学习Rxjava系列的文档记录，也就是为了让自己能够较为清晰的看到Rxjava在技术演进的时候，有哪些技术点在各个版本中被沿用，有哪些技术点被废弃掉了。

对于Rxjava2 ，很明显，依赖的包名是有变化的，这是为了区分Rxjava1和Rxjava2的。在升级Rxjava2的时候，肯定有同学遇到除了自己的SDK可能还是依赖了Rxjava1的，其他三方的SDK也有依赖 Rxjava1的，这个怎么办？其实这个就是代码工程中依赖三方SDK常遇到的，剔除外部SDK依赖的其他版本。
那么怎么查看三方SDK依赖了哪些SDK版本呢？这个其实在android Studio中就有脚本可以查看。
具体就是在右边 gradle/app/help/dependcies

image.png

双击这个命令，就能看到输出的SDK的依赖关系。可以很清楚的查看到外部SDK到底依赖了哪些SDK的哪些版本。
能查看到外部SDK使用的Rxjava1的版本了，那么怎么剔除呢？

    implementation('com.alibaba.android:virtualview:1.4.6@aar') {
        exclude group: 'com.alibaba', module: 'fastjson'
    }

OK，对于剔除三方SDK的某个外部SDK版本的依赖，就是这样了。
再回到Rxjava2当中来。
当然，被观察者和观察者，以及绑定关系还是跟Rxjava1 类似，不过还是存在差别的。

        Observable.create(new ObservableOnSubscribe<Integer>() {
                    @Override
                    public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                        emitter.onNext(100);
                        emitter.onComplete();
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                //可以直接写一个观察者，这个观察者定义了几个方法，比单个写listener要丰富些
                .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() {

                    }
                });

创建的方式跟Rxjava1 类似，不过有变化的是某些类的包名有变化。
Rxjava1中的包名是在：

image.png

而Rxjava2的包名是在这里：

image.png

Rxjava2除了包名不一样之外，还有新推出了可以支持指定策略的被观察者。
也就是Flowable
在创建这个Flowable的方式，跟Observable的方式一样，但是有所差别的是需要指定被压策略，什么是被压。
简单来讲就是被观察者发送的速率远大于观察者所能处理的速率，从而需要对产生事件做的一种舍弃方案，就叫做背压策略。
背压策略在Rxjava2.x有如下几种：

image.png

在Flowable中使用方式：

        Flowable.create(new FlowableOnSubscribe<Integer>() {
                    @Override
                    public void subscribe(FlowableEmitter<Integer> emitter) throws Exception {

                    }
                }, BackpressureStrategy.ERROR)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new FlowableSubscriber<Integer>() {
                    @Override
                    public void onSubscribe(Subscription s) {
                        s.request(129);
                    }

                    @Override
                    public void onNext(Integer integer) {

                    }

                    @Override
                    public void onError(Throwable t) {

                    }

                    @Override
                    public void onComplete() {

                    }
                });

可以看到，跟Observable类似。
有区别的是需要指定背压的策略。

Rxjava2是针对Rxjava1的技术思想的延续。
对于开发者来讲，知道一门技术，除了使用之外，还需要了解这门技术具体是以解决什么样的问题而诞生的。对于rxjava，我认为了简化业务流程的开发，方便线程切换的调度而产生的。
这就是对于Rxjava2

Rxjava2的学习和理解

推荐阅读更多精彩内容