共计 3791 个字符，预计需要花费 10 分钟才能阅读完成。
前言
本文基于 RxJava、Retrofit 的使用，若是对 RxJava 或 Retrofit 还不了解的简友可以先了解 RxJava、Retrofit 的用法再来看这篇文章。在这片文章之前分别单独介绍过 Rxjava 以及 Retrofit 的使用：Android Retrofit 2.0 的使用 Android RxJava 的使用（一）基本用法（以及后面的几篇，就不一一列出了）
使用
在了解了 RxJava 和 Retrofit 分别的用法后，RxJava、Retrofit 的搭配使用也就不再话下了。先看看使用 Retrofit 完成一次网络请求是怎样的
单独使用 Retrofit
1、先写一个 service
interface MyService {
@GET(“user/login”)
Call<UserInfo> login(
@Query(“username”) String username,
@Query(“password”) String password
);
}
2、获取 Call 执行网络请求
Retrofit retrofit = new Retrofit.Builder()
.addConverterFactory(GsonConverterFactory.create())
.baseUrl(BASE_URL)
.build();
MyService service = retrofit.create(MyService.class);
Call<UserInfo> call = service.login(“1111”, “ssss”);
call.enqueue(new Callback<UserInfo>() {
@Override
public void onResponse(Call<UserInfo> call, Response<UserInfo> response) {
// 请求成功操作
}
@Override
public void onFailure(Call<UserInfo> call, Throwable t) {
// 请求失败操作
}
});
以上是 Retrofit 单独使用时的做法。那 Retrofit 与 RxJava 结合是怎样使用的？下面就来说说这篇文章的重点。
RxJava + Retrofit 完成网络请求
1、添加依赖。前四个分别是 RxJava、RxAndroid、Retrofit 以及 Gson 的库，最后那个才是新加入的，RxJava + Retrofit 的使用需要用到最后那个包。
compile ‘io.reactivex:rxjava:x.y.z’
compile ‘io.reactivex:rxandroid:1.0.1’
compile ‘com.squareup.retrofit2:retrofit:2.0.2’
compile ‘com.squareup.retrofit2:converter-gson:2.0.2’
compile ‘com.squareup.retrofit2:adapter-rxjava:2.0.2’
注意：最后三个包的版本号必须一样，这里用的是 2.0.2。2、写一个登录的 service
interface MyService {
@GET(“user/login”)
Observable<UserInfo> login(
@Query(“username”) String username,
@Query(“password”) String password
);
}
相比之前的 service，这里 getNews 方法的返回值是 Observable 类型。Observable… 是不是觉得很熟悉，这货不就是之前在 RxJava 使用到的被监听者？3、使用 Observable 完成一个网络请求，登录成功后保存数据到本地。
Retrofit retrofit = new Retrofit.Builder()
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())// 新的配置
.baseUrl(BASE_URL)
.build();
MyService service = retrofit.create(MyService.class);
service.login(phone, password) // 获取 Observable 对象
.subscribeOn(Schedulers.newThread())// 请求在新的线程中执行
.observeOn(Schedulers.io()) // 请求完成后在 io 线程中执行
.doOnNext(new Action1<UserInfo>() {
@Override
public void call(UserInfo userInfo) {
saveUserInfo(userInfo);// 保存用户信息到本地
}
})
.observeOn(AndroidSchedulers.mainThread())// 最后在主线程中执行
.subscribe(new Subscriber<UserInfo>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
// 请求失败
}
@Override
public void onNext(UserInfo userInfo) {
// 请求成功
}
});
RxJava + Retrofit 形式的时候，Retrofit 把请求封装进 Observable，在请求结束后调用 onNext() 或在请求失败后调用 onError()。可以看到，调用了 service 的 login 方法后得到 Observable 对象，在新的线程中执行网络请求，请求成功后切换到 io 线程执行保存用户信息的动作，最后再切换到主线程执行请求失败 onError()、请求成功 onNext()。整体的逻辑十分清晰都在一条链中，就算还有别的要求还可以往里面添加，丝毫不影响代码的简洁。（终于举了一个有实际意义的例子）
注意：retrofit 的初始化加了一行代码
addCallAdapterFactory(RxJavaCallAdapterFactory.create())
RxJava + Retrofit 进阶
在上面举到登录后保存用户信息的例子，其实在做项目的时候，往往在登录后得到的并不是用户信息。一般登录后会得到 token，然后根据 token 去获取用户的信息。他们的步骤是这样的：1、登录 2、获取用户信息（前提：登录成功）可以看得出来，这是一个嵌套的结构 … 嵌套啊！！！天呐，最怕嵌套的结构了。使用 RxJava + Retrofit 来完成这样的请求（借用抛物线的例子，稍微做了点改动）
// 登录，获取 token
@GET(“/login”)
public Observable<String> login(
@Query(“username”) String username,
@Query(“password”) String password);
// 根据 token 获取用户信息
@GET(“/user”)
public Observable<User> getUser(
@Query(“token”) String token);
//…………………………….
service.login(“11111”, “22222”)
.flatMap(new Func1<String, Observable<User>>() {// 得到 token 后获取用户信息
@Override
public Observable<User> onNext(String token) {
return service.getUser(token);
})
.subscribeOn(Schedulers.newThread())// 请求在新的线程中执行请求
.observeOn(Schedulers.io()) // 请求完成后在 io 线程中执行
.doOnNext(new Action1<User>() {// 保存用户信息到本地
@Override
public void call(User userInfo) {
saveUserInfo(userInfo);
}
})
.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) {
// 请求失败
}
});
通过一个 flatMap() 轻松完成一次嵌套的请求，而且逻辑十分清晰。so easy～～～
小结
RxJava 的实用性从上面的两个例子慢慢体现了出来，逻辑越是复杂，RxJava 的优势就越明显。RxJava 的使用就暂时介绍到这里吧，使用过程中遇到好用的再出来跟大家分享。
以上有错误之处感谢指出
参考：给 Android 开发者的 RxJava 详解（本文部分内容引用自该博客）
