内容简介：一个基本的RxJava配合Retrofit以及Lambda的网络调用看起来像这个样子的:当
RxJava
配合 Retrofit
能够大大简化Android项目中的网络请求代码量，使得逻辑更清晰，当然也可能会遇到一些问题。下面给出一种问题的解决方案。
需求
一个基本的RxJava配合Retrofit以及Lambda的网络调用看起来像这个样子的:
Subscription subscription = mApi.getSimpleApi()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(response -> {
//do Something
}, throwable -> {
//Ops Error
});
当 Retrofit
中的网络请求返回码状态码为 200
时，执行 do Something
中的逻辑处理正常的
业务流程，但是当服务器返回状态码为 非200
时，将会执行 Ops Error
中的业务流程而不会
执行 do Something
中的业务逻辑。
这样本没有什么问题，一般我们会在错误处理逻辑中在UI中给出错误提示，像这样:
Log.e("Ops", "Error:" + throwable.getMessage());
但是这样的话我们只能获取到一服务器的错误响应码以及对应的简短的响应码错误说明，一般情况下我们服务器
都会包装错误信息为一个JSON，客户端解析错误信息必要的时候动态展示在UI上以提示用户。如果我们要拿到这样的JSON，使用 throwable.getMessage()
这样做显然是不行的。是不是使用RxJava配合Retrofit只能拿到这样的错误Throwable信息呢？
显然不是的，其实服务器返回的错误信息 非200
响应码的 Response Body
JSON对象包含在这个 throwable
对象中，我们可以这样将其解析出来:
throwable -> {
if(throwable instanceof HttpException){
HttpException httpException= (HttpException) throwable;
try {
String errorBody= httpException.response().errorBody().string();
//TODO: parse To JSON Obj
} catch (IOException e) {
e.printStackTrace();
}
}
//Ops Print throwable
});
在 Parse to JSON Obj
中将 errorBody
解析为JSON对象进行相应的处理即可。
然而，你不能让我每个地方都加上这样的一段代码吧，既然我们使用的是 RxJava
，我们可以让这种处理稍微看起来优雅点。以下以 Jackson
为例:
自定义Action1
由于 RxJava
的错误异常处理接受一个参数，并且没有返回值，因此我们可以定义一个 Action1
来替代默认的Error Action:
public abstract class ErrorAction implements Action1<Throwable> {
@Override public void call(Throwable throwable) {
call(ErrorMessage.handle(throwable));
}
public abstract void call(ErrorMessage error);
}
其中 ErrorMessage
为我们定义好的错误消息Model:
定义Throwable Handle
@JsonIgnoreProperties(ignoreUnknown = true) public class ResponseError {
private final static int ERROR_CODE_IO_ERROR = 2072;
private final static int ERROR_CODE_UN_KNOW = 2073;
@JsonProperty("status_code") public int statusCode;
public String message;
public void setStatusCode(int statusCode) {
this.statusCode = statusCode;
}
public void setMessage(String message) {
this.message = message;
}
public static ResponseError handle(Throwable throwable) {
ResponseError responseError = null;
if (throwable instanceof HttpException) {
HttpException exception = (HttpException) throwable;
try {
responseError = new ObjectMapper().readValue(exception.response().errorBody().string(),
ResponseError.class);
} catch (IOException e) {
responseError = new ResponseError();
responseError.setMessage(e.getLocalizedMessage());
responseError.setStatusCode(ERROR_CODE_IO_ERROR);
}
} else {
responseError = new ResponseError();
responseError.setMessage(throwable.getMessage());
responseError.setStatusCode(ERROR_CODE_UN_KNOW);
}
return responseError;
}
}
这样，我们就完成了一个自定义 Action1
了，接下来我们便可以这样使用了:
Subscription subscription = mApi.getSimpleApi()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(response -> {
//do Something
}, new ErrorAction() {
@Override public void call(ErrorMessage msg) {
//Do Error
}
});
其中在 Do Error
中拿到 ErrorMessage
对象，进行相应的对象操作即可~
Enjoy IT!
以上所述就是小编给大家介绍的《RxJava、Retrofit接收Error Response Body》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
- 关于在接收POST请求，Tomcat偶发性接收到的参数不全问题排查分析
- 异步接收MSMQ消息
- 如何突破商品期货Tick接收限制
- SpringMVC接收和响应json数据
- 如何使用 jq 接收 blob 数据
- 转的关于公众号接收信息的返回
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
挑战程序设计竞赛
秋叶拓哉、岩田阳一、北川宜稔 / 巫泽俊、庄俊元、李津羽 / 人民邮电出版社 / 2013-7-1 / CNY 79.00
世界顶级程序设计高手的经验总结 【ACM-ICPC全球总冠军】巫泽俊主译 日本ACM-ICPC参赛者人手一册 本书对程序设计竞赛中的基础算法和经典问题进行了汇总，分为准备篇、初级篇、中级篇与高级篇4章。作者结合自己丰富的参赛经验，对严格筛选的110 多道各类试题进行了由浅入深、由易及难的细致讲解，并介绍了许多实用技巧。每章后附有习题，供读者练习，巩固所学。 本书适合程序设计......一起来看看 《挑战程序设计竞赛》 这本书的介绍吧!
