*Android(安卓)多线程下载仿下载助手（改进版）

首先声明一点：这里的多线程下载并不是指的多个线程下载一个文件，而是每个线程负责一个文件。真正的多线程希望后面能给大家带来。

------------- 欢迎爱学习的小伙伴加群 -------------

-------------android交流群：230274309-------------

-------------一起分享，一起进步！需要你们--------------

-------------- 期待各位爱学习的小伙伴们的到来--------------

本文是接着前面http://blog.csdn.net/u011733020/article/details/47016715继续写的。感兴趣的小伙伴可以看前面的。

界面效果

2015/7/31改进

2015/7/31 日先说这次改进了两点。

第一点，前面说过项目只适合学习，作为商用的话，效率不高，是因为当时点击暂停，在点击下载继续下载时候，如果文件前面下载部分较大，会比较慢，因为 java 的 inputstream 的 skip(long size) 跳过字节这个方法并不能按照你想要跳过的字节，而是跳过的往往是比较小的，所以要不断遍历，直到返回满足条件，比较耗时。打个比方，文件大小 30M ，你下载了20M，你点了暂停然后继续点下载，就要跳过这20M，但是你用skip 方法可能每次跳过 4096 字节，这样要跳过20M 的时间就会很长。这样应该好理解。

第二点，原来项目中，你这一次下载没有完成，下次在下载是删除掉原来的从新下载，这次改成继续上次的地方接着下载。

吐槽下，关于下载，我最近一周一直在看开源的download, 但是无奈水平有限，收获甚微，往往是看到最后脑袋短路。

这次改的方式比较简单，只改动了项目中 DownloadManager 这个类。在来看下 DownloadManager 这个类的run 方法，

<span style="font-family:SimHei;font-size:14px;">@Overridepublic void run() {info.setDownloadState(STATE_DOWNLOADING);// 先改变下载状态notifyDownloadStateChanged(info);File file = new File(info.getPath());// 获取下载文件HttpResult httpResult = null;InputStream stream = null;if (info.getCurrentSize() == 0 || !file.exists()|| file.length() != info.getCurrentSize()) {// 如果文件不存在，或者进度为0，或者进度和文件长度不相符，就需要重新下载info.setCurrentSize(0);file.delete();}httpResult = HttpHelper.download(info.getUrl());if (httpResult == null|| (stream = httpResult.getInputStream()) == null) {info.setDownloadState(STATE_ERROR);// 没有下载内容返回，修改为错误状态notifyDownloadStateChanged(info);} else {try {skipBytesFromStream(stream, info.getCurrentSize());} catch (Exception e1) {e1.printStackTrace();}FileOutputStream fos = null;try {fos = new FileOutputStream(file, true);int count = -1;byte[] buffer = new byte[1024];while (((count = stream.read(buffer)) != -1)&& info.getDownloadState() == STATE_DOWNLOADING) {// 每次读取到数据后，都需要判断是否为下载状态，如果不是，下载需要终止，如果是，则刷新进度fos.write(buffer, 0, count);fos.flush();info.setCurrentSize(info.getCurrentSize() + count);notifyDownloadProgressed(info);// 刷新进度}} catch (Exception e) {info.setDownloadState(STATE_ERROR);notifyDownloadStateChanged(info);info.setCurrentSize(0);file.delete();} finally {IOUtils.close(fos);if (httpResult != null) {httpResult.close();}}// 判断进度是否和app总长度相等if (info.getCurrentSize() == info.getAppSize()) {info.setDownloadState(STATE_DOWNLOADED);notifyDownloadStateChanged(info);} else if (info.getDownloadState() == STATE_PAUSED) {// 判断状态notifyDownloadStateChanged(info);} else {info.setDownloadState(STATE_ERROR);notifyDownloadStateChanged(info);info.setCurrentSize(0);// 错误状态需要删除文件file.delete();}}mTaskMap.remove(info.getId());}</span>

从服务器返回的数据流 stream 最终是在 HttpHelper 这个类中

<span style="font-family:SimHei;font-size:14px;">HttpResponse response = httpClient.execute(requestBase, httpContext);//访问网络</span>

通过 httpclient 去联网请求的。

我没有试过 httpclient addHeader("Range", "bytes=" + begin + "-" + end); 可不可以进行继续下载。

而是改成了通过 httpurlconnection 去请求数据

现在的run（）方法是这样的。

<span style="font-family:SimHei;font-size:14px;">@Overridepublic void run() {info.setDownloadState(STATE_DOWNLOADING);// 先改变下载状态notifyDownloadStateChanged(info);File file = new File(info.getPath());// 获取下载文件/**********************************************************///try {try {URL url = new URL(info.getUrl());HttpURLConnection conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod("GET");conn.setConnectTimeout(30000);conn.setReadTimeout(30000);if (!file.exists()) {info.setCurrentSize(0);file.delete();} else if (file.length() > info.getAppSize()) {info.setCurrentSize(0);file.delete();} else if (file.length() == info.getAppSize()) {} else if (file.length() < info.getAppSize()) {info.setCurrentSize(file.length());}if (info.getCurrentSize() == 0 || !file.exists() || file.length() != info.getCurrentSize()) {// 如果文件不存在，或者进度为0，或者进度和文件长度不相符，就需要重新下载info.setCurrentSize(0);file.delete();} else if (file.length() == info.getCurrentSize() && file.length() < info.getAppSize()) {conn.setRequestProperty("Range", "bytes=" + info.getCurrentSize() + "-" + info.getAppSize());}int code = conn.getResponseCode();RandomAccessFile raf = new RandomAccessFile(file, "rw");InputStream is = conn.getInputStream();byte[] buffer = new byte[1024 * 8];int len = -1;int total = 0;// 当前线程下载的总的数据的长度if (code == 200) {} else if (code == 206) {raf.seek(file.length());}while (((len = is.read(buffer)) != -1) && (info.getDownloadState() == STATE_DOWNLOADING)) { // 下载数据的过程。raf.write(buffer, 0, len);total += len;// 需要记录当前的数据。info.setCurrentSize(info.getCurrentSize() + len);notifyDownloadProgressed(info);// 刷新进度}is.close();raf.close();} catch (MalformedURLException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (ProtocolException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (FileNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}/*************************对于各种情况，需要删除下载任务，从新下载的 请自己改动代码*****************************/// 判断进度是否和app总长度相等//} catch (Exception e) {//System.out.println(e.toString());//info.setDownloadState(STATE_ERROR);//info.setCurrentSize(0);//file.delete();//e.printStackTrace();//}if (info.getCurrentSize() == info.getAppSize()) {info.setDownloadState(STATE_DOWNLOADED);notifyDownloadStateChanged(info);} else if (info.getDownloadState() == STATE_PAUSED) {// 判断状态notifyDownloadStateChanged(info);} else {info.setDownloadState(STATE_ERROR);notifyDownloadStateChanged(info);info.setCurrentSize(0);// 错误状态需要删除文件file.delete();}/**********************************************************/mTaskMap.remove(info.getId());}</span>

先判断文件存不存在，以及大小是否满足条件, 在这里做判断

<span style="font-family:SimHei;font-size:14px;">if (info.getCurrentSize() == 0 || !file.exists() || file.length() != info.getCurrentSize()) {// 如果文件不存在，或者进度为0，或者进度和文件长度不相符，就需要重新下载info.setCurrentSize(0);file.delete();} else if (file.length() == info.getCurrentSize() && file.length() < info.getAppSize()) {     conn.setRequestProperty("Range", "bytes=" + info.getCurrentSize() + "-" + info.getAppSize());  }</span>

如果文件当前大小为0，或者文件不存在，或者长度不等于当前长度，则重新下载，否则设置 Range

下面判断 code 正常情况下code =200 表示成功，如果设置了Range 那么 code 返回 206 表示正常。这个时候我们通过RandomAccessFile

RandomAccessFile 这个类实现了RandomAccessFile implements DataInput, DataOutput，就是一个既可以读也可以写的类。

RandomAccessFile 这个类来处理跳过多少字节，前面我说过 inpuStream.skeep() 方法不准确，但是 RandomAccessFile 这个类是可以的。

<span style="font-family:SimHei;font-size:14px;">RandomAccessFile raf = new RandomAccessFile(file, "rw");InputStream is = conn.getInputStream();byte[] buffer = new byte[1024 * 8];int len = -1;int total = 0;// 当前线程下载的总的数据的长度if (code == 200) {} else if (code == 206) {raf.seek(file.length());}</span>

通过 seek 方法跳过这些字节。

然后

<span style="font-family:SimHei;font-size:14px;">while (((len = is.read(buffer)) != -1) && (info.getDownloadState() == STATE_DOWNLOADING)) { // 下载数据的过程。raf.write(buffer, 0, len);total += len;// 需要记录当前的数据。info.setCurrentSize(info.getCurrentSize() + len);notifyDownloadProgressed(info);// 刷新进度}is.close();raf.close();</span>

很普通的代码，把数据写出去。不断刷新当前进度，最后关闭流。

这样就可以保证快速的暂停继续下载，并且本次下载没有完成，点了暂停，下次进应用，继续下载的时候会接着上一次下载，但是断网，或者你自己把网关掉，下次在恢复网络，或者在点下载，我并没有处理，有需要的就自己处理下吧，应该是捕获异常 seckouttimeException，然后保存数据。自己动手试下就知道了。

本次就到这里。关于多个线程分段下载一个文件，等我有时间在整理。

共勉

界面效果

2015/7/31改进

更多相关文章

随机推荐

*Android(安卓)多线程下载 仿下载助手（改进版）

界面效果

2015/7/31改进

更多相关文章

随机推荐

*Android(安卓)多线程下载仿下载助手（改进版）