RxJava 详解

public void onNext(User user) {
userView.setUser(user);
}

@Override
public void onCompleted() {
}

@Override
public void onError(Throwable error) {
// Error handling
...
}
});

看到区别了吗？

当 RxJava 形式的时候，Retrofit 把请求封装进 

Observable

 ，在请求结束后调用 

onNext()

 或在请求失败后调用 

onError()

。

对比来看， 

Callback

 形式和 

Observable

 形式长得不太一样，但本质都差不多，而且在细节上 

Observable

 形式似乎还比 

Callback

 形式要差点。那
Retrofit 为什么还要提供 RxJava 的支持呢？

因为它好用啊！从这个例子看不出来是因为这只是最简单的情况。而一旦情景复杂起来， 

Callback

 形式马上就会开始让人头疼。比如：

假设这么一种情况：你的程序取到的 

User

 并不应该直接显示，而是需要先与数据库中的数据进行比对和修正后再显示。使用 

Callback

方式大概可以这么写：

getUser(userId, new Callback<User>() {
@Override
public void success(User user) {
processUser(user); // 尝试修正 User 数据
userView.setUser(user);
}

@Override
public void failure(RetrofitError error) {
// Error handling
...
}
};

有问题吗？

很简便，但不要这样做。为什么？因为这样做会影响性能。数据库的操作很重，一次读写操作花费 10~20ms 是很常见的，这样的耗时很容易造成界面的卡顿。所以通常情况下，如果可以的话一定要避免在主线程中处理数据库。所以为了提升性能，这段代码可以优化一下：

getUser(userId, new Callback<User>() {
@Override
public void success(User user) {
new Thread() {
@Override
public void run() {
processUser(user); // 尝试修正 User 数据
runOnUiThread(new Runnable() { // 切回 UI 线程
@Override
public void run() {
userView.setUser(user);
}
});
}).start();
}

@Override
public void failure(RetrofitError error) {
// Error handling
...
}
};

性能问题解决，但……这代码实在是太乱了，迷之缩进啊！杂乱的代码往往不仅仅是美观问题，因为代码越乱往往就越难读懂，而如果项目中充斥着杂乱的代码，无疑会降低代码的可读性，造成团队开发效率的降低和出错率的升高。

这时候，如果用 RxJava 的形式，就好办多了。 RxJava 形式的代码是这样的：

getUser(userId)
.doOnNext(new Action1<User>() {
@Override
public void call(User user) {
processUser(user);
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<User>() {
@Override
public void onNext(User user) {
userView.setUser(user);
}

@Override
public void onCompleted() {
}

@Override
public void onError(Throwable error) {
// Error handling
...
}
});

后台代码和前台代码全都写在一条链中，明显清晰了很多。

再举一个例子：假设 

/user

 接口并不能直接访问，而需要填入一个在线获取的 

token

 ，代码应该怎么写？

Callback

 方式，可以使用嵌套的 

Callback

：

@GET("/token")
public void getToken(Callback<String> callback);

@GET("/user")
public void getUser(@Query("token") String token, @Query("userId") String userId, Callback<User> callback);

...

getToken(new Callback<String>() {
@Override
public void success(String token) {
getUser(token, userId, new Callback<User>() {
@Override
public void success(User user) {
userView.setUser(user);
}

@Override
public void failure(RetrofitError error) {
// Error handling
...
}
};
}

@Override
public void failure(RetrofitError error) {
// Error handling
...
}
});

倒是没有什么性能问题，可是迷之缩进毁一生，你懂我也懂，做过大项目的人应该更懂。

而使用 RxJava 的话，代码是这样的：

@GET("/token")
public Observable<String> getToken();

@GET("/user")
public Observable<User> getUser(@Query("token") String token, @Query("userId") String userId);

...

getToken()
.flatMap(new Func1<String, Observable<User>>() {
@Override
public Observable<User> onNext(String token) {
return getUser(token, userId);
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<User>() {
@Override
public void onNext(User user) {
userView.setUser(user);
}

@Override
public void onCompleted() {
}

@Override
public void onError(Throwable error) {
// Error handling
...
}
});

用一个 

flatMap()

 就搞定了逻辑，依然是一条链。看着就很爽，是吧？

2016/03/31 更新，加上我写的一个 Sample 项目： 
rengwuxian RxJava Samples

好，Retrofit 部分就到这里。

2. RxBinding

RxBinding 是 Jake Wharton 的一个开源库，它提供了一套在 Android 平台上的基于 RxJava 的 Binding API。所谓 Binding，就是类似设置

OnClickListener

 、设置 

TextWatcher

 这样的注册绑定对象的
API。

举个设置点击监听的例子。使用 

RxBinding

 ，可以把事件监听用这样的方法来设置：

Button button = ...;
RxView.clickEvents(button) // 以 Observable 形式来反馈点击事件
.subscribe(new Action1<ViewClickEvent>() {
@Override
public void call(ViewClickEvent event) {
// Click handling
}
});

看起来除了形式变了没什么区别，实质上也是这样。甚至如果你看一下它的源码，你会发现它连实现都没什么惊喜：它的内部是直接用一个包裹着的 

setOnClickListener()

 来实现的。然而，仅仅这一个形式的改变，却恰好就是 

RxBinding

 的目的：扩展性。通过 

RxBinding

把点击监听转换成 

Observable

 之后，就有了对它进行扩展的可能。扩展的方式有很多，根据需求而定。一个例子是前面提到过的

throttleFirst()

 ，用于去抖动，也就是消除手抖导致的快速连环点击：

RxView.clickEvents(button)
.throttleFirst(500, TimeUnit.MILLISECONDS)
.subscribe(clickAction);

如果想对 

RxBinding

 有更多了解，可以去它的 GitHub
项目 下面看看。

3. 各种异步操作

前面举的 

Retrofit

 和 

RxBinding

 的例子，是两个可以提供现成的 

Observable

 的库。而如果你有某些异步操作无法用这些库来自动生成

Observable

，也完全可以自己写。例如数据库的读写、大图片的载入、文件压缩/解压等各种需要放在后台工作的耗时操作，都可以用
RxJava 来实现，有了之前几章的例子，这里应该不用再举例了。

4. RxBus

RxBus 名字看起来像一个库，但它并不是一个库，而是一种模式，它的思想是使用 RxJava 来实现了 EventBus ，而让你不再需要使用

Otto

 或者
GreenRobot 的 

EventBus

。至于什么是 RxBus，可以看这篇文章。顺便说一句，Flipboard
已经用 RxBus 替换掉了 

Otto

 ，目前为止没有不良反应。

最后

对于 Android 开发者来说， RxJava 是一个很难上手的库，因为它对于 Android 开发者来说有太多陌生的概念了。可是它真的很牛逼。因此，我写了这篇《给 Android 开发者的 RxJava 详解》，希望能给始终搞不明白什么是 RxJava 的人一些入门的指引，或者能让正在使用 RxJava 但仍然心存疑惑的人看到一些更深入的解析。无论如何，只要能给各位同为 Android 工程师的你们提供一些帮助，这篇文章的目的就达到了。

再次感谢对这篇文章的产出提供支持的各位： 

技术支持：流火枫林 

内测读者：代码家、鲍永章、drakeet、马琳、有时放纵、程序亦非猿、大头鬼、XZoomEye、席德雨、TCahead、Tiiime、Ailurus、宅学长、妖孽、大大大大大臣哥、NicodeLee 

赞助方：周伯通招聘 是他们让我的文章能够以不那么丑陋的样子出现在大家面前。

关于作者

朱凯（扔物线），Flipboard 北京 Android 工程师。

微博：扔物线

GitHub：rengwuxian

为什么写这个？

与两三年前的境况不同，中国现在已经不缺初级 Android 工程师，但中级和高级工程师严重供不应求。因此我决定从今天开始不定期地发布我的技术分享，只希望能够和大家共同提升，通过我们的成长来解决一点点国内互联网公司人才稀缺的困境，也提升各位技术党的收入。所以，不仅要写这篇，我还会写更多。至于内容的定位，我计划只定位真正的干货，一些边边角角的小技巧和炫酷的黑科技应该都不会写，总之希望每篇文章都能帮读者提升真正的实力。