Rxjava+ReTrofit+okHttp深入浅出-终极封装特殊篇(替换Gson返回)
介绍
封装原理博客专栏:
介绍如何放弃GsonConverterFactory,直接返回String,灵活我们的封装!
具备功能
1.Retrofit+Rxjava+okhttp基本使用方法
2.统一处理请求数据格式
3.统一的ProgressDialog和回调Subscriber处理
4.取消http请求
5.预处理http请求
6.返回数据的统一判断
7.失败后的retry处理
8.RxLifecycle管理生命周期,防止泄露
9.文件上传下载(支持多文件,断点续传)
10.Cache数据持久化和数据库(greenDao)两种缓存机制
11.异常统一处理
效果
使用
1.初始化
moudel导入工程
compile project(':rxretrofitlibrary')
在Application中初始化RxRetrofitApp
RxRetrofitApp.init(this);
2.初始化HttpManager
需要传递一个回调HttpOnNextListener接口和activity生命周期
HttpManager manager=new HttpManager(this,this);
3.初始请求的数据和参数
public class SubjectPostApi extends BaseApi {
// 接口需要传入的参数 可自定义不同类型
private boolean all;
/*任何你先要传递的参数*/
// String xxxxx;
/**
* 默认初始化需要给定回调和rx周期类
* 可以额外设置请求设置加载框显示,回调等(可扩展)
*/
public SubjectPostApi() {
setShowProgress(true);
setCancel(true);
setCache(true);
setMothed("AppFiftyToneGraph/videoLink");
setCookieNetWorkTime(60);
setCookieNoNetWorkTime(24*60*60);
}
/**
*通过自定义sercie得到Observable对象
*sercie可动态设置,方便扩展
*/
@Override
public Observable getObservable(Retrofit retrofit) {
HttpPostService httpService = retrofit.create(HttpPostService.class);
return httpService.getAllVedioBy(isAll());
}
}
4.请求后的统一处理
通过method参数判断接口,然后动态解析返回的数据
@Override
public void onNext(String resulte, String method) {
/*post返回处理*/
if(method.equals(postEntity.getMothed())){
List<SubjectResulte> subjectResulte= JSONObject.parseArray(resulte,SubjectResulte.class);
tvMsg.setText("post返回:\n"+subjectResulte.toString() );
}
/*上传返回处理*/
if(method.equals(uplaodApi.getMothed())){
UploadResulte uploadResulte=JSONObject.parseObject(resulte,UploadResulte.class);
tvMsg.setText("上传成功返回:\n"+uploadResulte.getHeadImgUrl());
Glide.with(MainActivity.this).load(uploadResulte.getHeadImgUrl()).skipMemoryCache(true).into(img);
}
}
@Override
public void onError(Throwable e) {
tvMsg.setText("失败:\n" + e.toString());
}
- 初始化一个请求数据的对象继承BaseApi对象设置请求需要的参数
- 通过httpmanger对象,触发请求
- 结果统一通过BaseApi中的fun1方法判断,最后返回HttpOnNextListener
优化迭代
根据反馈及时更新和优化的过程,如果在使用过程中有任何问题,欢迎反馈给我!
思路
详细思路可以可以参看我的博客: Rxjava+ReTrofit+okHttp深入浅出-终极封装