okhttp3下载文件检测进度与断点续传

之前有用过retrofit来做下载的功能，虽然retrofit基于okhttp，但是这还是有点不同。
我是在做更新功能的时候用到这个，具体的操作可能不会说太多，因为网上能找到很多基本的操作，我就说下一些流程和BUG，不管是okhttp还是retrofit都适用。

一.下载文件

1.下载操作

下载文件其实我感觉并不像上传那么复杂，就按照拉取文本文件一样弄就行。
这是我普通的用okhttp的get请求

 Request request = new Request.Builder() .url(murl) .build(); Call call = okHttpClient.newCall(request); call.enqueue(callback); 

下载文件的操作其实差不多

public Call download(String url, final DownloadListener downloadListener, final long startsPoint, Callback callback){ Request request = new Request.Builder() .url(url) .header("RANGE", "bytes=" + startsPoint + "-")//断点续传 .build(); // 重写ResponseBody监听请求 Interceptor interceptor = new Interceptor() { @Override public Response intercept(Chain chain) throws IOException { Response originalResponse = chain.proceed(chain.request()); return originalResponse.newBuilder() .body(new DownloadResponseBody(originalResponse, startsPoint, downloadListener)) .build(); } }; OkHttpClient.Builder dlOkhttp = new OkHttpClient.Builder() .addNetworkInterceptor(interceptor); // 绕开证书 try { setSSL(dlOkhttp); } catch (Exception e) { e.printStackTrace(); } // 发起请求 Call call = dlOkhttp.build().newCall(request); call.enqueue(callback); return call; } 

注释讲得也比较请求，要重写ResponseBody是因为要监听下载进度，网上有很多人的写法是在onResponse的回调中读写字节到本地时监听进度，我建议是重写ResponseBody来监听下载进度，因为好像写在onResponse会有什么问题我忘记了，就算没问题，自定义ResponseBody也会显得更灵活。

2.自定义的ResponseBody

public class DownloadResponseBody extends ResponseBody{ private Response originalResponse; private DownloadListener downloadListener; private long oldPoint = 0; public DownloadResponseBody(Response originalResponse, long startsPoint, DownloadListener downloadListener){ this.originalResponse = originalResponse; this.downloadListener = downloadListener; this.oldPoint = startsPoint; } @Override public MediaType contentType() { return originalResponse.body().contentType(); } @Override public long contentLength() { return originalResponse.body().contentLength(); } @Override public BufferedSource source() { return Okio.buffer(new ForwardingSource(originalResponse.body().source()) { private long bytesReaded = 0; @Override public long read(Buffer sink, long byteCount) throws IOException { long bytesRead = super.read(sink, byteCount); bytesReaded += bytesRead == -1 ? 0 : bytesRead; if (downloadListener != null) { downloadListener.loading((int) ((bytesReaded+oldPoint)/(1024))); } return bytesRead; } }); } } 

主要就是要重写这个source方法来实现监听，代码也不难，其实不用多说什么。

3.定义请求中的回调

最好是用一个接口来定义在下载过程中的行为，接口的好处不用多说

public interface DownloadListener { /** * 开始下载 */ void start(long max); /** * 正在下载 */ void loading(int progress); /** * 下载完成 */ void complete(String path); /** * 请求失败 */ void fail(int code, String message); /** * 下载过程中失败 */ void loadfail(String message); } 

我这里定义了两种失败，主要是这边要根据请求网络的失败和读写过程的失败写不同的逻辑，如果没有特定的需求，这里只定义一个失败的回调也是可以的。

二.下载的文件保存到本地

okhttp中是写在onResponse方法中进行io操作，retrofit可以写在onNext中

 @Override public void onResponse(Call call, Response response) throws IOException { long length = response.body().contentLength(); if (length == 0){ // 说明文件已经下载完，直接跳转安装就好 downloadListener.complete(String.valueOf(getFile().getAbsoluteFile())); return; } downloadListener.start(length+startsPoint); // 保存文件到本地 InputStream is = null; RandomAccessFile randomAccessFile = null; BufferedInputStream bis = null; byte[] buff = new byte[2048]; int len = 0; try { is = response.body().byteStream(); bis =new BufferedInputStream(is); File file = getFile(); // 随机访问文件，可以指定断点续传的起始位置 randomAccessFile = new RandomAccessFile(file, "rwd"); randomAccessFile.seek (startsPoint); while ((len = bis.read(buff)) != -1) { randomAccessFile.write(buff, 0, len); } // 下载完成 downloadListener.complete(String.valueOf(file.getAbsoluteFile())); } catch (Exception e) { e.printStackTrace(); downloadListener.loadfail(e.getMessage()); } finally { try { if (is != null) { is.close(); } if (bis != null){ bis.close(); } if (randomAccessFile != null) { randomAccessFile.close(); } } catch (Exception e) { e.printStackTrace(); } } } }); private File getFile() { String root = Environment.getExternalStorageDirectory().getPath(); File file = new File(root,"updateDemo.apk"); return file; } private long getFileStart(){ String root = Environment.getExternalStorageDirectory().getPath(); File file = new File(root,"updateDemo.apk"); return file.length(); } 

因为我们之前在请求时写了

这里先获取报文的长度，如果长度为0，说明在我门本地已经下载好文件了，这里就不用下载了，直接跳转到安装。 这个主要是对断点续传的一个判断，你想想，如果我都已经下载完文件了，那我有什么必要再去开启io流。
这里还要注意一下，获取文件长度用file.length()而不用fis.available()是因为网上有个朋友测试过用fis.available()如果数据过大的话会出问题。

downloadListener.start(length+startsPoint);是我在开始读写前要先给ProgressBar设最大值。
读写时用到RandomAccessFile，这个主要是能随时读写，做的就是断点续传的操作。其实断点续传主要就三句代码

.header("RANGE", "bytes=" + startsPoint + "-") randomAccessFile = new RandomAccessFile(file, "rwd"); randomAccessFile.seek (startsPoint); 

后面就没有什么了，就是普通的io操作。

三.安装应用

下载完成后跳转到安装页面，需要做一个7.0的判断

 private void installApk(String path){ try { Intent intent = new Intent(Intent.ACTION_VIEW); File file = new File(path); if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) { intent.setFlags(Intent.FLAG_GRANT_READ_URI_PERMISSION); String authority = "com.example.kylin.mindabs" + ".fileProvider"; Uri fileUri = FileProvider.getUriForFile(getActivity().getApplicationContext(), authority, file); intent.setDataAndType(fileUri, "application/vnd.android.package-archive"); } else { intent.setDataAndType(Uri.fromFile(file),"application/vnd.android.package-archive"); intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK); } this.startActivityForResult(intent, 0); }catch (Exception e){ // todo 安装失败的操作 } } 

配置在清单中

 <provider tools:replace="android:authorities" android:name="android.support.v4.content.FileProvider" android:authorities="com.example.kylin.mindabs.fileProvider" android:grantUriPermissions="true" android:exported="false"> <meta-data tools:replace="android:resource" android:name="android.support.FILE_PROVIDER_PATHS" android:resource="@xml/file_paths" /> </provider> 

定义一个xml文件

<paths> <external-path path="Android/data/com.example.kylin.mindabs/" name="files_root" /> <external-path path="." name="external_storage_root" /> </paths> 

还有就是很多人网上写的跳转是用startActivity，我建议用startActivityForResult，这样可以拿到安装页面解析时的回到，方便之后做解析失败之类的。

 @Override public void onActivityResult(int requestCode, int resultCode, Intent data) { super.onActivityResult(requestCode, resultCode, data); if(requestCode == 0) { ...... } } 

我这里之前调试的时候打印成功和失败的回调

（1）成功

看到resultCode为0，data为空。注意，就算你不安装应用点取消，只要是能识别这个包出来，都是算解析成功，那么什么时候是失败的呢，比如安装包损坏这些才会回调失败的情况。
（2）失败

我自己模拟了一个失败的情况，这种情况它会直接提示你安装包解析失败。

四.开发中遇到的问题

1.断点续传的细节

在使用

.header("RANGE", "bytes=" + startsPoint + "-") 

之后，其实就是从文件的startsPoint 字节开始去下载，startsPoint 是我获取的当前本地文件的大小，这本来是没啥问题的，但是在apk已经下载完成的情况下startsPoint 就是整个文件的长度，按理说这里这样操作应该会让response.body().contentLength()等于0，而实际上我在调试的时候没有崩溃，但是response.body().contentLength()莫名其妙的等于229，我认真看日记才发现请求时报416错误，就是越界了。为了解决这个文件，我在拿到断点的时候会做一个-1的操作

final long startsPoint = getFileStart() > 0 ? getFileStart()-1 : getFileStart(); 

2.流程问题

其实更新的知识点就那两三个，但是对于流程来说需要严谨些，说得直白些，尽量有条能走通的路，所以我的代码里大量加了try-catch

3.请求放在service

请求为什么要放在service中呢，其实是一个生命周期的问题，如果请求是在activity中发起的，关闭activity之后其实activity还不会结束，他会被请求影响生命周期，所以需要再service中请求。而如果你不是在activity中请求的话，比如你在弹框中请求，只要在弹框消失的时候取消请求就行，这种情况放不放在service里面做请求我觉得就无所谓了。