随着越来越多的人开始提及 RxJava ，鉴于 RxJava 目前这种既火爆又神秘的现状，写下这篇文章来对 RxJava 做一个相对详细的、针对 Android 开发者的介绍。
这篇文章的目的有两个： 1. 给对 RxJava 感兴趣的人一些入门的指引 2. 给正在使用 RxJava 但仍然心存疑惑的人一些更深入的解析。
在正文开始之前，放上 GitHub
链接和引入依赖的 gradle
代码： Github： https://github.com/ReactiveX/RxJava https://github.com/ReactiveX/RxAndroid 引入依赖： compile 'io.reactivex:rxjava:1.0.14'
compile 'io.reactivex:rxandroid:1.0.1'
RxJava 到底是什么
一个词：异步。
RxJava 在 GitHub 主页上的自我介绍是 "a library for composing asynchronous and event-based programs using observable sequences for the Java VM"（一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库）。这就是 RxJava ，概括得非常精准。
然而，对于初学者来说，这太难看懂了。因为它是一个『总结』，而初学者更需要一个『引言』。
其实， RxJava 的本质可以压缩为异步这一个词。说到根上，它就是一个实现异步操作的库，而别的定语都是基于这之上的。
RxJava 好在哪
换句话说，『同样是做异步，为什么人们用它，而不用现成的 AsyncTask / Handler / XXX / ... ？』
一个词：简洁。
异步操作很关键的一点是程序的简洁性，因为在调度过程比较复杂的情况下，异步代码经常会既难写也难被读懂。 Android 创造的 AsyncTask
和Handler
，其实都是为了让异步代码更加简洁。RxJava 的优势也是简洁，但它的简洁的与众不同之处在于，随着程序逻辑变得越来越复杂，它依然能够保持简洁。
API 介绍和原理简析
- 概念：扩展的观察者模式
RxJava 的异步实现，是通过一种扩展的观察者模式来实现的。
RxJava 的观察者模式
RxJava 有四个基本概念：Observable
(可观察者，即被观察者)、 Observer
(观察者)、 subscribe
(订阅)、事件。Observable
和 Observer
通过 subscribe()
方法实现订阅关系，从而 Observable
可以在需要的时候发出事件来通知 Observer
。
与传统观察者模式不同， RxJava 的事件回调方法除了普通事件 onNext()
（相当于 onClick()
/ onEvent()
）之外，还定义了两个特殊的事件：onCompleted()
和 onError()
。
onCompleted()
: 事件队列完结。RxJava 不仅把每个事件单独处理，还会把它们看做一个队列。RxJava 规定，当不会再有新的 onNext()
发出时，需要触发 onCompleted()
方法作为标志。
onError()
: 事件队列异常。在事件处理过程中出异常时，onError()
会被触发，同时队列自动终止，不允许再有事件发出。
在一个正确运行的事件序列中, onCompleted()
和 onError()
有且只有一个，并且是事件序列中的最后一个。需要注意的是，onCompleted()
和 onError()
二者也是互斥的，即在队列中调用了其中一个，就不应该再调用另一个。
- 基本实现
基于以上的概念， RxJava 的基本实现主要有三点：
-
创建 Observer
Observer 即观察者，它决定事件触发的时候将有怎样的行为。 RxJava 中的 Observer
接口的实现方式：
除了 Observer
接口之外，RxJava 还内置了一个实现了 Observer
的抽象类：Subscriber
。 Subscriber
对 Observer
接口进行了一些扩展，但他们的基本使用方式是完全一样的：
-
创建 Observable
Observable 即被观察者，它决定什么时候触发事件以及触发怎样的事件。 RxJava 使用 create()
方法来创建一个 Observable ，并为它定义事件触发规则：
可以看到，这里传入了一个 OnSubscribe
对象作为参数。OnSubscribe
会被存储在返回的 Observable
对象中，它的作用相当于一个计划表，当 Observable
被订阅的时候，OnSubscribe
的 call()
方法会自动被调用，事件序列就会依照设定依次触发（对于上面的代码，就是观察者Subscriber
将会被调用三次 onNext()
和一次 onCompleted()
）。这样，由被观察者调用了观察者的回调方法，就实现了由被观察者向观察者的事件传递，即观察者模式。 -
Subscribe (订阅)
除了 subscribe(Observer)
和 subscribe(Subscriber)
，subscribe()
还支持不完整定义的回调，RxJava 会自动根据定义创建出 Subscriber
。形式如下：
简单解释一下这段代码中出现的 Action1
和 Action0
。 Action0
是 RxJava 的一个接口，它只有一个方法 call()
，这个方法是无参无返回值的；由于 onCompleted()
方法也是无参无返回值的，因此 Action0
可以被当成一个包装对象，将 onCompleted()
的内容打包起来将自己作为一个参数传入 subscribe()
以实现不完整定义的回调。这样其实也可以看做将 onCompleted()
方法作为参数传进了 subscribe()
，相当于其他某些语言中的『闭包』。 Action1
也是一个接口，它同样只有一个方法 call(T param)
，这个方法也无返回值，但有一个参数；与 Action0
同理，由于 onNext(T obj)
和 onError(Throwable error)
也是单参数无返回值的，因此 Action1
可以将 onNext(obj)
和 onError(error)
打包起来传入 subscribe()
以实现不完整定义的回调。事实上，虽然 Action0
和 Action1
在 API 中使用最广泛，但 RxJava 是提供了多个 ActionX
形式的接口 (例如 Action2
, Action3
) 的，它们可以被用以包装不同的无返回值的方法。 -
场景示例
下面举两个例子
关注微信公众号获得更多内容：
网友评论