引言

RxAndroid是一个开发库、是一种代码风格、也是一种思维方式。

正如标题所言，RxAndroid的特点是简洁、优雅、高效，它的优点是多线程切换简单、数据变换容易、代码简洁可读性好、第三方支持丰富易于开发；缺点是学习成本较高、出错难以排查。

 

用途与优势

·起源

RxAndroid源于RxJava——"a library for composing asynchronous and event-based programs using observable sequences for the Java VM“，意为“一个在Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库”。

·用途

RxAndoid在我的粗略理解中，是一个实现异步操作的库，具有简洁的链式代码，提供强大的数据变换。

在详细解析 RxAndroid 的使用方式中，有这样一个例子：

一个典型的Android图文列表

这个界面是一个典型的Android图文列表，取在线数据，并显示为图文列表，业务流程是这样的：

1.输入多个人名

2.根据人名，在线查询对应的信息

3.获取返回信息，显示为图文列表

我们在常规开发中，一般要做到这样几件事：

•用异步线程在线查询数据

•用foreach查询每个用户（没有批量查询的接口）

•访问网络，查询每个人名对应的github信息（返回Json字符串）

•类型转换（Json->Java Object）

•在主线程中接收数据

•每收到一条数据，就用Adapter向列表添加一条，并刷新界面

实现这样的需求，可以说功能不多，代码不少，少说也得N个类+几百行代码吧，加班到23:59:59应该就能搞定了…工作量主要在异步网络操作、类型转换和界面刷新上。

不过，RxAndroid可以做到，用区区一小段儿代码就实现这个需求：

除了MainActivity、layout文件和Adapter类之外，主要的业务逻辑都在这一段儿代码中实现了。感兴趣的朋友可以在详细解析 RxAndroid 的使用方式中找到这段儿代码。

刚才谁说要几百行代码来着...

·优势

我看到这段代码，想到的第一件事就是异步好简单、代码好简洁，一个简单、一个简洁，这就意味着工作效率。

知识结构

前面说过，RxAndroid学习成本比较高，其中一个原因是出现的概念和知识点比较多，我个人倾向于把它们分为三部分：基本概念、线程控制和变换操作。

基本概念

先看一下刚才那段儿RxAndroid代码，里面有这么几个元素：

 

图中出现的基本概念，包括观察者、被观察者和订阅、另外还有一个图中没有出现的事件。

线程控制和变换操作我们先略过，在后面再看。

我们理解一个观察者、被观察者、订阅和事件的关系：

 

被观察者、观察者、订阅和事件

这显然是一个观察者模式，其中有四个基本概念：Observable (可观察者，即被观察者)、 Observer (观察者)、 subscribe (订阅)、事件。Observable 和Observer 通过 subscribe() 方法实现订阅关系，从而 Observable 可以在需要的时候发出事件来通知 Observer。

与传统观察者模式不同， RxJava 的事件回调方法除了普通事件 onNext() （相当于 onClick() / onEvent()）之外，还定义了两个特殊的事件：onCompleted() 和 onError()，作为事件队列的结束。

·基本概念—被观察者Observable

 

 

被观察者有这么几个特点：

•每一段Rx代码都从被观察者开始

•被观察者向观察者抛出onNext，onCompleted，onError事件，onNext可以连续多个，但onCompleted/onError只能出现一次，且出现后就结束事件队列

•用一些操作符可以方便地生成Observable对象，例如这段代码等价于Observable.just("Hello","Hi","Aloha");

·基本概念—观察者Observer及其变体

 

 

观察者有这么几个特点：

•被观察者抛出事件，观察者响应事件

•观察者决定如何响应onNext/onCompleted/onError事件

•订阅（.subscribe(...)）的逻辑和写法是有问题的，从逻辑上是观察者订阅被观察者，但写法却好像是被观察者订阅了观察者，这是为了不打断Rx的链式代码格式，而且，我个人觉得写成.subscribeby(...)更恰当

观察者Observer有多种变体的写法：

.subscribe(new Observer…)

.subscribe(new Subscriber…)

.subscribe(new onNextAction…,new onErrorAction…,new onCompleteAction…)

.subscribe(new onNextAction…,new onErrorAction…）

.subscribe(new onNextAction…)

其中，Observer是原始写法；

 

Subscriber继承了Observer