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

Python024

Retrofit2.0+RxJava网络请求异常统一处理,第1张

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

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

以下这些错误,都是在网络请求中经常见的。我们可以通过Toast弹出消息通知用户具体的异常以及加载对应的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

1、Rxjava逻辑会比较清晰,蛋代码可读性比较差;用在后台的业务处理上,后台业务通常复杂,步骤多,这会让逻辑更清晰,但是前端基本上没有必要用,而且代码可读性比较差;

2、ReTrofit每次发起请求都会创建OkHttp,不会复用,导致单条数据的请求性能低了一倍以上;

3、Rxjava+ReTrofit组合起来运行的性能非常低,特别是并发的时候,性能更低,测试发现并发100条要1200ms,不使用的话并发130ms;

4、Rxjava+ReTrofit组合当需要读取本地缓存的时候,读缓存是通过URL作为KEY来读取,这样就需要写两遍的URL,一遍是框架用的,一遍是用于缓存的,使用起来更不方便;

以上是本人使用过程中的经历,有没有高手解惑,目前决定放弃这套组合,自己实现一套