RxJava貌似是当前Android开发避不开的一个问题，作为小白的我一直对RxJava有很强的好奇心，它强大异步任务处理、丰富的流处理API都是魅力所在。但是看了很多文章后发现都写得深奥晦涩，看完更加疑惑了，所以就在一个练手的demo中使用了Rxjava来，一番使用后，有了一点点小小心得，写下来供大家参考，欢迎大神指点（因为我还是有点用不太明白/(ㄒoㄒ)/~~）；

什么是RxJava

RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences.

RxJava是一个在Java虚拟机上实现的Reactive Extensions：一个使用可观察序列来构建异步的、基于事件的程序的库。

从这段介绍我们可以看出，RxJava是一个用于实现异步操作的库

为什么是RxJava

说到异步操作，Android已经为我们提供了 AsyncTask / Handler 等等异步操作的工具，但为什么仍然大家都推荐RxJava呢？

通过我的使用我觉得有以下几点：

• 代码呈链式，逻辑清晰。
• API丰富功能强大。
• 如果使用Lamada表达式的话，代码非常简洁。
• 线程之间配合清晰明了。

初步接触

从知道Rxjava到尝试使用中间也有一个月了，由于平时很多异步场景都是自己封装的Service或者AsyncTask ，感觉并不是很需要使用到Rxjava，但经过一番使用，现在我在想还有什么地方能用上RxJava！

这里我使用的示例是我自己写的一个练手demo，欢迎大家star我的demo（虽然写的很不好 /(ㄒoㄒ)/~~），github地址：https://github.com/junerver/CloudNote

由于使用的Bmob云后端的SDK中已经包含了RxJava的依赖，所以没有额外的引入Rxjava的依赖。

Bmob中的RxJava

想到用RxJava是在看了izzyleung大神的知乎日报后，参考其中的一部分代码写了当时的第一个Observable，包括方法名都是参考的，代码如下所示：

用于读取数据库数据的Observable

这个被观察者（Observable）只做了一件事情，就是去查询数据库中有没有数据，如果有就全部取出。如果正常我们做这个操作，无非就是使用AsyncTask，如下所示：

使用AsyncTask

哎呀？说好的代码变得更加简洁呢，说好的逻辑更加清晰呢？坑爹啊！摔！！！

其实这是因为我们的异步任务太简单了，所以直接使用AsyncTask也可以很简单清晰。但是当逻辑变得复杂的时候，使用RxJava的优势就会体现出来，这里先按下不表（其实我也没做过什么复杂的 :-D）。

理解Observable

看了上面我写的那一堆鬼代码之后你是不是满肚子疑惑呢？又是Observable又是Subscriber的，到底是什么鬼？

网上有很多详解RxJava的帖子，里面有很详尽的API解释。但是我们先不说这些，我们先从这个最简单的Observable来试着理解。

被观察者（Observable）我们可以理解为处理任务的主体，观察者（Observer）是Observable处理完任务后关注结果的人。类似正常的异步回调，异步任务执行完毕后调用接口传递处理结果，回调的主体实现回调接口操作处理结果。

上面代码里的方法返回值是一个Observable<List<NoteEntity>>型变量，这里需要注意，被观察者（Observable）携带的这个泛型，是观察者（Observer）关注的数据类型。如果你理解了回调，那么久不难看懂这段代码了。

Observable.OnSubscribe接口在Observable被注册时调用，注册时需要传入一个实现Subscriber（Observer接口的抽象类）的对象。

所以我们这段代码其实就是，在执行完数据查询后，将查询到的数据通过onNext()接口，传递给观察者。

再来简单说说最后的两行代码：

.subscribeOn(Schedulers.io())                     //io线程执行
.observeOn(AndroidSchedulers.mainThread());      //主线程观察

聪明的你直接通过方法名应该就理解了它的作用了吧，subscribeOn()定义我们写在Observable.OnSubscribe中的耗时任务执行在什么线程，observeOn()则定义了观察者（获取处理结果的主体）所在的线程。

• Schedulers.immediate(): 直接在当前线程运行，相当于不指定线程。这是默认的 Scheduler。

• Schedulers.newThread(): 总是启用新线程，并在新线程执行操作。
• Schedulers.io(): I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler。行为模式和 newThread() 差不多，区别在于 io() 的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中，可以避免创建不必要的线程。
• Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。不要把 I/O 操作放在 computation() 中，否则 I/O 操作的等待时间会浪费 CPU。
• 另外， Android 还有一个专用的 AndroidSchedulers.mainThread()，它指定的操作将在 Android 主线程运行。

再来看看Observer

我们的观察者（Observer），其实是一个Fragment，它接受数据然后将数据显示在RecyclerView上。

Observer需要通过Observable的subscribe方法来订阅被观察者，subscribe方法接受一个Observer接口。由于Subscriber是Observer接口的抽象类，我们可以直接实现这个抽象类作为参数提供给subscribe方法。

Subscriber有几个重要的方法分别是：

• onNext(); * //普通事件的传递*
• onCompleted(); //事件队列执行完毕，当没有新的onNext() 发出时，需要触发 onCompleted() 方法作为标志。
• onError(); //事件队列异常，一般放在try{}catch{}中

实现观察者

如上代码所示，我们通过onNext()获取到由Observable处理后的结果，并在onCompleted()中将数据添加到RecyclerView的Adapter里。

好了，今天就先写到这里，文章中肯定有很多有问题的地方，希望给位大佬不吝赐教（第一次用MD写这么长的内容，给自己点赞！）。

致谢：扔物线大佬的给 Android 开发者的 RxJava 详解是对我启发较深的一篇RxJava文章，强烈推荐！