首页 > 代码库 > RxJava + Retrofit完成网络请求

RxJava + Retrofit完成网络请求

 

1、前言

   

本文基于RxJava、Retrofit的使用,若是对RxJava或Retrofit还不了解的简友可以先了解RxJava、Retrofit的用法再来看这篇文章。

 

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

  • Android Retrofit 2.0 的使用

  • Android RxJava的使用(一)基本用法

 

2、使用   

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

 

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

2.1 单独使用Retrofit

 

1、先写一个service

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

2、获取Call执行网络请求

技术分享

 

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

 

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

 

2.2 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包含登录方法

 

技术分享

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

Observable...是不是觉得很熟悉,这货不就是之前在RxJava使用到的被监听者?

 

3、使用Observable完成一个网络请求,登录成功后保存数据到本地。

 

技术分享

 

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

 

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

 

整体的逻辑十分清晰都在一条链中,就算还有别的要求还可以往里面添加,丝毫不影响代码的简洁。

(终于举了一个有实际意义的例子)。

 

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

addCallAdapterFactory(RxJavaCallAdapterFactory.create())

3、RxJava + Retrofit 进阶   

在上面举到登录后保存用户信息的例子,其实在做项目的时候,往往在登录后得到的并不是用户信息。一般登录后会得到token,然后根据token去获取用户的信息。他们的步骤是这样的:

 

  • 1、登录

  • 2、获取用户信息(前提:登录成功)

可以看得出来,这是一个嵌套的结构...嵌套啊!!!天呐,最怕嵌套的结构了。


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

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

稍微做了点改动)

 

接口方法:

 

技术分享

 

调用login方法:

 

技术分享

 

通过一个flatMap()轻松完成一次嵌套的请求,而且逻辑十分清晰。so easy~~~

 

4、小结

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

RxJava + Retrofit完成网络请求