优势 - 逻辑简洁
Rx 优势可以概括为四个字，那就是 逻辑简洁。然而，逻辑简洁并不意味着代码简洁。
由于链式结构，一条龙，你可以从头到尾，从上到下，很清楚的看到这个连式结构的执行顺序。
对于开发人员来说，代码质量并不在于代码量，而在于逻辑是否清晰简洁，可维护性如何，代码是否健壮！
需要了解的概念
Observable（被观察者）
Observer/Subscriber（观察者）
</br>
Observable 发出一系列事件他是事件的产生者；
Subscriber 负责处理事件，他是事件的消费者；
Operator 是对 Observable 发出的事件进行修改和变换；
AndroidStudio中使用Rx需要的环境
在app的build.gradle加入以下引用包
/*Rx引入包*/
compile 'io.reactivex:rxandroid:1.1.0'
compile 'io.reactivex:rxjava:1.1.5'
/*漂亮Log*/
compile 'com.github.orhanobut:logger:1.12'
如果你想使用漂亮的Logger打印
在项目的build.gradle加入以下
allprojects {
repositories {
jcenter()
/*漂亮Log*/
maven { url "https://jitpack.io" }
}
}
下面的我就不上代码直接上图了，最好跟着图一起动手敲一敲，最后我会上代码地址
创建Observable（被观察者） 的两种方法
Paste_Image.png
创建Observer/Subscriber（观察者） 的方法
Paste_Image.png
最后，我们可以调用 subscribe 操作符， 进行事件订阅。
Paste_Image.png
代码是都实现了，大致的理解下他们的意思
1 Observer 是观察者 - *** Subscriber 也是观察者Subscriber 是一个实现了Observer接口的抽象类***，对 Observer 进行了部分扩展，在用上基本没有区别；Subscriber 多了发送之前调用的 onStart() 和解除订阅关系的 unsubscribe()方法。
2 并且，在 RxJava 的 subscribe 过程中，Observer 也总是会先被转换成一个 Subscriber 再使用。所以在这之后的示例代码，都使用 Subscriber 来作为观察者。
在 Subscriber 实现的三个方法中，顾名思义，对应三种不同状态：
1 onComplete() 事件全部处理完成后回调
2 onError(Throwable t)事件处理异常回调
3 onNext(T t) 每接收到一个事件，回调一次
对于事件消费与事件订阅来说，好像为了打印一个“Hello World！”要费好大的劲… 其实，RxJava 自身提供了精简回调方式，我们可以为 Subscriber 中的三种状态根据自身需要分别创建一个回调动作 Action
Paste_Image.png
那么，RxJava 的事件订阅支持以下三种不完整定义的回调。
1 observable.subscribe(onNextAction);
2 observable.subscribe(onNextAction, onErrorAction);
3 observable.subscribe(onNextAction, onErrorAction, onCompleteAction);
我们可以根据当前需要，传入对应的 Action， RxJava 会相应的自动创建 Subscriber
1 Action0 表示一个无回调参数的Action；
2 Action1 表示一个含有一个回调参数的Action；
3 当然，还有Action2 ~ Action9，分别对应2~9个参数的Action；
4 每个Action，都有一个 call() 方法，通过泛型T，来指定对应参数的类型；
前面讲解了事件的产生到消费、订阅的过程，下面就举个完整的例子。
通过Rx写个小例子就是显示一张图片
从res/mipmap中取出一张图片，显示在ImageView上。
上面示例是RxJava最基本的一个用法。稍微消化一下，继续~~
RxJava 进阶 Scheduler线程控制
默认情况下，RxJava事件产生和消费均在同一个线程中，例如在主线程中调用，那么事件的产生和消费都在主线程。
所以，RxJava 的第一个牛逼之处在于可以自由切换线程！那么，如何做？
在 RxJava 中，提供了一个名为 Scheduler的线程调度器，RxJava 内部提供了4个调度器，分别是：Schedulers.io(): I/O 操作（读写文件、数据库、网络请求等），与newThread()差不多，区别在于io() 的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io()效率比 newThread() 更高。值得注意的是，在 io()下，不要进行大量的计算，以免产生不必要的线程；
1 Schedulers.newThread(): 开启新线程操作；
2 Schedulers.immediate(): 默认指定的线程，也就是当前线程；
3 Schedulers.computation():计算所使用的调度器。这个计算指的是 CPU 密集型计算，即不会被 I/O等操作限制性能的操作，例如图形的计算。这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。值得注意的是，不要把 I/O 操作放在computation() 中，否则 I/O 操作的等待时间会浪费 CPU；
4 AndroidSchedulers.mainThread(): RxJava 扩展的 Android 主线程；
我们可以通过 subscribeOn() 和 observeOn() 这两个方法来进行线程调度,依然还是显示一张图片，不同的是，这次是从网络上加载图片
所以，这段代码就做一件事，在 io 线程加载一张网络图片，加载完毕之后在主线程中显示到ImageView上。
RxJava的又一牛逼之处，在于 变换,稍微消化一下，继续~~
变换，啥意思呢？ 就是将发送的事件或事件序列，加工后转换成不同的事件或事件序列。
Observable 创建了一个 String 事件，也就是产生一个url，通过 map 操作符进行变换，返回Drawable对象。
逻辑表示就是：**Observable<String> --> map变换 --> Observable<Drawable>**
那么，Func1 是什么呢？与 Action1类似,不同的是 FuncX有返回值，而 ActionX没有。为什么需要返回值呢？目的就在于对象的变换，由String对象转换为Drawable对象。同样，也有Func0 ~ Func9，对应不同的参数个数。
flatMap操作符
不难发现，上述的 map 操作符，是一对一的变换，并且返回的是变换后的对象。而flatMap操作符可以适应一对多，并且返回的是一个 Observable
。应用场景举例：例如一个员工负责多个任务，现在要打印所有员工的所有任务。
执行结果为顺序打印出两位员工的所有任务列表
通过上面的代码可以看出，map 与 flatMap 这两个操作符的共同点在于，他们都是把一个对象转换为另一个对象，但须注意以下这些特点:
1 flatMap返回的是一个Observable对象，
2 map 返回的是一个普通转换后的对象;
3 flatMap返回的Observable对象并不是直接发送到Subscriber的回调中，而是重新创建一个Observable对象，并激活这个Observable对象，使之开始发送事件
4 map变换后返回的对象直接发到Subscriber回调中；
5 flatMap 变换后产生的每一个Observable对象发送的事件，最后都汇入同一个Observable，进而发送给Subscriber回调；
6 map返回类型 与 flatMap返回的Observable事件类型，可以与原来的事件类型一样；可以对一个Observable多次使用 map和 flatMap
