Retrofit2.0+RxJava网络请求异常统一处理

本文内容是基于RxJava 2.0及Retrofit 2.1分析的。参考了 Rxjava +Retrofit 你需要掌握的几个技巧，Retrofit缓存，统一对有无网络处理, 异常处理，返回结果问题

下面列出具体添加的依赖。

以下这些错误，都是在网络请求中经常见的。我们可以通过Toastd出消息通知用户具体的异常以及加载对应的UI界面。除此之外，通过具体的异常信息，方便我们及时的排查项目中的BUG。

那么问题就来了，我们如何判断异常的类型？

这就要从服务器返回的数据格式说起了。

我们一般请求的返回都是像下面这样

服务器端返回数据约定俗称就是大概以上的格式。可能具体的code码表示的含义不一样，这个可以与服务器端人员交流，灵活变化。

关于Retrofit的基本配置就不再讲述了，这里具体讲解如何对服务器返回数据封装以及使用RxJava对错误信息处理。

封装返回数据

对于上述的服务器返回数据我们要对code做出一些判断，code不为200（假设200表示请求网络成功）就抛出异常。所以我们新建一个BaseResponse类，对应上面的数据结构。

这算是所有实体的一个基类，data可以为任何数据类型。

然后要对返回结果进行预处理，新建一个ExceptionHandle。预处理无非就是当根据返回数据BaseResponse的isOk()方法判断为是否为true，若为true则正常处理，否则抛出异常让ExceptionHandle进一步处理，判断异常为何种异常。我们先跳过前面的逻辑，先了解如何判断是何种异常？

判断异常类型

详细可看源码，下面会贴出地址。

通过ExceptionHandle.handleException(Throwable e) 即可返回一个异常，并携带具体异常类型信息。

现在我们已经知道了如何判断是否产生以上以及如何判断异常类型。接下来需要解决地就是如何把异常传递给Observer的onError(Throwable e)去处理异常。

在进行异常传递的过程中，第一步我们先要判断服务器返回的数据是否是异常，如果不是异常则返回data数据，如果是异常则抛出异常。这个时候就包含了一个数据转换的过程即把BaseResponse对象转换成data类型的对象，所以需要map() *** 作符。

其中HandleFuc实现了 Function<BaseResponse<T>, T>接口

如果不出现异常则不会走第二步。如果出现异常，则需要进行第二步，即对异常进行判断，然后将ExceptionHandle.handleException(Throwable e) 返回的异常传入onError()中处理。

重点来了：当产生异常时，应该终止对onNext()方法的调用并调用onError()方法。如果不继续处理，仅通过以上步骤，虽然会调用onError()方法，但是没有对异常进行判断，并且没有取消onNext()方法。那么有没有一个好的方法，可以即取消onNext()方法，又能在其中实现异常判断的执行，并且会调用onError()方法？

如此强大的RxJava自然有这样的方法了， onErrorResumeNext() 就能实现这个要求。对于 onErrorResumeNext() ，可以简单理解为：当发生错误的时候，由另外一个Observable来代替当前的Observable并继续发射数据。

onErrorResumeNext() 中传入的参数可以是一个Function接口。这样，我们可以在Function中生成一个Observable，该Observable执行异常判断的逻辑，并调用onError()方法。

具体实现如下：

至此，我们便实现了异常判断与传递的逻辑。这样我们就可以在onError()方法中提取具体的异常状态信息，进行相应的处理。

大概流程是：map()进行数据类型转换，并检测异常。如果正常，返回data类型的数据。如果不正常，onErrorResumeNext()判断异常类型并传递异常

上述情况关闭了网络。当发起网络请求，没有网络则抛出异常，然后检测出具体异常，Toast提示异常类型，用户便知道是什么地方出错了。

demo参考地址： https://github.com/maiduoduo/RetrofitRxJavaException

Retrofit 是一个 RESTful 的 HTTP 网络请求框架的封装，网络请求的工作本质上是 OkHttp 完成，而 Retrofit 仅负责 网络请求接口的封装

1.添加Retrofit库的依赖：

后面三个是可选的，分别是数据解析器和gson，以及rxjava支持的依赖

2.创建 用于描述网络请求 的接口

Retrofit将 Http请求 抽象成 Java接口：采用 注解 描述网络请求参数 和配置网络请求参数

3.创建Retrofit实例

4.发送请求

请求分为同步请求和异步请求

response.body()就是Reception对象，网络请求的完整 Url =在创建Retrofit实例时通过.baseUrl()设置 +网络请求接口的注解设置（下面称 “path“ ）

整合的规则如下：

上面我们用了@GET注解来发送Get请求，Retrofit还提供了很多其他的注解类型

1.@GET、@POST、@PUT、@DELETE、@HEAD分别对应 HTTP中的网络请求方式

2.@HTTP替换@GET、@POST、@PUT、@DELETE、@HEAD注解的作用 及 更多功能拓展

具体使用：通过属性method、path、hasBody进行设置

1.@FormUrlEncoded

表示发送form-encoded的数据，每个键值对需要用@Filed来注解键名，随后的对象需要提供值。

2.@Multipart

表示发送form-encoded的数据（适用于 有文件 上传的场景），每个键值对需要用@Part来注解键名，随后的对象需要提供值。

1.@Header &@Headers

添加请求头 &添加不固定的请求头

2.@Body

以 Post方式 传递 自定义数据类型 给服务器,如果提交的是一个Map，那么作用相当于 @Field,不过Map要经过 FormBody.Builder 类处理成为符合 Okhttp 格式的表单，如：

3.@Field &@FieldMap

发送 Post请求 时提交请求的表单字段,与 @FormUrlEncoded 注解配合使用

4.@Part &@PartMap

发送 Post请求 时提交请求的表单字段,与@Field的区别：功能相同，但携带的参数类型更加丰富，包括数据流，所以适用于 有文件上传 的场景,与 @Multipart 注解配合使用

5.@Query和@QueryMap

用于 @GET 方法的查询参数（Query = Url 中 ‘?’ 后面的 key-value）

如：url = http://www.println.net/?cate=android ，其中，Query = cate

配置时只需要在接口方法中增加一个参数即可：

6.@Path

URL地址的缺省值

7.@Url

直接传入一个请求的 URL变量 用于URL设置

例如：工程 A 添加了 rxandroid:2.0.1 和adapter-rxjava两个libs.

而adapter-rxjava中使用了rxandroid:1.1.5

这样在工程中就会出现两个不同的类库。

引用的部分libs:

compile ‘io.reactivex.rxjava2:rxandroid:2.0.1’

compile ‘io.reactivex.rxjava2:rxjava:2.0.1’

compile ‘com.google.code.gson:gson:2.7’

compile ‘com.squareup.retrofit2:retrofit:2.1.0’

compile ‘com.squareup.retrofit2:converter-gson:2.1.0’

compile (‘com.squareup.retrofit2:adapter-rxjava:2.1.0’)

编译之后 如下图：

二、问题分析：

1、 rxandroid:1.1.5 在 dependencies 并没有添加1.1.5版本（注意工程中添加的是rxandroid:2.0.1），此lib从何而来？

答案是肯定的，显然在dependencies添加的其他libs中有使用到rxandroid:1.1.5版本的。

1

2、多余的rxandroid:1.1.5 是被那个lib使用到的呢？如何知道呢？

在文件目录下或 Android Studio的 Terminal下敲 gradlew -q app:dependencies 便有各个libs引用关系的输出：

通过各个libs引用的关系图，就可以清楚的看出：adapter-rxjava:2.1.0 中使用的是 io.reactivex:rxjava:1.1.5

三、问题解决：

1、知道是那个libs中和rxandroid:1.1.5 ，问题就好解决了，直接

exclude 问题解决！

compile (‘com.squareup.retrofit2:adapter-rxjava:2.1.0’){

exclude module: ‘rxjava’

}

---