RxJava Retrofit2 网络请求，返回数据格式统一的数据报文处理方法

admin

统一的报文格式

一般公司开发都是会设计请求报文，报文结构一般是统一的，例如下面这样的格式

1. {
   
2. "code": "error",
   
3. "msg": "错误信息",
   
4. "data": "返回数据信息"
   
5. }

复制代码

data 有可能是JsonArray 也有可能是JsonObject。demo如下：
JsonArray

1. {
   
2. "code": "ok",
   
3. "msg": "",
   
4. "data": [
   
5.    "1923837918273.jpg",
   
6.    "1039488945879.jpg",
   
7.    "3981293879878.jpg",
   
8.    "5927378100293.jpg"
   
9. ]
   
10. }

复制代码

JsonObject

1. {
   
2. "code": "ok",
   
3. "msg": "",
   
4. "data": {
   
5.    "fileName":"1923837918273.jpg"
   
6. }
   
7. }

复制代码

那么使用Json序列化工具的时候，数据格式就会发生一定的变形。
DataResponse.Java

1. 
   
2. /**
   
3. * <b>类名称：</b> DataResponse <br/>
   
4. * <b>类描述：</b> 携带有数据的Http请求报文<br/>
   
5. * <b>创建人：</b> Lincoln <br/>
   
6. * <b>修改人：</b> Lincoln <br/>
   
7. * <b>修改时间：</b> 2016年03月15日 下午5:19<br/>
   
8. * <b>修改备注：</b> <br/>
   
9. *
   
10. * @version 1.0.0 <br/>
    
11. */
    
12. public class DataResponse<T> {
    
13. 
    
14.     private String code;
    
15.     private String msg;
    
16.     private T data;
    
17. 
    
18.     public String getCode() {
    
19.         return code;
    
20.     }
    
21. 
    
22.     public void setCode(String code) {
    
23.         this.code = code;
    
24.     }
    
25. 
    
26.     public String getMsg() {
    
27.         return msg;
    
28.     }
    
29. 
    
30.     public void setMsg(String msg) {
    
31.         this.msg = msg;
    
32.     }
    
33. 
    
34.     public T getData() {
    
35.         return data;
    
36.     }
    
37. 
    
38.     public void setData(T data) {
    
39.         this.data = data;
    
40.     }
    
41. }

复制代码

当data为JsonObject时Observable的泛型如下

1. Observable<DataResponse<User>>

复制代码

当data为JsonArray时Observable的泛型如下

1. Observable<DataResponse<List<String>>>

复制代码

这样泛型很多层，获取数据更是一个体力活。我们的报文既然是固定格式的，那么可不可以在处理的时候自动化？

答案是可行的！

使用map操作符，转换数据流

此文使用到了RxJava中的map操作符，此处不赘述，不清楚的童鞋点击这里
rain 大神的 RxJava 教程

1. http://blog.chengyunfeng.com/?p=964

复制代码

写的超级细致！赞！

map操作符是可以转换数据流的操作符，那么我们是不是可以将

1. DataResponse<User>

复制代码

或

1. DataResponse<List<String>>

复制代码

格式的泛型结构自动脱去一层？

最简单的方法就是我们继承Func1类，重载里面的call方法，自动化脱掉一层泛型。
代码如下

1. import rx.functions.Func1;
   
2. 
   
3. /**
   
4. * <b>类名称：</b> ResponseFunc <br/>
   
5. * <b>类描述：</b> 用于处理DataResponse数据格式的数据<br/>
   
6. * <b>创建人：</b> Lincoln <br/>
   
7. * <b>修改人：</b> Lincoln <br/>
   
8. * <b>修改时间：</b> 2016年03月23日 下午4:04<br/>
   
9. * <b>修改备注：</b> <br/>
   
10. *
    
11. * @version 1.0.0 <br/>
    
12. */
    
13. public class ResponseFunc<T> implements Func1<DataResponse<T>, T> {
    
14. 
    
15.     private static final String RESP_OK = "ok";
    
16. 
    
17.     //此处逻辑根据约定报文进行修改，实现逻辑即可
    
18.     @Override
    
19.     public T call(DataResponse<T> httpResult) {
    
20.         if (!httpResult.getCode().equals(RESP_OK)) {
    
21.             // 在此处抛出异常，subscribe的onError方法中会收到异常。
    
22.             // 抛出的异常不能是会使系统崩溃的检查异常，如OOM
    
23.             throw new IllegalStateException(httpResult.getMsg());
    
24.         }
    
25.         return httpResult.getData();
    
26.     }
    
27. }

复制代码

使用方法：

1. @Override
   
2. public void getConvenientBanner(final ServerView serverView) {
   
3.         ConvenientBannerModel model = new ConvenientBannerModelImpl();
   
4.         model.convenientBanner()
   
5.                 .observeOn(AndroidSchedulers.mainThread())
   
6.                 .subscribeOn(Schedulers.io())
   
7.                 //在此处调用一下，subscribe再处理的时候就脱掉了DataResponse
   
8.                 .map(new ResponseFunc<List<String>>())
   
9.                 .subscribe(new Action1<List<String>>() {
   
10.                     @Override
    
11.                     public void call(List<String> images) {
    
12.                         serverView.convenientBanner(images);
    
13.                     }
    
14.                 }, new Action1<Throwable>() {
    
15.                     @Override
    
16.                     public void call(Throwable throwable) {
    
17.                         DebugLog.e("首页广告图获取失败，" + throwable.getLocalizedMessage());
    
18.                     }
    
19.                 });
    
20.     }

复制代码

至此，即可简便的处理统一格式的数据报文。XML、Json 均可以使用！