Android 响应式编程 RxJava2 完全解析

　　使用了 RxJava2 有一段时间了，深深感受到了其“牛逼”之处。下面，就从 RxJava2 的基础开始，一步步与大家分享一下这个强大的异步库的用法！RxJava 是 一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库，也就是用于实现异步操作的库。

　　RxJava可以浓缩为异步两个字，其核心的东西不外乎两个， Observables（被观察者） 和 Observable（观察者）。Observables可以发出一系列的 事件（例如网络请求、复杂计算、数据库操作、文件读取等），事件执行结束后交给Observable 的回调处理。

　　什么是观察者模式？举个栗子，Android中View的点击的实现，View是被观察者，OnClickListener对象是观察者，Activity要如何知道View被点击了？那就是派一个OnClickListener对象，入驻View，与View达成一个订阅关系，一旦View被点击了，就通过OnClickListener对象的OnClick方法传达给Activity。采用观察者模式可以避免去轮询检查，节约有限的cpu资源。

　　如图所示，RxJava 的基本概念分别为：Observable(被观察者，事件源)，Observer(观察者，订阅者)，subscribe (订阅)、事件；不同的是，RxJava 把多个事件看做一个队列，并对每个事件单独处理。在一个队列中 onCompleted() 和 ()，只有一个会被调用。如果调用了 onCompleted() 就说明队列执行完毕，没有出现异常，否则调用 () 方法并终止队列。

　　什么是响应式编程？举个栗子，a = b + c; 这句代码将b+c的值赋给a，而之后如果b和c的值改变了不会影响到a，然而，对于响应式编程，之后b和c的值的改变也动态影响着a，意味着a会随着b和c的变化而变化。

　　Subscriber通常在主线程执行，所以原则上不要去处理太多的事务，而这些复杂的处理则交给Operator；

　　若喜欢简洁、定务，那么可以实现的方法跟的实现方法是对应起来的，大家看参数就知道哪个对应哪个了，你可以通过new Consumer（不需要实现的方法你可以不写，看上去更简洁），Consumer就是消费者的意思，可以理解为消费了 onNext 等事件：

　　RxJava中提供了大量不同种类，不同场景的Operators(操作符)，RxJava的强大性就来自于它所定义的操作符。主要分类：

　　调度器 Scheduler 用于控制操作符和被观察者事件所执行的线程，不同的调度器对应不同的线程。RxJava提供了5种调度器：

　　// 参数二表示转换的数据，那么就是通过发送网络参数，转换成网络返回的数据，调用Retrofit

　　这个案例其实就是用户添加购物车的时候，首先会在本地存储一份，然后发现如果没有网络，那么没办法提交到服务器上，只能等下一次有网络的时候采用本地数据库和服务器数据的合并来实现上传到服务器。

　　// 参数二表示转换的数据，那么就是通过发送网络参数，转换成网络返回的数据，调用Retrofit

　　// 数据转换 flatMap: 当同时多个数据请求访问的时候，前面的网络数据会覆盖后面的网络数据

　　// 数据转换 switchMap: 当同时多个网络请求访问的时候，会以最后一个发送请求为准，前面网络数据会被最后一个覆盖

　　当用户一直点击一个按钮的时候，我们不应该一直调用访问网络请求，而是 1秒内，只执行一次网络请求。

　　举个例子，对于前面常用操作符 interval 做周期性操作的例子，并没有使之停下来的，没有去控制订阅的生命周期，这样，就有可能引发内存泄漏。所以，在 Activity 的 onDestroy() 方法执行的时候或者不需要继续执行的时候应该解除订阅。