请求网络接口时使用RxJava进行链式调用。
一,执行网络请求得到网络Response
如果response的状态为不成功,封装异常类,将其抛出如果网络请求过程中出现过异常被catch到,将其抛出
二,网络Response转换成结果类
得到Response后,需要将其中携带的信息转换成结果类,如果转换出现异常,将其抛出
三,服务器异常
转换成结果类实例后,如果其中有服务器返回的异常信息,封装异常类,用Observable.error抛出去。
设计异常类结构时应该通过异常类型code区分出网络错误、转换错误、服务器错误等不同的错误。服务器异常类中可以包括具体的服务器异常类型。
四,最终错误出口处的处理
网络接口链式调用的最后,会去subscribe一个subscriber,之前抛出的所有错误都会在这里被捕获,可以写一个基类BaseSubscriber,在onError里做一些通用的操作,如单点登录状态被踢掉、会话超时等通用处理,并对外暴露一些方法来允许开发人员自行处理异常。
五,捕获全局异常
有些错误可能未在链式调用中被捕捉到并导致程序崩溃,需要记录错误日志以便分析错误原因。记录方法:实现UncaughtExceptionHandler接口,将该类在Application初始化的时候设置给主线程,未被捕捉的异常引起主线程终止时,会调用其uncaughtException方法,在这里我们将日志保存到本地或者上传到服务器。
六,无法被捕捉到链式调用的onError中的异常
比如在subscriber的onError里又抛出了onError的情况:
java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker thread.
Caused by: rx.exceptions.OnErrorFailedException: Error occurred when trying to propagate error to Observer.onError
Caused by: rx.exceptions.CompositeException$CompositeExceptionCausalChain: Chain of Causes for CompositeException In Order Received
遇到上述日志需要检查自己在onError中的处理方法中有没有问题。
七,并发请求接口时的错误处理
RxJava合并Observable——merge和mergeDelayError操作符
1.merge
可以合并多个Observable的输出,它们的数据可能会交错发射(concat可以保持顺序)。如果某个原始Observable出现onError,merge后的Observable就会onError.
2.mergeDelayError
在合并和交错输出上和merge一样,但是mergeDelayError的原始observable出现onError时,错误通知会被保留,直到所有数据发射完毕后才执行onError。如果有多个原始observable出现了onError,这些onError通知会被合并成一个CompositeException ,保留在它的 Listexceptions异常列表里。如果只有一个原始observable出现了onError,则会直接使用这个onError通知,而不会生成CompositeException。
假如mergeDelayError(A,B)时需要有针对性地处理错误,需要将异常信息和A,B原始Observable对应起来,可以在原始Observable后面加上doOnError方法来处理错误。mergeDelayError(A.doOnError,B)
或者在doOnError里把异常信息保存到全局变量里,然后推迟到在最终出口处的onError里处理异常。
八,错误处理的操作符
1.catch类
从onError通知中恢复数据(替换成其它数据项或者数据序列)
onErrorResumeNext
onErrorReturn
onExceptionResumeNext
2.Retry类
发生错误时重新订阅它。可能会导致数据重复,需要自己处理重复的情形。
retry
retryWhen