02 | Android 项目笔记 Retrofit+RxJav
打算在本项目中引入目前流行的Retrofit+RxJava网络框架，为了尽快从使用角度上手，以及适应大伙老工程调用习惯， 所以参考了好几篇大神的demo，封装成通用的post请求
- 在Application中初始化网络参数
private void initHttp() {
HttpSet.setOutLog(true);
// Retrofit+Rxjava网络请求框架的参数配置
HttpSet.config(this)//配置请求主机地址
.baseUrl(HttpSet.API_HOST = API_BASE_HOST)
//.baseUrl(API_HOST)
//配置全局请求头
.globalHeaders(new HashMap<String, String>())
//配置全局请求参数
.globalParams(new HashMap<String, String>())
//配置读取超时时间，单位秒
.readTimeout(30)
//配置写入超时时间，单位秒
.writeTimeout(30)
//配置连接超时时间，单位秒
.connectTimeout(30)
//配置请求失败重试次数
.retryCount(3)
//配置请求失败重试间隔时间，单位毫秒
.retryDelayMillis(1000)
//配置开启Gzip请求方式，需要服务器支持
// .postGzipInterceptor()
//配置应用级拦截器
// .interceptor(new HttpLogInterceptor()
// .setLevel(HttpLogInterceptor.Level.BODY))
// 打印全部日志
.networkInterceptor(new HttpLogInterceptor()
.setLevel(HttpLogInterceptor.Level.BODY))
//配置网络拦截器
// .networkInterceptor(new NoCacheInterceptor())
//配置主机证书验证
.hostnameVerifier(new SSLUtil.UnSafeHostnameVerifier(API_BASE_HOST))
//配置SSL证书验证
.SSLSocketFactory(SSLUtil.getSslSocketFactory(null, null, null)).build();
}
其中API_BASE_HOST为要配置的主机地址， 如"https://www.jianshu.com/"
2.有两种调用方式
2-1.传入要解析的实体类包装类， 返回相应的实体类
public void getTResult() {
Map<String, String> maps = new HashMap<>();
maps.put("seat_id", "1");
ILoading ll = new ILoading(this);
ll.setMessage("网络请求");
// data 是 对象 , 泛型是 CommonObjResp<T>
// data 是 数组 , 泛型是 CommonArrayResp<T>
HttpRequestHelper.doPost(UrlEntity.GET_START_AD, maps, new RespCallback<CommonObjResp<AdEntity>>() {
@Override
public void onResponse(CommonObjResp<AdEntity> response, String requestPath) {
if (response.isSuccess()) {
AdEntity resp = response.getData();
LogUtil.e(TAG, "#结果#--data " + resp);
tv_result.setText("#200结果data##" + resp);
} else {
LogUtil.e(TAG, "#结果# " + response);
tv_result.setText("#结果#：" + response);
}
}
@Override
public void onError(ApiException ex, String requestPath) {
LogUtil.e(TAG, ex.toString());
Toast.makeText(MainActivity.this, ex.toString(), Toast.LENGTH_LONG).show();
tv_result.setText("#error#: " + ex);
}
}, ll);
}
传入4个参数： 请求的路径，参数，回调, 对话框接口。 对话框ILoading可不传
这种方式，不用自己解析，返回的结果就是解析好的实体
2-2. 返回json字符串
public void getStringResult() {
Map<String, String> maps = new HashMap<String, String>();
maps.put("seat_id", "1");
ILoading ll = new ILoading(this);
ll.setMessage("网络请求");
HttpRequestHelper.doPost(UrlEntity.GET_START_AD, maps, stringRespCallback, ll);
}
private StringRespCallback stringRespCallback = new StringRespCallback() {
@Override
public void onResponse(String response, String requestPath) {
switch (requestPath) {
case UrlEntity.GET_START_AD:
LogUtil.e(TAG, "#结果#：" + response);
tv_result.setText("#结果#--：" + response);
parseStringResp(response);
break;
default:
break;
}
}
@Override
public void onError(ApiException ex, String requestPath) {
LogUtil.e(TAG, ex.toString());
Toast.makeText(MainActivity.this, ex.toString(), Toast.LENGTH_LONG).show();
tv_result.setText("#error#: " + ex);
}
};
private void parseStringResp(String resp) {
try {
long start = System.currentTimeMillis();
AdObj obj = JsonManager.parseJson(resp, AdObj.class);
long end = System.currentTimeMillis();
LogUtil.e(TAG, " ##解析耗时##" + (end - start) + "##毫秒##" + (end - start) / 1000 + "##秒##");
if (obj != null) {
if (obj.isSuccess()) {
if (obj.getData() != null) {
}
} else {
Toast.makeText(MainActivity.this, obj.getMsg(), Toast.LENGTH_LONG).show();
}
}
} catch (JsonSyntaxException e) {
e.printStackTrace();
}
}
传入4个参数： 请求的路径，参数，回调, 对话框接口。 对话框ILoading可不传，回调StringRespCallback 继承RespCallback。
这种方式需自己解析json, 比较灵活。另外它有一个优点：在一个页面有多个请求的时候， 只要创建一个回调StringRespCallback ， 通过返回的请求路径requestPath去区分。 目前老工程就是这种场景， 所以很快就能切换到本框架。
3.底层几个关键类
HttpRequestHelper 适应相应的业务需求，做的包装，最终调RetrofitClient
RetrofitClient请求实现
RespObserver 网络返回的结果首先经过这里，在这做处理和转发 ， 这里最终会调请求传入的回调RespCallback
好了，这里只做简单的使用笔记，具体看源码
