转载请标明出处:http://blog.csdn.net/lmj623565791/article/details/26994463
有个朋友需要个多线程现在的例子,就帮忙实现了,在此分享下~
先说下原理,原理明白了,其实很简单:
a、对于网络上的一个资源,首先发送一个请求,从返回的Content-Length中回去需要下载文件的大小,然后根据文件大小创建一个文件。
this.fileSize = conn.getContentLength();// 根据响应获取文件大小
File dir = new File(dirStr);
this.localFile = new File(dir, filename);
RandomAccessFile raf = new RandomAccessFile(this.localFile, "rw");
raf.setLength(fileSize);
raf.close();
b、根据线程数和文件大小,为每个线程分配下载的字节区间,然后每个线程向服务器发送请求,获取这段字节区间的文件内容。
conn.setRequestProperty("Range", "bytes=" + startPos + "-"
+ endPos);// 设置获取实体数据的范围
c、利用RandomAccessFile的seek方法,多线程同时往一个文件中写入字节。
raf.seek(startPos);
while ((len = is.read(buf)) != -1)
{
raf.write(buf, 0, len);
}
分析完了原理就很简单了,我封装了一个类,利用这个类的实例进行下载,所需参数:下载资源的URI, 本地文件路径,线程的数量。
package com.zhy.mutilthread_download;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
public class MultipartThreadDownloador
{
/**
* 需要下载资源的地址
*/
private String urlStr;
/**
* 下载的文件
*/
private File localFile;
/**
* 需要下载文件的存放的本地文件夹路径
*/
private String dirStr;
/**
* 存储到本地的文件名
*/
private String filename;
/**
* 开启的线程数量
*/
private int threadCount;
/**
* 下载文件的大小
*/
private long fileSize;
public MultipartThreadDownloador(String urlStr, String dirStr,
String filename, int threadCount)
{
this.urlStr = urlStr;
this.dirStr = dirStr;
this.filename = filename;
this.threadCount = threadCount;
}
public void download() throws IOException
{
createFileByUrl();
/**
* 计算每个线程需要下载的数据长度
*/
long block = fileSize % threadCount == 0 ? fileSize / threadCount
: fileSize / threadCount + 1;
for (int i = 0; i < threadCount; i++)
{
long start = i * block;
long end = start + block >= fileSize ? fileSize : start + block - 1;
new DownloadThread(new URL(urlStr), localFile, start, end).start();
}
}
/**
* 根据资源的URL获取资源的大小,以及在本地创建文件
*/
public void createFileByUrl() throws IOException
{
URL url = new URL(urlStr);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setConnectTimeout(15 * 1000);
conn.setRequestMethod("GET");
conn.setRequestProperty(
"Accept",
"image/gif, image/jpeg, image/pjpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*");
conn.setRequestProperty("Accept-Language", "zh-CN");
conn.setRequestProperty("Referer", urlStr);
conn.setRequestProperty("Charset", "UTF-8");
conn.setRequestProperty(
"User-Agent",
"Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.2; Trident/4.0; .NET CLR 1.1.4322; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)");
conn.setRequestProperty("Connection", "Keep-Alive");
conn.connect();
if (conn.getResponseCode() == 200)
{
this.fileSize = conn.getContentLength();// 根据响应获取文件大小
if (fileSize <= 0)
throw new RuntimeException(
"the file that you download has a wrong size ... ");
File dir = new File(dirStr);
if (!dir.exists())
dir.mkdirs();
this.localFile = new File(dir, filename);
RandomAccessFile raf = new RandomAccessFile(this.localFile, "rw");
raf.setLength(fileSize);
raf.close();
System.out.println("需要下载的文件大小为 :" + this.fileSize + " , 存储位置为: "
+ dirStr + "/" + filename);
} else
{
throw new RuntimeException("url that you conneted has error ...");
}
}
private class DownloadThread extends Thread
{
/**
* 下载文件的URI
*/
private URL url;
/**
* 存的本地路径
*/
private File localFile;
/**
* 是否结束
*/
private boolean isFinish;
/**
* 开始的位置
*/
private Long startPos;
/**
* 结束位置
*/
private Long endPos;
public DownloadThread(URL url, File savefile, Long startPos, Long endPos)
{
this.url = url;
this.localFile = savefile;
this.startPos = startPos;
this.endPos = endPos;
}
@Override
public void run()
{
System.out.println(Thread.currentThread().getName() + "开始下载...");
try
{
HttpURLConnection conn = (HttpURLConnection) url
.openConnection();
conn.setConnectTimeout(15 * 1000);
conn.setRequestMethod("GET");
conn.setRequestProperty(
"Accept",
"image/gif, image/jpeg, image/pjpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*");
conn.setRequestProperty("Accept-Language", "zh-CN");
conn.setRequestProperty("Referer", url.toString());
conn.setRequestProperty("Charset", "UTF-8");
conn.setRequestProperty("Range", "bytes=" + startPos + "-"
+ endPos);// 设置获取实体数据的范围
conn.setRequestProperty(
"User-Agent",
"Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.2; Trident/4.0; .NET CLR 1.1.4322; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)");
conn.setRequestProperty("Connection", "Keep-Alive");
conn.connect();
/**
* 代表服务器已经成功处理了部分GET请求
*/
if (conn.getResponseCode() == 206)
{
InputStream is = conn.getInputStream();
int len = 0;
byte[] buf = new byte[1024];
RandomAccessFile raf = new RandomAccessFile(localFile,
"rwd");
raf.seek(startPos);
while ((len = is.read(buf)) != -1)
{
raf.write(buf, 0, len);
}
raf.close();
is.close();
System.out.println(Thread.currentThread().getName()
+ "完成下载 : " + startPos + " -- " + endPos);
this.isFinish = true;
} else
{
throw new RuntimeException(
"url that you conneted has error ...");
}
} catch (IOException e)
{
e.printStackTrace();
}
}
}
}
createFileByUrl方法,就是我们上述的原理的步骤1,得到文件大小和创建本地文件。我在程序使用了一个内部类DownloadThread继承Thread,专门负责下载。download()方法,根据线程数量和文件大小计算每个线程需要下载的字节区间,然后开启线程去下载。
服务器端:我就扔了几个文件在Tomcat根目录做实验,下面是测试代码:
package com.zhy.mutilthread_download;
import java.io.IOException;
public class Test
{
public static void main(String[] args)
{
try
{
new MultipartThreadDownloador("http://localhost:8080/nexus.zip",
"f:/backup/nexus", "nexus.zip", 2).download();
} catch (IOException e)
{
e.printStackTrace();
}
}
}
输出结果:
需要下载的文件大小为 :31143237 , 存储位置为: f:/backup/nexus/nexus.zip
Thread-1开始下载...
Thread-2开始下载...
Thread-3开始下载...
Thread-4开始下载...
Thread-4完成下载 : 23357430 -- 31143237
Thread-2完成下载 : 7785810 -- 15571619
Thread-1完成下载 : 0 -- 7785809
Thread-3完成下载 : 15571620 -- 23357429
截图:
ok,多线程下载介绍完毕,如果代码设计不合理,以及方法使用错误,欢迎各位留言,,,
源码点击下载
分享到:
相关推荐
一个基于安卓的打地鼠游戏源码,地鼠并不是在9个洞里出现,而是特么的全屏随机位置出现,且出现时间极端,这样才真是考验反应能力,游戏有...代码只有两个java文件,是新手练手的上乘项目,感兴趣的可以自己下载研究。
这个是java开发的多线程断点续传下载demo,内有详细注释,是练习android多线程断点续传下载时写的测试demo,下面的android开发的多线程断点续传下载demo是基于这个移植过去的,使用java开发的可以参考这个。
一个基于安卓的打地鼠游戏源码,地鼠并不是在9个洞里出现,而是特么的全屏随机位置出现,且出现时间极端,这样才真是考验反应能力,游戏有...代码只有两个java文件,是新手练手的上乘项目,感兴趣的可以自己下载研究。
本示例介绍在Android平台下通过HTTP协议实现断点续传下载。具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
Android 是Google开发的基于Linux平台的开源手机操作系统。它包括操作系统、用户界面...【第一版第十四章】老罗Android开发视频--多线程编程(7集) 【第一版第十五章】老罗Android开发视频--百度地图实战开发(10集)
下载界面的设计及多线程下载功能的实现;漫画阅读界面的设计及漫画阅读功能的实现。 搜索漫画的界面设计与搜索功能的实现;漫画收藏、历史记录页面的设计及功能的实现;左侧菜单栏的设计与夜间模式功能的实现。
它的主要特性包括:高效地支持从消费类入门级声卡到专业级音频设备所有类型的音频接口,完全模块化的设计,支持对称多处理和线程安全,对OSS(Open Sound System,开放声音系统)的向后兼容,以及提供了用户空间的...
通过这个Android源码可学习一下如何基于Java代码实现断点续传的应用,比如如何设置当前线程下载的起点、终点,设置断点续传的开始位置,设置User-Agent ,httpURLConnection.setRequestProperty("User-Agent",...
在系统架构实现上,采用了 MVC 结构进行框架的组建,结合各子校图书馆环境分析,搭建系统运行...系统实际时以用户的使用体验为核心,考虑到移动设备的运行效率,系统开启了多线程服务对聊天、文件下载功能等进行管理。
Java实现HTTP连接与浏览,Java源码下载,输入html文件地址或网址,显示页面和HTML源文件,一步步的实现过程请下载本实例的Java源码,代码中包括丰富的注释,对学习有帮助。 Java实现的FTP连接与数据浏览程序 1个...
采用单线程解析多线程业务处理方案,内置线程池方便线程管理;支持静态文件下载;支持表单参数和文件上传,支持PUT文件上传。解析成功后返回HttpRequest和HttpResponse。除常见的接口请求返回外,HttpResponse可以向...
Java实现HTTP连接与浏览,Java源码下载,输入html文件地址或网址,显示页面和HTML源文件,一步步的实现过程请下载本实例的Java源码,代码中包括丰富的注释,对学习有帮助。 Java实现的FTP连接与数据浏览程序 1个...
的 Android SDK 提供了在 Android 平台上使用 JaVa 语言进行 Android 应用开发必须的工具和 API 接口。 特性 • 应用程序框架 支持组件的重用与替换 • Dalvik Dalvik Dalvik Dalvik 虚拟机 专为移动设备优化 • ...
MyBatchFramework 是一个开源的轻量级的用以创建可靠的易管理的批量作业的Java包,主要特点是多线程、调度、JMX管理和批量执行报表,执行历史等。 SIP协议包 jSIP.tar jSIP这个Java包目标是用Java实现SIP(SIP:...
本文主要介绍了Android多线程之同步锁的使用,分享给大家,具体如下: 一、同步机制关键字synchronized 对于Java来说,最常用的同步机制就是synchronized关键字,他是一种基于语言的粗略锁,能够作用于对象、函数...
MyBatchFramework 是一个开源的轻量级的用以创建可靠的易管理的批量作业的Java包,主要特点是多线程、调度、JMX管理和批量执行报表,执行历史等。 SIP协议包 jSIP.tar jSIP这个Java包目标是用Java实现SIP(SIP:...
MyBatchFramework 是一个开源的轻量级的用以创建可靠的易管理的批量作业的Java包,主要特点是多线程、调度、JMX管理和批量执行报表,执行历史等。 SIP协议包 jSIP.tar jSIP这个Java包目标是用Java实现SIP(SIP:...
将服务器端所有的通讯线程保存到一个集合当中,当有用户发来数据,则转发给所有用户,实现聊天室效果。Android端通过使用Socket建立客户端链接,并且在AsyncTask中执行网络读写的任务,将用户输入的内容发送到服务器...
3、了解Android中Intent跳转机制,java的多线程机制,完成实验二 课程时间: 10月30日课堂教学, 11月6日之前提交报告 4、了解Android的小型数据库SQLite,java的SQL操作,完成实验三 课程时间:11月6日课堂教学,11...