RxJava、Retrofit接收Error Response Body

发表于 | 更新于 | 分类于 | 评论数： | 阅读次数：

RxJava配合Retrofit能够大大简化Android项目中的网络请求代码量，使得逻辑更清晰，当然也可能会遇到一些问题。下面给出一种问题的解决方案。

需求

一个基本的RxJava配合Retrofit以及Lambda的网络调用看起来像这个样子的:

1
2
3
4
5
6
7
8
9
10
11
12
13

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中给出错误提示，像这样:

1
Log.e("Ops", "Error:" + throwable.getMessage());

但是这样的话我们只能获取到一服务器的错误响应码以及对应的简短的响应码错误说明，一般情况下我们服务器
都会包装错误信息为一个JSON，客户端解析错误信息必要的时候动态展示在UI上以提示用户。如果我们要拿到这样的JSON，使用throwable.getMessage()这样做显然是不行的。是不是使用RxJava配合Retrofit只能拿到这样的错误Throwable信息呢？

显然不是的，其实服务器返回的错误信息非200响应码的Response BodyJSON对象包含在这个throwable对象中，我们可以这样将其解析出来:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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:

1
2
3
4
5
6
7
8
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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
@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了，接下来我们便可以这样使用了:

1
2
3
4
5
6
7
8
9
10
11
12
13
14

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!

0%