RxJava + Retrofit完成网络请求

 

一、前言

   

本文基于RxJava、Retrofit的使用，如果对RxJava或Retrofit还不了解的简友能够先了解RxJava、Retrofit的用法再来看这篇文章。

 

在这片文章以前分别单独介绍过Rxjava以及Retrofit的使用：

• Android Retrofit 2.0 的使用

• Android RxJava的使用（一）基本用法

 

二、使用   

在了解了RxJava和Retrofit分别的用法后，RxJava、Retrofit的搭配使用也就再也不话下了。

 

先看看使用Retrofit完成一次网络请求是怎样：

2.1 单独使用Retrofit

 

一、先写一个service

1  interface MyService {  
2              @GET("user/login" )
3                    Call<UserInfo> login(
4                    @Query("username") String username,
5                    @Query("password") String password
6           );
7 }

 

二、获取Call执行网络请求

 

以上是Retrofit单独使用时的作法。

 

那Retrofit与RxJava结合是怎样使用的？下面就来讲说这篇文章的重点。

 

2.2 RxJava+Retrofit完成网络请求

 

一、添加依赖。前四个分别是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。

二、写一个service包含登陆方法

 

相比以前的service，这里login方法的返回值是Observable类型。

Observable...是否是以为很熟悉，这货不就是以前在RxJava使用到的被监听者？

 

三、使用Observable完成一个网络请求，登陆成功后保存数据到本地。

 

 

RxJava + Retrofit 形式的时候，Retrofit 把请求封装进 Observable ，在请求结束后调用 onNext() 或在请求失败后调用 onError()。

 

能够看到，调用了service的login方法后获得Observable对象，在新的线程中执行网络请求，请求成功后切换到io线程执行保存用户信息的动做，最后再切换到主线程执行请求失败onError()、请求成功onNext()。

 

总体的逻辑十分清晰都在一条链中，就算还有别的要求还能够往里面添加，丝绝不影响代码的简洁。

（终于举了一个有实际意义的例子）。

 

注意：retrofit的初始化加了一行代码

addCallAdapterFactory(RxJavaCallAdapterFactory.create())

三、RxJava + Retrofit 进阶   

在上面举到登陆后保存用户信息的例子，其实在作项目的时候，每每在登陆后获得的并非用户信息。通常登陆后会获得token，而后根据token去获取用户的信息。他们的步骤是这样的：

 

• 一、登陆

• 二、获取用户信息（前提：登陆成功）
  
  

能够看得出来，这是一个嵌套的结构...嵌套啊！！！天呐，最怕嵌套的结构了。

使用RxJava + Retrofit来完成这样的请求

（借用抛物线的例子 http://gank.io/post/560e15be2dca930e00da1083 ，

稍微作了点改动）

 

接口方法：

 

 

调用login方法：

 

 

经过一个flatMap()轻松完成一次嵌套的请求，并且逻辑十分清晰。so easy～～～

 

四、小结

RxJava的实用性从上面的两个例子慢慢体现了出来，逻辑越是复杂，RxJava的优点就越明显。RxJava的使用就暂时介绍到这里吧，使用过程当中遇到好用的再出来跟你们分享。