一、Rxjava
1.简介
Rxjava 是一个实现异步操作的库
优势： 使逻辑变得简洁，而不是代码量得增减，当逻辑变得复杂时，RxJava能保证从上到下仍然是链式调用，没有任何嵌套。
github :
https://github.com/ReactiveX/RxJava
https://github.com/ReactiveX/RxAndroid
2.概览
Rxjava基本原理就是观察者(ObServer)通过(Subscribe)订阅被观察者(Observable)
RxJava有四个基本概念：Observable(被观察者)，Observer(观察者)，subscribe(订阅)，事件。Observable和Observer通过subscribe达成订阅关系，从而 Observable可以在需要的时候发出事件来通知 Observer。
RxJava定义了三个事件回调方法：
(1) onNext()：相当于onClick(),每个单独的事件处理回调方法
(2) onCompleted()： 事件队列完结。RxJava不仅把每个事件单独处理，还会把它看成一个事件队列。当不再有新的onNext()发出时，需要触发onCompleted()作为结束标志。
(3) onError()： 事件队列异常，在事件处理过程中出异常时，onError()
会被触发，同时队列自动终止，不允许再有事件发出。
在一个正确运行的事件序列中, onCompleted()和 onError()有且只有一个，并且是事件序列中的最后一个。
在 RxJava 2.x 中，Observable 用于订阅 Observer，不再支持背压（1.x 中可以使用背压策略），而 Flowable 用于订阅 Subscriber ， 是支持背压（Backpressure）的。
Observable ( 被观察者 ) / Observer ( 观察者 )
Flowable （被观察者）/ Subscriber （观察者）
二、分析
从过程开始
2.1 创建Observer
Observer 即观察者，它决定事件触发的时候将有怎样的行为。可以通过创建Observer对象和创建Subscriber对象来实现观察者。
2.1.1 创建Observer对象：
Observer<String> observer=new Observer<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
};
2.1.2 创建Subscriber对象：
Subscriber<String> subscriber=new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
};
Subscriber实现了 Observer，并对 Observer 接口进行了一些扩展，实质上，在 RxJava 的 subscribe 过程中，Observer也总是会先被转换成一个 Subscriber再使用。
//转换成Subscriber
if (observer instanceof Subscriber) {
return subscribe((Subscriber<? super T>)observer);
}
2.2 创建Observable
2.2.1 使用 create方法创建： observable 即被观察者，它决定什么时候触发事件以及触发怎样的事件。RxJava使用create方法来创建一个Observable,其中OnSubcribe对象作为参数传入。当Observable被订阅时，OnSubcribe对象的call()方法会被自动调用，事件会按照设定依次触发。
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Hi");
subscriber.onNext("Aloha");
subscriber.onCompleted();
}
});
RxJava 还提供了一些方法用来快捷创建事件队列
2.2.2 使用just(T...) 创建： 将传入的参数依次发送出来。
Observable observable = Observable.just("Hello", "Hi", "Aloha");
// 将会依次调用：
// onNext("Hello");
// onNext("Hi");
// onNext("Aloha");
// onCompleted();
2..2.3 使用from(T[]) /from(Iterable<? extends T>)创建：将传入的数组或者Iterable拆分成具体的对象后，依次发送出来。
String[] words = {"Hello", "Hi", "Aloha"};
Observable observable = Observable.from(words);
// 将会依次调用：
// onNext("Hello");
// onNext("Hi");
// onNext("Aloha");
// onCompleted();
2.3 Subcribe(订阅)
创建了 Observable 和 Observer之后，再用 subscribe() 方法将它们联结起来。
observable.subscribe(observer);
// 或者：
observable.subscribe(subscriber);
Observable.subscribe(Subscriber) 的内部实现是这样的（逻辑实现）：
public Subscription subscribe(Subscriber subscriber) {
subscriber.onStart();
onSubscribe.call(subscriber);
return subscriber;
}
主要做了三件事：
(1)调用 subscriber.onStart();
(2)调用onSubscribe.call(subscriber);
(3)将传入的 Subscriber 作为 Subscription返回。
2.4RxJava不完整定义的回调(Action0,Action1)。
Action0： 是一个接口，只有一个call()方法，并且该方法无参无返回值。
public interface Action0 extends Action {
void call();
}
4.1.2 Action1： 是一个接口，只有一个call()方法，并且该方法有一个参数返回值。
public interface Action1<T> extends Action {
void call(T t);
}
2.5线程控制(Scheduler)
2.5.1 Scheduler API
RxJava 遵循的是线程不变的原则：在哪个线程调用 subscribe()，就在哪个线程生产事件；在哪个线程生产事件，就在哪个线程消费事件。
切换线程需要通过Scheduler，RxJava内置的Schedulers。
Schedulers.immediate()：直接在当前线程运行。
Schedulers.newThread()： 启动新线程，并在新线程执行操作。
Schedulers.io()： I/O操作使用的Scheduler。
Schedulers.computation()：计算所使用的Scheduler，CPU密集型计算，即不会被I/O操作限制性能的操作，不要把I/O操作放在这个computation()中，否则这个I/O操作的等待时间会浪费CPU。
AndroidSchedulers.mainThread()：使 操作执行在Android的主线程。
subscribeOn()： 指定subscribe发生的线程，即事件生产线程。
observeOn()： 指定Subscriber所运行的线程，即事件消费线程。
2.5.2线程控制：Scheduler (二)
observeOn()： 可以多次调用；指定的是它之后的操作所在的线程。observeOn()指定的是Subscriber的线程，而这个Subscriber并不一定是subscribe()中的Subscriber，而是observeOn()执行时，当前Obserable所对应的Subscriber。
subscribeOn()： subscribeOn()的位置放在哪里都可以，但它是只能调用一次的。
subscribeOn()和observeOn()的原理
subscribeOn 的线程切换发生在OnSubcribe中，即在它通知上一级 OnSubscribe 时，这时事件还没有开始发送，因此subscribeOn()的线程控制可以从事件发出的开端就造成影响；
observeOn() 的线程切换则发生在它内建的 Subscriber中，即发生在它即将给下一级 Subscriber 发送事件时，因此 observeOn()控制的是它后面的线程。
doOnSubscribe()
默认情况下doOnSubscribe()执行在subscribe()线程；但是如果doOnSubscribe()后面有subscribeOn()的话，它将执行在离它最近的 subscribeOn()所指定的线程。
doOnSubscribe()主要是在事件流程之前进行一些初始化工作，和Subscriber的 onStart()方法左右类似1；不同的是onStart()方法不能指定线程，它执行在 subscribe()被调用时的线程，这会对onStart()中代码有要求。
三、其他
1、RxJava和RxAndroid的区别： RxAndroid是特别针对Android这个平台增加了更新UI的调度器，其余的类都是相同的。
- Subscriber和Observer的区别
onStart()： 这个是Subscriber新增的方法，用于subscribe刚开始,事件还没发送之前，可以用于做一些准备工作。例如事件清零。onStart方法总是在subscribe的线程发生。
unSubscrible()： 这个是Subscribe实现的Subscription接口中的方法，用于取消订阅，因为subscribe后， Observable会持有一个Subscriber的引用，这个引用如果不能及时被释放，将有内存泄露的风险。所以最好保持一个原则：要在不再使用的时候尽快在合适的地方（例如 onPause() onStop()等方法中）调用unsubscribe()来解除引用关系，以避免内存泄露的发生。
