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

成了完整的文件了。这样就大大提高了文件的下载效率。对于文件下载来说,多线程下载是必须要考虑的环节。
多线程下载大致可分为以下几个步骤:
一.获取服务器上的目标文件的大小
显然这一步是需要先访问一下网络,只需要获取到目标文件的总大小即可。目的是为了计算每个线程应该分配的下载任务。
二. 在本地创建一个跟原始文件同样大小的文件
在本地可以通过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实现断点多线程下载
# 多个
# 进度条
# 创建一个
# 临时文件
# 都是
# 有两种
# 再将
# 要再
# 自己的
# 断点续传
# 是一个
# 器上
# 几个
# 是在
# 在这里
# 成了
# 放在
# 就在
# 长条形
相关文章:
定制建站平台哪家好?企业官网搭建与快速建站方案推荐
代购小票制作网站有哪些,购物小票的简要说明?
建站VPS推荐:2025年高性能服务器配置指南
海南网站制作公司有哪些,海口网是哪家的?
如何在自有机房高效搭建专业网站?
山东网站制作公司有哪些,山东大源集团官网?
头像制作网站在线观看,除了站酷,还有哪些比较好的设计网站?
一键网站制作软件,义乌购一件代发流程?
如何做静态网页,sublimetext3.0制作静态网页?
建站为何优先选择香港服务器?
创业网站制作流程,创业网站可靠吗?
官网自助建站系统:SEO优化+多语言支持,快速搭建专业网站
如何正确下载安装西数主机建站助手?
建站之星后台密码遗忘?如何快速找回?
建站之星2.7模板:企业网站建设与h5定制设计专题
浙江网站制作公司有哪些,浙江栢塑信息技术有限公司定制网站做的怎么样?
如何获取开源自助建站系统免费下载链接?
名字制作网站免费,所有小说网站的名字?
公司网站制作需要多少钱,找人做公司网站需要多少钱?
天河区网站制作公司,广州天河区如何办理身份证?需要什么资料有预约的网站吗?
香港服务器选型指南:免备案配置与高效建站方案解析
孙琪峥织梦建站教程如何优化数据库安全?
定制建站是什么?如何实现个性化需求?
如何通过商城免费建站系统源码自定义网站主题?
如何彻底删除建站之星生成的Banner?
如何通过可视化优化提升建站效果?
如何确保FTP站点访问权限与数据传输安全?
c# 服务器GC和工作站GC的区别和设置
网站网页制作电话怎么打,怎样安装和使用钉钉软件免费打电话?
如何高效完成独享虚拟主机建站?
建站主机功能解析:服务器选择与快速搭建指南
如何在Windows环境下新建FTP站点并设置权限?
建站主机系统SEO优化与智能配置核心关键词操作指南
建站之星多图banner生成与模板自定义指南
Python lxml的etree和ElementTree有什么区别
制作营销网站公司,淘特是干什么用的?
交易网站制作流程,我想开通一个网站,注册一个交易网址,需要那些手续?
网站制作员失业,怎样查看自己网站的注册者?
如何在Ubuntu系统下快速搭建WordPress个人网站?
详解一款开源免费的.NET文档操作组件DocX(.NET组件介绍之一)
小自动建站系统:AI智能生成+拖拽模板,多端适配一键搭建
正规网站制作公司有哪些,目前国内哪家网页网站制作设计公司比较专业靠谱?口碑好?
如何实现建站之星域名转发设置?
如何在IIS中新建站点并配置端口与IP地址?
如何彻底卸载建站之星软件?
建站之星如何修改网站生成路径?
详解ASP.NET 生成二维码实例(采用ThoughtWorks.QRCode和QrCode.Net两种方式)
php json中文编码为null的解决办法
大连网站制作公司哪家好一点,大连买房网站哪个好?
制作企业网站建设方案,怎样建设一个公司网站?
*请认真填写需求信息,我们会在24小时内与您取得联系。