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
