Android实现网络多线程文件下载

概述实现原理(1)首先获得下载文件的长度，然后设置本地文件的长度。(2)根据文件长度和线程数计算每条线程下载的数据长度和下载位置。

实现原理

(1)首先获得下载文件的长度，然后设置本地文件的长度。

(2)根据文件长度和线程数计算每条线程下载的数据长度和下载位置。

如：文件的长度为6M，线程数为3，那么，每条线程下载的数据长度为2M，每条线程开始下载的位置如下图所示：

（网上找的图）

例如10M大小，使用3个线程来下载，

线程下载的数据长度 (10%3 == 0 ？ 10/3:10/3+1),第1，2个线程下载长度是4M，第三个线程下载长度为2M

下载开始位置：线程ID*每条线程下载的数据长度 = ?

下载结束位置：（线程ID+1）*每条线程下载的数据长度-1=?

之前练习时的一个demo，不多说了，直接上代码吧，有关断点续传，需要使用数据库，不再加了，网上有很多成熟的项目可以直接用。

实例

MainApp：

package com.amos.app; import java.io.file; import java.io.IOException; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; import com.amos.download.R; import androID.annotation.Suppresslint; import androID.app.Activity; import androID.os.Bundle; import androID.os.Environment; import androID.os.Handler; import androID.os.Message; import androID.util.Log; import androID.vIEw.VIEw; import androID.vIEw.VIEw.OnClickListener; import androID.Widget.Progressbar; import androID.Widget.TextVIEw; import androID.Widget.Toast; /** * @author yangxiaolong * @2014-5-6 */ public class MainApp extends Activity implements OnClickListener { private static final String TAG = MainApp.class.getSimplename(); /** 显示下载进度TextVIEw */ private TextVIEw mMessageVIEw; /** 显示下载进度Progressbar */ private Progressbar mProgressbar; @OverrIDe protected voID onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentVIEw(R.layout.progress_activity); findVIEwByID(R.ID.download_btn).setonClickListener(this); mMessageVIEw = (TextVIEw) findVIEwByID(R.ID.download_message); mProgressbar = (Progressbar) findVIEwByID(R.ID.download_progress); } @OverrIDe public voID onClick(VIEw v) { if (v.getID() == R.ID.download_btn) { dodownload(); } } /** * 使用Handler更新UI界面信息 */ @Suppresslint("HandlerLeak") Handler mHandler = new Handler() { @OverrIDe public voID handleMessage(Message msg) { mProgressbar.setProgress(msg.getData().getInt("size")); float temp = (float) mProgressbar.getProgress() / (float) mProgressbar.getMax(); int progress = (int) (temp * 100); if (progress == 100) { Toast.makeText(MainApp.this,"下载完成！",Toast.LENGTH_LONG).show(); } mMessageVIEw.setText("下载进度:" + progress + " %"); } }; /** * 下载准备工作，获取SD卡路径、开启线程 */ private voID dodownload() { // 获取SD卡路径 String path = Environment.getExternalStorageDirectory() + "/amosdownload/"; file file = new file(path); // 如果SD卡目录不存在创建 if (!file.exists()) { file.mkdir(); } // 设置progressbar初始化 mProgressbar.setProgress(0); // 简单起见，我先把URL和文件名称写死，其实这些都可以通过httpheader获取到 String downloadUrl = "http://gdown.baIDu.com/data/wisegame/91319a5a1dfae322/baIDu_16785426.apk"; String filename = "baIDu_16785426.apk"; int threadNum = 5; String filepath = path + filename; Log.d(TAG,"download file path:" + filepath); downloadTask task = new downloadTask(downloadUrl,threadNum,filepath); task.start(); } /** * 多线程文件下载 * * @author yangxiaolong * @2014-8-7 */ class downloadTask extends Thread { private String downloadUrl;// 下载链接地址 private int threadNum;// 开启的线程数 private String filePath;// 保存文件路径地址 private int blockSize;// 每一个线程的下载量 public downloadTask(String downloadUrl,int threadNum,String fileptah) { this.downloadUrl = downloadUrl; this.threadNum = threadNum; this.filePath = fileptah; } @OverrIDe public voID run() { fileDownloadThread[] threads = new fileDownloadThread[threadNum]; try { URL url = new URL(downloadUrl); Log.d(TAG,"download file http path:" + downloadUrl); URLConnection conn = url.openConnection(); // 读取下载文件总大小 int fileSize = conn.getContentLength(); if (fileSize <= 0) { System.out.println("读取文件失败"); return; } // 设置Progressbar最大的长度为文件Size mProgressbar.setMax(fileSize); // 计算每条线程下载的数据长度 blockSize = (fileSize % threadNum) == 0 ? fileSize / threadNum : fileSize / threadNum + 1; Log.d(TAG,"fileSize:" + fileSize + " blockSize:"); file file = new file(filePath); for (int i = 0; i < threads.length; i++) { // 启动线程，分别下载每个线程需要下载的部分 threads[i] = new fileDownloadThread(url,file,blockSize,(i + 1)); threads[i].setname("Thread:" + i); threads[i].start(); } boolean isfinished = false; int downloadedAllSize = 0; while (!isfinished) { isfinished = true; // 当前所有线程下载总量 downloadedAllSize = 0; for (int i = 0; i < threads.length; i++) { downloadedAllSize += threads[i].getDownloadLength(); if (!threads[i].isCompleted()) { isfinished = false; } } // 通知handler去更新视图组件 Message msg = new Message(); msg.getData().putInt("size",downloadedAllSize); mHandler.sendMessage(msg); // Log.d(TAG,"current downloadSize:" + downloadedAllSize); Thread.sleep(1000);// 休息1秒后再读取下载进度 } Log.d(TAG," all of downloadSize:" + downloadedAllSize); } catch (MalformedURLException e) { e.printstacktrace(); } catch (IOException e) { e.printstacktrace(); } catch (InterruptedException e) { e.printstacktrace(); } } } }

fileDownloadThread:

package com.amos.app; import java.io.BufferedinputStream; import java.io.file; import java.io.IOException; import java.io.RandomAccessfile; import java.net.URL; import java.net.URLConnection; import androID.util.Log; /** * 文件下载类 * * @author yangxiaolong * @2014-5-6 */ public class fileDownloadThread extends Thread { private static final String TAG = fileDownloadThread.class.getSimplename(); /** 当前下载是否完成 */ private boolean isCompleted = false; /** 当前下载文件长度 */ private int downloadLength = 0; /** 文件保存路径 */ private file file; /** 文件下载路径 */ private URL downloadUrl; /** 当前下载线程ID */ private int threadID; /** 线程下载数据长度 */ private int blockSize; /** * * @param url:文件下载地址 * @param file:文件保存路径 * @param blocksize:下载数据长度 * @param threadID:线程ID */ public fileDownloadThread(URL downloadUrl,file file,int blocksize,int threadID) { this.downloadUrl = downloadUrl; this.file = file; this.threadID = threadID; this.blockSize = blocksize; } @OverrIDe public voID run() { BufferedinputStream bis = null; RandomAccessfile raf = null; try { URLConnection conn = downloadUrl.openConnection(); conn.setAllowUserInteraction(true); int startPos = blockSize * (threadID - 1);//开始位置 int endPos = blockSize * threadID - 1;//结束位置 //设置当前线程下载的起点、终点 conn.setRequestProperty("Range","bytes=" + startPos + "-" + endPos); System.out.println(Thread.currentThread().getname() + " bytes=" + startPos + "-" + endPos); byte[] buffer = new byte[1024]; bis = new BufferedinputStream(conn.getinputStream()); raf = new RandomAccessfile(file,"rwd"); raf.seek(startPos); int len; while ((len = bis.read(buffer,1024)) != -1) { raf.write(buffer,len); downloadLength += len; } isCompleted = true; Log.d(TAG,"current thread task has finished,all size:" + downloadLength); } catch (IOException e) { e.printstacktrace(); } finally { if (bis != null) { try { bis.close(); } catch (IOException e) { e.printstacktrace(); } } if (raf != null) { try { raf.close(); } catch (IOException e) { e.printstacktrace(); } } } } /** * 线程文件是否下载完毕 */ public boolean isCompleted() { return isCompleted; } /** * 线程下载文件长度 */ public int getDownloadLength() { return downloadLength; } }

效果图：

Log控制台：

可以看到文件总大小、我们创建的5个线程每个负责下载的区间

SD卡：

关于AndroID实现网络多线程文件下载小编就给大家介绍这么多，希望对大家有所帮助！同时也非常感谢大家一直以来对编程小技巧网站的支持！

总结

以上是内存溢出为你收集整理的Android实现网络多线程文件下载全部内容，希望文章能够帮你解决Android实现网络多线程文件下载所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。