Android帝国—四大天王（RxAndroid） 2

写文章是一件比较麻烦的事。好处就是让你不仅巩固所学。还能够更深刻地了解所学的，假如了解不好，在写的过程中就暴露出来了。这和代码差不多。

????线程了解起来（在这里，其实很难的）也不是那么难，这里我们完全可以将线程想象交通道路。每逢周末下班，或者小长假时，回家路或者高速上肯定会堵车，想早点回家的心情都是可以了解，程序也是跑在线程上的车，假如所有的操作都跑在一个线程会是什么样，尤其在这个缺乏耐心的年头。(图)这个能否为了缓解交通拥堵，我们需要采取少量措施。我们需要通过调配方式或者者。

因为 Android 对主线程看的很紧，小窄路，稍不留神，就ANR了。我们应用需要频繁访问访问获取数据，也可以进行操作 IO，而后将数据呈现到界面上。

RxAndroid 确实有些难于了解概念，他并不是简单异步回调，假如用好了他确实是得心应手的利器

很常见就是我们在一个线程解决网络请求和 IO 操作。而后返回到主线程绘制视图。有点像并道吧。并道比较麻烦得左右前后注意。这样复杂的事rxandroid帮我们做了，有了他我们可以利用他提供的选择在线程间任意穿梭。有了交警害怕堵车

背压问题，通过一个实例给大家解释一下。什么是背压。我们在屏幕上移动手指。那么就会产生连续的触摸事件。我们获取事件的坐标信息，来进行绘制一个点。好。问题来了，还没有绘制完当前的点，下一个事件就来了。我们怎样办。这个火爆的自助餐门前一样。这就是背压。我们无法及时消费掉这些事件。那么是等待还是离开就是我们对应的策略。在 rxandroid 1 的时代我们observable 在后期小版本提供对应解决。但是有些不需要解决背压。所以在 rxandroid2有了flowable 他不是什么新东西。就是将 observable 分离出一份专门对应背压的。但是 flowableprocessor 这个解决器可是一个新东西。

我们先总体，看一看大致流程吧，先发送事件（1），而后即可以订阅事件（2），可以先于发送前后进行订阅事件，取得（捕获）订阅的事件，解决事件（3），尽管不感兴趣就取消订阅事件（4），这就是整个流程了。

Observable 实现了 publiser 接口来发布事件，Observer 订阅(subscribe) Obsrvable 发布的事件。而后在 onNext 解决发送过来的事件。而后在 onSubscribe 解决能否取消订阅。这就是整个Rx的流程，

我们如何创立事件源头。 多数情况我们会用到 just 和 create 来创立事件源，使用 Observable.just 方法可以创立一个事件源，这里我们可以传入一个字符串，集合或者对象。

range 可以创立少量列的整数。

我们最常用还是 create 来创立一个事件源。Observable 表示可以观察的对象，看看语法 able（能够被）。

这里调用 create 方法发布肯定可观察到事件源，这方法接受一个 ObservableOnSubscribe 对象作为参数。在java 中通常都用匿名类来实现函数式编程。这里我们分析一下语法吧，使用英文的语法，而非 code 。在这里 subscribe 是订阅意思，大家都清楚吧，OnSubscribe 表示订阅的可观察对象。我们需要来实现他的订阅方法，方法提供以参数供我们使用，就是可以发射发射器的对象，

用于发布数据，我们具体怎样发布数据，都是在这里完成的。

多数情况我们会结合着解决网络请求。和解决 UI 例如点击，拖到等事件，包裹这些请求和事件，来优雅地实现异步编程。下面例子是包裹了 okhttp 的请求。