详解Android中的多线程断点下载

发布时间 - 2026-01-10 21:57:04    点击率:

首先来看一下多线程下载的原理。多线程下载就是将同一个网络上的原始文件根据线程个数分成均等份,然后每个单独的线程下载对应的一部分,然后再将下载好的文件按照原始文件的顺序“拼接”起来就构

成了完整的文件了。这样就大大提高了文件的下载效率。对于文件下载来说,多线程下载是必须要考虑的环节。

多线程下载大致可分为以下几个步骤:

一.获取服务器上的目标文件的大小

显然这一步是需要先访问一下网络,只需要获取到目标文件的总大小即可。目的是为了计算每个线程应该分配的下载任务。

二. 在本地创建一个跟原始文件同样大小的文件

在本地可以通过RandomAccessFile 创建一个跟目标文件同样大小的文件,该api 支持文件任意位置的读写操作。这样就给多线程下载提供了方便,每个线程只需在指定起始和结束脚标范围内写数据即可。

三.计算每个线程下载的起始位置和结束位置

我们可以把原始文件当成一个字节数组,每个线程只下载该“数组”的指定起始位置和指定结束位置之间的部分。在第一步中我们已经知道了“数组”的总长度。因此只要再知道总共开启的线程的个数就好计算每个线程要下载的范围了。每个线程需要下载的字节个数(blockSize)=总字节数(totalSize)/线程数(threadCount)。       假设给线程按照0,1,2,3...n 的方式依次进行编号,那么第n 个线程下载文件的范围为:

起始脚标startIndex=n*blockSize。

结束脚标endIndex=(n-1)*blockSize-1。

考虑到totalSize/threadCount 不一定能整除,因此对已最后一个线程应该特殊处理,最后一个线程的起始脚标计算公式不变,但是结束脚标为endIndex=totalSize-1即可。

四.开启多个子线程开始下载

在子线程中实现读流操作,将conn.getInputStream()读到RandomAccessFile中。

五.记录下载进度

为每一个单独的线程创建一个临时文件,用于记录该线程下载的进度。对于单独的一个线程,每下载一部分数据就在本地文件中记录下当前下载的字节数。这样子如果下载任务异常终止了,那么下次重新开始下载时就可以接着上次的进度下载。

六. 删除临时文件

当多个线程都下载完成之后,最后一个下载完的线程将所有的临时文件删除。

Android有界面可以跟用户进行良好的交互,在界面上让用户输入原文件地址、线程个数,然后点击确定开始下载。为了让用户可以清晰的看到每个线程下载的进度根据线程个数动态的生成等量的进度条(ProgressBar)。ProgressBar 是一个进度条控件,用于显示一项任务的完成进度。其有两种样式,一种是圆形的,该种样式是系统默认的,由于无法显示具体的进度值,适合用于不确定要等待多久的情形下;另一种是长条形的,此类进度条有两种颜色,高亮颜色代表任务完成的总进度。对于我们下载任务来说,由于总任务(要下载的字节数)是明确的,当前已经完成的任务(已经下载的字节数)也是明确的,因此特别适合使用后者。由于在我们的需求里ProgressBar 是需要根据线程的个数动态添加的,而且要求是长条形的。因此可以事先在布局文件中编写好ProgressBar 的样式。当需要用到的时候再将该布局填充起来。ProgressBar 的max 属性代表其最大刻度值,progress 属性代表当前进度值。使用方法如下:

ProgressBar.setMax(int max);设置最大刻度值。

ProgressBar.setProgress(int progress);设置当前进度值。

给ProgressBar 设置最大刻度值和修改进度值可以在子线程中操作的,其内部已经特殊处理过了,因此不需要再通过handler发送Message 让主线程修改进度。

下面就给出我们自己写的安卓环境下的多线程。

多线程下载界面布局如下,三个进度条分别表示三个子线程的下载进度。

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
 xmlns:tools="http://schemas.android.com/tools"
 android:layout_width="match_parent"
 android:layout_height="match_parent"
 android:orientation="vertical"
android:paddingBottom="@dimen/activity_vertical_margin" android:paddingLeft="@dimen/activity_horizontal_margin"
android:paddingRight="@dimen/activity_horizontal_margin"
android:paddingTop="@dimen/activity_vertical_margin"
 tools:context=".MainActivity" >
 <EditText
 android:id="@+id/et_path"
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:hint="请输入要下载的文件资源路径"
android:text="http://192.168.1.104:8080/gg.exe" />
 <Button
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:onClick="download"
 android:text="下载" />
 <ProgressBar
 android:id="@+id/pb0"
 style="?android:attr/progressBarStyleHorizontal"
 android:layout_width="match_parent"
 android:layout_height="wrap_content" />
 <ProgressBar
 android:id="@+id/pb1"
 style="?android:attr/progressBarStyleHorizontal"
 android:layout_width="match_parent"
 android:layout_height="wrap_content" />
 <ProgressBar
 android:id="@+id/pb2"
 style="?android:attr/progressBarStyleHorizontal"
 android:layout_width="match_parent"
 android:layout_height="wrap_content" />
</LinearLayout>

多线程下载的内部逻辑如下,其实这在开头已经有了,只不过是代码的实现了。

 public class MainActivity extends Activity {
 private EditText et_path;
 private ProgressBar pb0;
 private ProgressBar pb1;
 private ProgressBar pb2;
 /**
 * 开启几个线程从服务器下载数据
 */
 public static int threadCount = 3;
 public static int runningThreadCount;
 private String path;
 @Override
 protected void onCreate(Bundle savedInstanceState) {
 super.onCreate(savedInstanceState);
 setContentView(R.layout.activity_main);
 //初始化控件
 et_path = (EditText) findViewById(R.id.et_path);
 pb0 = (ProgressBar) findViewById(R.id.pb0);
 pb1 = (ProgressBar) findViewById(R.id.pb1);
 pb2 = (ProgressBar) findViewById(R.id.pb2);
 }
 //下载按钮的点击事件
 public void download(View view) {
 path = et_path.getText().toString().trim();
 if (TextUtils.isEmpty(path) || (!path.startsWith("http://"))) {
 Toast.makeText(this, "对不起路径不合法", 0).show();
 return;
 }
 new Thread(){
 public void run() {
 try {
 //1.获取服务器上的目标文件的大小
 URL url = new URL(path);
 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
 conn.setConnectTimeout(5000);
 conn.setRequestMethod("GET");
 int code = conn.getResponseCode();
 if (code == 200) {
 int length = conn.getContentLength();
 System.out.println("服务器文件的长度为:" + length);
 //2.在本地创建一个跟原始文件同样大小的文件
 RandomAccessFile raf = new RandomAccessFile(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+getFileName(path), "rw");
 raf.setLength(length);
 raf.close();
 //3.计算每个线程下载的起始位置和结束位置
 int blocksize = length / threadCount;
 runningThreadCount = threadCount;
 for (int threadId = 0; threadId < threadCount; threadId++) {
 int startIndex = threadId * blocksize;
 int endIndex = (threadId + 1) * blocksize - 1;
 if (threadId == (threadCount - 1)) {
 endIndex = length - 1;
 }
 //4.开启多个子线程开始下载
 new DownloadThread(threadId, startIndex, endIndex).start();
 }
 }
 } catch (Exception e) {
 e.printStackTrace();
 }
 };
 }.start();
 }
 private class DownloadThread extends Thread {
 /**
 * 线程id
 */
 private int threadId;
 /**
 * 线程下载的理论开始位置
 */
 private int startIndex;
 /**
 * 线程下载的结束位置
 */
 private int endIndex;
 /**
 * 当前线程下载到文件的那一个位置了.
 */
 private int currentPosition;
 public DownloadThread(int threadId, int startIndex, int endIndex) {
 this.threadId = threadId;
 this.startIndex = startIndex;
 this.endIndex = endIndex;
 System.out.println(threadId + "号线程下载的范围为:" + startIndex
 + " ~~ " + endIndex);
 currentPosition = startIndex;
 }
 @Override
 public void run() {
 try {
 URL url = new URL(path);
 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
 //检查当前线程是否已经下载过一部分的数据了 
 File info = new File(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+threadId+".position");
 RandomAccessFile raf = new RandomAccessFile(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+getFileName(path), "rw");
 if(info.exists()&&info.length()>0){
 FileInputStream fis = new FileInputStream(info);
 BufferedReader br = new BufferedReader(new InputStreamReader(fis));
 currentPosition = Integer.valueOf(br.readLine());
 conn.setRequestProperty("Range", "bytes="+currentPosition+"-"+endIndex);
 System.out.println("原来有下载进度,从上一次终止的位置继续下载"+"bytes="+currentPosition+"-"+endIndex);
 fis.close();
 raf.seek(currentPosition);//每个线程写文件的开始位置都是不一样的.
 }else{
 //告诉服务器 只想下载资源的一部分
 conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
 System.out.println("原来没有有下载进度,新的下载"+ "bytes="+startIndex+"-"+endIndex);
 raf.seek(startIndex);//每个线程写文件的开始位置都是不一样的.
 }
 InputStream is = conn.getInputStream();
 byte[] buffer = new byte[1024];
 int len = -1;
 while((len = is.read(buffer))!=-1){
 //把每个线程下载的数据放在自己的空间里面.
// System.out.println("线程:"+threadId+"正在下载:"+new String(buffer));
 raf.write(buffer,0, len);
 //5.记录下载进度
 currentPosition+=len;
 File file = new File(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+threadId+".position");
 RandomAccessFile fos = new RandomAccessFile(file,"rwd");
 //System.out.println("线程:"+threadId+"写到了"+currentPosition);
 fos.write(String.valueOf(currentPosition).getBytes());
 fos.close();//fileoutstream数据是不一定被写入到底层设备里面的,有可能是存储在缓存里面.
 //raf 的 rwd模式,数据是立刻被存储到底层硬盘设备里面.
 //更新进度条的显示
 int max = endIndex - startIndex;
 int progress = currentPosition - startIndex;
 if(threadId==0){
 pb0.setMax(max);
 pb0.setProgress(progress);
 }else if(threadId==1){
 pb1.setMax(max);
 pb1.setProgress(progress);
 }else if(threadId==2){
 pb2.setMax(max);
 pb2.setProgress(progress);
 }
 }
 raf.close();
 is.close();
 System.out.println("线程:"+threadId+"下载完毕了...");
 File f = new File(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+threadId+".position");
 f.renameTo(new File(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+threadId+".position.finish"));
 synchronized (MainActivity.class) {
 runningThreadCount--;
 //6.删除临时文件
 if(runningThreadCount<=0){
 for(int i=0;i<threadCount;i++){
 File ft = new File(Environment.getExternalStorageDirectory().getAbsolutePath()+"/"+i+".position.finish");
 ft.delete();
 }
 }
 }
 } catch (Exception e) {
 e.printStackTrace();
 }
 }
 }
 /**
 * 获取一个文件名称
 * @param path
 * @return
 */
 public String getFileName(String path){
 int start = path.lastIndexOf("/")+1;
 return path.substring(start);
 }
}

最后别忘了添加权限,在该工程中不仅用到了网络访问还用到了sdcard 存储,因此需要添加两个权限。

<uses-permission android:name="android.permission.INTERNET"/>
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>

另外,xUtils同样可以实现多线程下载。xUtils 是开源免费的Android 工具包,代码托管在github 上。目前xUtils 主要有四大模块:DbUtils 模块,主要用于操作数据库的框架。ViewUtils 模块,通过注解的方式可以对UI,资源和事件绑定进行管理。HttpUtils 模块,提供了方便的网络访问,断点续传等功能。BitmapUtils 模块,提供了强大的图片处理工具。我们在这里只简单实用xUtils 工具中的HttpUtils 工具。第三方包的使用较为简单,直接拷贝xUtils的jar包到libs目录下,然后添加依赖。

接下来就可以使用xUtils中的httpUtils的功能了:

HttpUtils http = new HttpUtils();
 /**
 * 参数1:原文件网络地址
 * 参数2:本地保存的地址
 * 参数3:是否支持断点续传,true:支持,false:不支持
 * 参数4:回调接口,该接口中的方法都是在主线程中被调用的,
 * 也就是该接口中的方法都可以修改UI
 */
 http.download(path, "/mnt/sdcard/xxx.exe", true, new RequestCallBack<File>() {
 //下载成功后调用一次
 @Override
 public void onSuccess(ResponseInfo<File> arg0) {
 Toast.makeText(MainActivity.this, "下载成功", 0).show();
 }
 /**
 * 每下载一部分就被调用一次,通过该方法可以知道当前下载进度
 * 参数1:原文件总字节数
 * 参数2:当前已经下载好的字节数
 * 参数3:是否在上传,对于下载,该值为false
 */
 @Override
 public void onLoading(long total, long current, boolean isUploading) {
 pb0.setMax((int) total);
 pb0.setProgress((int) current);
 super.onLoading(total, current, isUploading);
 }
 //失败后调用一次
 @Override
 public void onFailure(HttpException arg0, String arg1) {
 Toast.makeText(MainActivity.this, "下载失败"+arg1, 0).show();
 }
 });

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,同时也希望多多支持!


# Android  # 多线程  # 断点下载  # Android 断点下载和自动安装的示例代码  # android多线程断点下载-带进度条和百分比进度显示效果  # Android HttpURLConnection断点下载(单线程)  # Android原生实现多线程断点下载实例代码  # Android入门:多线程断点下载详细介绍  # Android使用多线程实现断点下载  # Android实现断点下载的方法  # Android实现多线程断点下载的方法  # Android实现断点多线程下载  # 多个  # 进度条  # 创建一个  # 临时文件  # 都是  # 有两种  # 再将  # 要再  # 自己的  # 断点续传  # 是一个  # 器上  # 几个  # 是在  # 在这里  # 成了  # 放在  # 就在  # 长条形 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: 如何用西部建站助手快速创建专业网站?  如何用狗爹虚拟主机快速搭建网站?  Python文本处理实践_日志清洗解析【指导】  如何用IIS7快速搭建并优化网站站点?  LinuxCD持续部署教程_自动发布与回滚机制  Laravel如何使用Gate和Policy进行授权?(权限控制)  Linux虚拟化技术教程_KVMQEMU虚拟机安装与调优  百度输入法ai组件怎么删除 百度输入法ai组件移除工具  Linux安全能力提升路径_长期防护思维说明【指导】  车管所网站制作流程,交警当场开简易程序处罚决定书,在交警网站查询不到怎么办?  Laravel如何生成和使用数据填充?(Seeder和Factory示例)  nginx修改上传文件大小限制的方法  Laravel与Inertia.js怎么结合_使用Laravel和Inertia构建现代单页应用  Laravel如何使用Vite进行前端资源打包?(配置示例)  如何注册花生壳免费域名并搭建个人网站?  Laravel如何自定义错误页面(404, 500)?(代码示例)  JavaScript如何操作视频_媒体API怎么控制播放  Laravel Seeder填充数据教程_Laravel模型工厂Factory使用  如何快速重置建站主机并恢复默认配置?  图册素材网站设计制作软件,图册的导出方式有几种?  Laravel怎么导出Excel文件_Laravel Excel插件使用教程  如何快速辨别茅台真假?关键步骤解析  零基础网站服务器架设实战:轻量应用与域名解析配置指南  个人网站制作流程图片大全,个人网站如何注销?  JavaScript如何实现继承_有哪些常用方法  JavaScript如何实现音频处理_Web Audio API如何工作?  Laravel如何使用API Resources格式化JSON响应_Laravel数据资源封装与格式化输出  Android利用动画实现背景逐渐变暗  如何在Windows虚拟主机上快速搭建网站?  香港服务器租用每月最低只需15元?  laravel怎么配置Redis作为缓存驱动_laravel Redis缓存配置教程  Laravel怎么防止CSRF攻击_Laravel CSRF保护中间件原理与实践  手机怎么制作网站教程步骤,手机怎么做自己的网页链接?  详解vue.js组件化开发实践  Laravel如何升级到最新的版本_Laravel版本升级流程与兼容性处理  购物网站制作费用多少,开办网上购物网站,需要办理哪些手续?  如何在IIS管理器中快速创建并配置网站?  美食网站链接制作教程视频,哪个教做美食的网站比较专业点?  如何确保西部建站助手FTP传输的安全性?  Laravel如何实现图片防盗链功能_Laravel中间件验证Referer来源请求【方案】  javascript日期怎么处理_如何格式化输出  Edge浏览器提示“由你的组织管理”怎么解决_去除浏览器托管提示【修复】  laravel怎么在请求结束后执行任务(Terminable Middleware)_laravel Terminable Middleware请求结束任务执行方法  谷歌浏览器下载文件时中断怎么办 Google Chrome下载管理修复  EditPlus中的正则表达式实战(6)  如何在万网ECS上快速搭建专属网站?  Laravel如何实现本地化和多语言支持?(i18n教程)  ChatGPT常用指令模板大全 新手快速上手的万能Prompt合集  jquery插件bootstrapValidator表单验证详解  Laravel Livewire是什么_使用Laravel Livewire构建动态前端界面