一、RxJava
GitHub: RxJava2Demo
好处：
1、整洁
2、异步
观察者模式：
观察者（Observer）模式：是对象的行为模式，又叫做发布-订阅（Publish/Subscribe）模式。
观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主体对象，这个主体对象在状态上发生变化时，会通知所有观察者对象，使它们能够自动更新自己。
二、RxJava的概念
RxJava是一个java vm 利用可观察序列编写异步事件、基于事件的程序库。
RxJava
RxAndroid
添加依赖：
compile "io.reactivex.rxjava2:rxjava:2.x.y"
compile 'io.reactivex:rxandroid:2.x.y'
1、Observable：被观察者(主体Subject)
2、Observer/Subscriber：观察者
3、Subscribe：订阅
Observable和Observer通过subscrile()方法实现订阅关系
三、基本使用3部
1、创建Observable（被观察者）
//创建一个上游 Observable：Observable observable = Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(ObservableEmitter emitter) throws Exception {
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onComplete();//和onError()不能同时调用（同时调用会执行前一个）
}
});
2、创建Observer（观察者）
//创建一个下游 Observer
Observer observer = new Observer() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "subscribe");
}
@Override
public void onNext(Integer value) {
Log.d(TAG, "" + value);
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "error");
}
@Override
public void onComplete() {
Log.d(TAG, "complete");
}
};
3、订阅
//建立连接
observable.subscribe(observer);
四、简洁写法
1、创建被观察者
//第二种简写的几种方法
return Observable.just("李小璐", "贾乃亮", "绿帽子");
// Observable.fromArray("李小璐", "贾乃亮", "绿帽子");
// Observable.fromCallable(new Callable() {
// @Override
// public Object call() throws Exception {
// return "范冰冰";
// }
// });
2、创建观察者并建立链接
//第二种简写Consumer代替了Observer
observable.subscribe(new Consumer() {
@Override
public void accept(String s) throws Exception {
}
});
五、与Retrofit2结合
1、环境配置，添加依赖（在RxJava2的包依赖基础上）
在builde.gradle里面添加上
compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
4、在AndroidManifest.xml添加所需权限
六、Scheduler线程控制
1、Schedulers.immediate();
直接在当前线程运行，相当于不指定线程。这是默认的Scheduler。
2、Schedulers.newThread();
总是启用新线程，并在新线程执行操作。
3、Schedulers.io();
I/O操作（读写文件、读写数据库、网络信息交互等）所使用的Scheduler。行为模式和newThread()差不多,区别在于io()的内部实现是使用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下io()比newThread()更有效率。不要把计算工作放在io()中，可以避免创建不必要的线程。
4、Schedulers.computation();
计算所使用的Scheduler。这个计算指的是CPU密集型计算，既不会被I/O等操作限制性能的操作，例如图形的计算。这个Scheduler使用的固定的线程池，大小为CPU核数。不要把I/O操作放在computation()中，否则I/O操作的等待时间会浪费CPU。
5、AndroidSchedulers.mainThread();
它指定的操作将在Android主线程运行。
