断点续传的思路

Http 怎么支持断点续传的?

Http 1.1 协议中默认支持获取文件的部分内容,这其中主要是通过头部的两个参数:Range 和 Content Range 来实现的。客户端发请求时对应的是 Range ,服务器端响应时对应的是 Content-Range。

没有发生断开重传时响应码responsecode==200,

发生了断开重传时响应码responsecode==206

 

断点下载思路

  • step 1:判断检查本地是否有下载文件,若存在,则获取已下载的文件大小 downloadLength,若不存在,那么本地已下载文件的长度为 0
  • step 2:获取将要下载的文件总大小(HTTP 响应头部的 content-Length)
  • step 3:比对已下载文件大小和将要下载的文件总大小(contentLength),判断要下载的长度
  • step 4:再即将发起下载请求的 HTTP 头部中添加即将下载的文件大小范围(Range: bytes = downloadLength - contentLength)

 

用RandomAccessFile类中的可以移动到指定位置,从而开始在本地文件特定位置进行写操作的方法;

如果涉及到多线程,那就让这些线程各自去读取分配的文件;

/*** String 在执行AsyncTask时需要传入的参数,可用于在后台任务中使用。* Integer 后台任务执行时,如果需要在界面上显示当前的进度,则使用这里指定的泛型作为进度单位。* Integer 当任务执行完毕后,如果需要对结果进行返回,则使用这里指定的泛型作为返回值类型。*/
public class DownloadTask extends AsyncTask {public static final int TYPE_SUCCESS = 0;public static final int TYPE_FAILED = 1;public static final int TYPE_PAUSED = 2;public static final int TYPE_CANCELED = 3;private DownloadListener listener;private boolean isCanceled = false;private boolean isPaused = false;private int lastProgress;public DownloadTask(DownloadListener listener) {this.listener = listener;}/*** 这个方法中的所有代码都会在子线程中运行,我们应该在这里处理所有的耗时任务。** @param params* @return*/@Overrideprotected Integer doInBackground(String... params) {InputStream is = null;RandomAccessFile savedFile = null;File file = null;long downloadLength = 0;  //记录已经下载的文件长度//文件下载地址String downloadUrl = params[0];//下载文件的名称String fileName = downloadUrl.substring(downloadUrl.lastIndexOf("/"));//下载文件存放的目录String directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath();//创建一个文件file = new File(directory + fileName);if (file.exists()) {//如果文件存在的话,得到文件的大小downloadLength = file.length();}//得到下载内容的大小long contentLength = getContentLength(downloadUrl);if (contentLength == 0) {return TYPE_FAILED;} else if (contentLength == downloadLength) {//已下载字节和文件总字节相等,说明已经下载完成了return TYPE_SUCCESS;}OkHttpClient client = new OkHttpClient();/*** HTTP请求是有一个Header的,里面有个Range属性是定义下载区域的,它接收的值是一个区间范围,* 比如:Range:bytes=0-10000。这样我们就可以按照一定的规则,将一个大文件拆分为若干很小的部分,* 然后分批次的下载,每个小块下载完成之后,再合并到文件中;这样即使下载中断了,重新下载时,* 也可以通过文件的字节长度来判断下载的起始点,然后重启断点续传的过程,直到最后完成下载过程。*/Request request = new Request.Builder().addHeader("RANGE", "bytes=" + downloadLength + "-" + contentLength) //断点续传要用到的,指示下载的区间.url(downloadUrl).build();try {Response response = client.newCall(request).execute();if (response != null) {is = response.body().byteStream();savedFile = new RandomAccessFile(file, "rw");savedFile.seek(downloadLength);//跳过已经下载的字节byte[] b = new byte[1024];int total = 0;int len;while ((len = is.read(b)) != -1) {if (isCanceled) {return TYPE_CANCELED;} else if (isPaused) {return TYPE_PAUSED;} else {total += len;savedFile.write(b, 0, len);//计算已经下载的百分比int progress = (int) ((total + downloadLength) * 100 / contentLength);//注意:在doInBackground()中是不可以进行UI操作的,如果需要更新UI,比如说反馈当前任务的执行进度,//可以调用publishProgress()方法完成。publishProgress(progress);}}response.body().close();return TYPE_SUCCESS;}} catch (IOException e) {e.printStackTrace();} finally {try {if (is != null) {is.close();}if (savedFile != null) {savedFile.close();}if (isCanceled && file != null) {file.delete();}} catch (Exception e) {e.printStackTrace();}}return TYPE_FAILED;}/*** 当在后台任务中调用了publishProgress(Progress...)方法之后,onProgressUpdate()方法* 就会很快被调用,该方法中携带的参数就是在后台任务中传递过来的。在这个方法中可以对UI进行操作,利用参数中的数值就可以* 对界面进行相应的更新。** @param values*/@Overrideprotected void onProgressUpdate(Integer... values) {int progress = values[0];if (progress > lastProgress) {listener.onProgress(progress);lastProgress = progress;}}/*** 当后台任务执行完毕并通过Return语句进行返回时,这个方法就很快被调用。返回的数据会作为参数* 传递到此方法中,可以利用返回的数据来进行一些UI操作。** @param status*/@Overrideprotected void onPostExecute(Integer status) {switch (status) {case TYPE_SUCCESS:listener.onSuccess();break;case TYPE_FAILED:listener.onFailed();break;case TYPE_PAUSED:listener.onPaused();break;case TYPE_CANCELED:listener.onCanceled();break;default:break;}}public void pauseDownload() {isPaused = true;}public void cancelDownload() {isCanceled = true;}/*** 得到下载内容的完整大小** @param downloadUrl* @return*/private long getContentLength(String downloadUrl) {OkHttpClient client = new OkHttpClient();Request request = new Request.Builder().url(downloadUrl).build();try {Response response = client.newCall(request).execute();if (response != null && response.isSuccessful()) {long contentLength = response.body().contentLength();response.body().close();return contentLength;}} catch (IOException e) {e.printStackTrace();}return 0;}}

 

 

 

public class DownloadListener {/*** 通知当前的下载进度* @param progress*/void onProgress(int progress);/*** 通知下载成功*/void onSuccess();/*** 通知下载失败*/void onFailed();/*** 通知下载暂停*/void onPaused();/*** 通知下载取消事件*/void onCanceled();}

 

 


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部