Retrofit + OKHttp + RxJava 简单二次封装
1.在项目Module的build.gradle中添加依赖
compile 'com.code4a:retrofit-util:1.2.0'
2.创建RetrofitManager对象
RetrofitManager retrofitManager;
public Code4aApiImpl() {
retrofitManager = new RetrofitManager.Builder()
.setContext(context)
.setBaseUrl(SimpleApi.CODE4A_API)
.enableCache()
.setTimeoutSec(15)
.setTransferDataType(RetrofitManager.Builder.TransferDataType.GSON)
.setHttpHeaderMap(HttpUtil.getJsonHeaderMap())
.build();
}
3.Api简述
-
创建ApiService
public <S> S create(Class<S> clazz) -
订阅事件
public <T> Subscription doSubscribe(Observable<T> observable, Subscriber<T> subscriber)
4.eg
- http get请求获取字符串,响应在主线程中
void httpGetString(){
new RetrofitManager.Builder()
.setBaseUrl("http://www.code4a.com/")
.setTransferDataType(RetrofitManager.Builder.TransferDataType.STRING)
.build()
.getStringRequest("android", new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
});
}
- http get请求获取ResponseBody,响应在IO线程中,可进行下载等操作
void httpGetResponseBody(){
new RetrofitManager.Builder()
.setBaseUrl("http://www.code4a.com/")
.build()
.getResponseBodyRequest("android", new Subscriber<ResponseBody>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(ResponseBody body) {
}
});
}
-
自定义Service 进行json数据类型传输,自动转换bean对象
1.Service类
@GET("{type}/{size}/{page}") Observable<GankIoBean> getBeanRequest( @Path(value = "type", encoded = true) String type, @Path(value = "size", encoded = true) int size, @Path(value = "page", encoded = true) int page );2.封装转换
GankIoService getService() { return retrofitManager.create(GankIoService.class); } public Observable<GankIoBean> getResource(String type, int page, int size) { return getService().getBeanRequest(type, size, page); } public Subscription getResourceDoSubcribe(String type, int page, int size, Subscriber<GankIoBean> subscriber) { return retrofitManager.doSubscribe(getResource(type, page, size), subscriber); }3.获取结果
protected void loadData(String type, int page, int size) { unsubscribe(); subscription = getGankIoManager().getResourceDoSubcribe(type, page, size, new Subscriber<GankIoBean>() { @Override public void onCompleted() { onLoadDataCompleted(); } @Override public void onError(Throwable e) { onLoadDataError(); } @Override public void onNext(GankIoBean gankIoBean) { if (gankIoBean.isError()) { onLoadDataFailed(); } else { onLoadDataSuccess(gankIoBean.getResults()); } } });
详细用法可参看simpleapi
1.创建可进行https操作的RetrofitManager
RetrofitManager retrofitManager;
AndLinkUserNetImpl() {
retrofitManager = new RetrofitManager.Builder()
.setBaseUrl(AndLinkApi.ANDLINK_USER_ROOTURL)
.setTimeoutSec(15)
.setTransferDataType(RetrofitManager.Builder.TransferDataType.GSON)
.setHttpHeaderMap(HttpUtil.getJsonHeaderMap())
.setHttpType(RetrofitManager.Builder.HttpType.HTTPS)
.setSSLHelper(new SSLImpl())
.build();
// 使用自定义证书校验的https请求
// retrofitManager = new RetrofitManager.Builder()
// .setBaseUrl(AndLinkApi.ANDLINK_USER_ROOTURL)
// .setContext(context)
// .setTimeoutSec(15)
// .setTransferDataType(RetrofitManager.Builder.TransferDataType.GSON)
// .setHttpHeaderMap(HttpUtil.getJsonHeaderMap())
// .setHostnameVerifiers(AndLinkApi.HOSTURLS)
// .setAssetCertificateName(AndLinkApi.CERTIFICATE_NAME)
// .setHttpType(RetrofitManager.Builder.HttpType.HTTPS)
// .build();
}
2.请求接口定义
@POST(AndLinkApi.ANDLINK_PLATFORMURL + "user/login")
Observable<BaseResponseBean<ResponseLoginUserBean>> aluLogin(@Body RequestLoginUserBean requestLoginUserBean);
3.请求封装和转换
@Override
public Subscription andLinkUser_Login(RequestLoginUserBean requestLoginUserBean, RxSubscriber<ResponseLoginUserBean> rxSubscriber) {
return createUserService()
.aluLogin(requestLoginUserBean)
.compose(RxHelper.<ResponseLoginUserBean>handleResult())
.subscribe(rxSubscriber);
}