Android(安卓)异步 RxAndroid框架官方例子
RxAndroid：Reactive Extensions for Android
RxAndroid 采用观察者模式的典型应用，本质实现异步操作的库，是RxJava的在Android上的运应用。
GitHub 链接和引入依赖的 gradle 代码： Github：
https://github.com/ReactiveX/RxAndroid
引入依赖：
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
This module adds the minimum classes to RxJava that make writing reactive components in Android applications easy and hassle-free. More specifically, it provides a Scheduler that schedules on the main thread or any given Looper.
先看看github官方上RxAndroid的例子
public class MainActivity extends Activity { private static final String TAG = "RxAndroidSamples"; private final CompositeDisposable disposables = new CompositeDisposable(); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main_activity); findViewById(R.id.button_run_scheduler).setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { onRunSchedulerExampleButtonClicked(); } }); } @Override protected void onDestroy() { super.onDestroy(); disposables.clear(); } void onRunSchedulerExampleButtonClicked() { disposables.add(sampleObservable()//添加被观察者 // Run on a background thread .subscribeOn(Schedulers.io())//订阅事件;被创建的事件的内容"one", "two", "three", "four", "five"将会在 IO 线程发出 // Be notified on the main thread .observeOn(AndroidSchedulers.mainThread())//指定 Subscriber 的回调发生在主线程 .subscribeWith(new DisposableObserver() { @Override public void onComplete() { Log.d(TAG, "onComplete()"); } @Override public void onError(Throwable e) { Log.e(TAG, "onError()", e); } @Override public void onNext(String string) { Log.d(TAG, "onNext(" + string + ")"); } })); } static Observable sampleObservable() { return Observable.defer(new Callable>() { @Override public ObservableSource<? extends String> call() throws Exception { // Do some long running operation SystemClock.sleep(5000); // RxJava 还提供了一些方法用来快捷创建事件队列，just(T...): 将传入的参数依次发送出来 // 如下将会依次调用： // onNext("one"); // onNext("two"); // onNext("four"); // onNext("five"); // onCompleted(); return Observable.just("one", "two", "three", "four", "five"); } }); }} 运行看看如何
demoLog.pngRxJava 好在哪-简洁
异步操作很关键的一点是程序的简洁性，因为在调度过程比较复杂的情况下，异步代码经常会既难写也难被读懂。 Android 创造的 AsyncTask 和Handler ，其实都是为了让异步代码更加简洁。RxJava 的优势也是简洁，但它的简洁的与众不同之处在于，随着程序逻辑变得越来越复杂，它依然能够保持简洁。
观察一下你会发现， RxJava 的这个实现，是一条从上到下的链式调用，没有任何嵌套，这在逻辑的简洁性上是具有优势的。
附：观察者模式简介
观察者模式面向的需求是：A 对象（观察者）对 B 对象（被观察者）的某种变化高度敏感，需要在 B 变化的一瞬间做出反应。观察者不需要时刻盯着被观察者（例如 A 不需要每过 2ms 就检查一次 B 的状态），而是采用注册(Register)或者称为订阅(Subscribe)的方式，告诉被观察者：我需要你的某某状态，你要在它变化的时候通知我。
Android 开发中一个比较典型的例子是点击监听器 OnClickListener 。对设置 OnClickListener 来说， View 是被观察者， OnClickListener 是观察者，二者通过 setOnClickListener() 方法达成订阅关系。订阅之后用户点击按钮的瞬间，Android Framework 就会将点击事件发送给已经注册的 OnClickListener 。采取这样被动的观察方式，既省去了反复检索状态的资源消耗，也能够得到最高的反馈速度。
第一、RxJava的事件原理
https://www.jianshu.com/p/464fa025229e
第二、RxJava的线程
https://www.jianshu.com/p/8818b98c44e2
第三、RxJava的操作符
https://www.jianshu.com/p/128e662906af
第四、RxJava的多事件操作符zip
https://www.jianshu.com/p/bb58571cdb64
第五、RxJava的事件背压
https://www.jianshu.com/p/0f2d6c2387c9
https://www.jianshu.com/p/e4c6d7989356
https://www.jianshu.com/p/9b1304435564
https://www.jianshu.com/p/a75ecf461e02
https://www.jianshu.com/p/36e0f7f43a51
操作符总结：
filter:可以过滤上游的事件
sample:可以指定时间间隔接受上游时间
map:把上游事件进行转化发给下游
zip:多个上游事件合并结果发给下游
filterMap:把上游事件进行处理转发给下游，和map的区别是输入为单个，输出可以是多个的Observeable
doOnNext:对下游接受事件之前的数据做一次处理
just,from,create,range,interval:主要用于构造事件，just支持可变参数，from支持数组，range是表示事件个数范围，interval是定时发送事件，当然还有repeat重复发送事件等
dispose用于关闭事件流，2.0之后是用cancel，当然还有手动响应式获取事件的request方法
操作对象：
1.0：上游：Observable，下游：Observer
2.0：上游：Flowable，下游：Subscriber
参考：给Android 开发者的 RxJava 详解 -扔物线
更多相关文章
- 百度地图SDK for Android【事件监听】
- toolbar自定义右边的菜单注意
- Android(安卓)—— EventBus使用简介
- View Touch 事件分发
- onKeyDown事件与Layout坐标交互
- 【Android(安卓)开发教程】注册事件监听器
- Android(安卓)游戏开发中 OnTouchEvent() 触屏事件的性能优化
- 安卓seekBar的使用（初学者）
- Android触摸事件(三)-触摸事件类使用实例