一、概述
Retrofit+RxJava是當前最流行的Android網絡交互解決方案服鹅。OkRetrofit是一個基于Retrofit2+RxJava2封裝的文件下載和網絡請求庫兔院，
其中文件下載部分參考了RxDownload，去掉了RxPermission相關的代碼，網絡請求部分做了適當的抽象和封裝几苍，方便使用的同時也不影響相關部分的定制。
1.1 文件下載
- 智能判斷服務器是否支持斷點續(xù)傳并適配相應下載方式陈哑；
- 智能判斷同一地址對應的文件在服務端是否有改變并重新下載妻坝；
- 支持多線程下載，可設置下載線程數惊窖；
- 支持下載狀態(tài)刽宪、下載進度監(jiān)聽；
- 支持在Service中下載文件界酒，內置DownloadService圣拄；
1.2 網絡請求
- 內置
BaseRetrofit,提供了抽象方法initOkHttp供上層實現，可在此方法中配置日志毁欣、緩存庇谆、超時等岳掐； - 內置服務器統(tǒng)一返回
HttpResponse和請求異常HttpException； - 內置統(tǒng)一線程處理和統(tǒng)一返回結果轉換方法饭耳；
二串述、使用
2.1 Gradle
OkRetrofit已上傳到jcenter，在gradle中直接引用即可寞肖。
dependencies {
compile 'com.hengda.zwf:OkRetrofit:0.0.1'
}
2.2 文件下載
RxDownload.getInstance().context(MainActivity.this)
.maxThread(4).maxRetryCount(3)
.download(url, saveName, savePath)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnSubscribe(disposable -> {
compositeDisposable.add(disposable);
tvDownloadStatus.setText("下載地址：" + url + "\n");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
tvDownloadStatus.setText(tvDownloadStatus.getText() + "\n開始下載：" + sdf.format(new Date()));
})
.doOnNext(downloadStatus -> {
//此處更新下載進度
String formatStatusString = downloadStatus.getFormatStatusString();
tvDownloadPrg.setText("下載進度：" + formatStatusString);
})
.doOnError(throwable -> {
//此處處理下載異常
tvDownloadStatus.setText("下載失敗:" + throwable.getMessage());
})
.doOnComplete(() -> {
//下載完成纲酗，解壓或安裝
SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
tvDownloadPrg.setText(tvDownloadPrg.getText() + "\n下載完成：" + sdf.format(new Date()));
File file = new File(savePath, saveName);
file.delete();
})
.subscribe();
2.3 網絡請求
2.3.1 新建聲明網絡請求方法的接口
public interface HttpApis {
@GET("index.php?g=mapi&m=appdatas&a=datas")
Observable<HttpResponse<DataBean>> loadDatas();
}
2.3.2 繼承BaseRetrofit，實現initOkHttp方法新蟆，在此方法中可配置超時觅赊、日志、緩存等琼稻。
public class RetrofitHelper extends BaseRetrofit {
private static HttpApis httpApis = null;
private volatile static RetrofitHelper instance;
/**
* 單例模式
*
* @author 祝文飛（Tailyou）
* @time 2016/11/12 11:31
*/
private RetrofitHelper() {
super();
httpApis = getApiService(setupBaseHttpUrl(), HttpApis.class);
}
/**
* 組裝網絡請求基地址
*
* @author 祝文飛（Tailyou）
* @time 2016/11/12 11:38
*/
public static String setupBaseHttpUrl() {
return "http://" + HdAppConfig.getDefaultIpPort() + "/hnbwy/";
}
/**
* 獲取實例-單例
*
* @author 祝文飛（Tailyou）
* @time 2016/11/12 11:32
*/
public static RetrofitHelper getInstance() {
if (instance == null) {
synchronized (RetrofitHelper.class) {
if (instance == null) {
instance = new RetrofitHelper();
}
}
}
return instance;
}
/**
* 在此配置超時吮螺，緩存，日志等
*
* @author 祝文飛（Tailyou）
* @time 2017/5/10 11:10
*/
@Override
public OkHttpClient initOkHttp() {
OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.connectTimeout(10, TimeUnit.SECONDS);
builder.writeTimeout(20, TimeUnit.SECONDS);
builder.readTimeout(20, TimeUnit.SECONDS);
builder.retryOnConnectionFailure(true);
return builder.build();
}
/**
* 獲取數據
*
* @author 祝文飛（Tailyou）
* @time 2017/1/3 11:57
*/
public Observable<DataBean> loadDatas() {
return httpApis.loadDatas().compose(rxSchedulerHelper()).compose(handleResult());
}
}
2.3.3 使用
RetrofitHelper.getInstance()
.loadDatas()
.doOnSubscribe(disposable -> compositeDisposable.add(disposable))
.doOnNext(dataBean -> Toast.makeText(MainActivity.this, new Gson().toJson(dataBean), Toast.LENGTH_SHORT).show())
.doOnError(throwable -> Logger.e(throwable.getMessage()))
.subscribe();
詳細用法參見Demo帕翻，地址：https://github.com/Tailyou/OkRetrofit
