nba
- 浏览: 2444 次
-
文章分类
最新评论
网上关于多线程下载的教程基本都是以请求某个具体的文件url路径为例子， 这种例子与实际应用不太相符。
一般我们都是通过请求一个Controller路径或servlet路径来下载文件内容：
这里就涉及到根据请求头rang返回客户端需要的字节数：
服务端代码：
客户端代码：
一般我们都是通过请求一个Controller路径或servlet路径来下载文件内容：
这里就涉及到根据请求头rang返回客户端需要的字节数：
服务端代码：
package org.wenchj.servlet;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.ArrayUtils;
public class DownloadServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
public void download(HttpServletRequest request, HttpServletResponse response) {
try {
String filePath = request.getSession().getServletContext().getRealPath("/115com_v2.1.1.exe");
System.out.println(filePath);
File f = new File(filePath);
FileInputStream fis = new FileInputStream(f);
response.reset();
// 告诉客户端允许断点续传多线程连接下载
// 响应的格式是:
// Accept-Ranges: bytes
response.setHeader("Accept-Ranges", "bytes");
long p = 0;
long l = 0;
l = f.length();
// 如果是第一次下,还没有断点续传,状态是默认的 200,无需显式设置
// 响应的格式是:
// HTTP/1.1 200 OK
if (request.getHeader("Range") != null) // 客户端请求的下载的文件块的开始字节
{
// 如果是下载文件的范围而不是全部,向客户端声明支持并开始文件块下载
// 要设置状态
// 响应的格式是:
// HTTP/1.1 206 Partial Content
response.setStatus(javax.servlet.http.HttpServletResponse.SC_PARTIAL_CONTENT);// 206
// 从请求中得到开始的字节
// 请求的格式是:
// Range: bytes=[文件块的开始字节]-
p = Long.parseLong(request.getHeader("Range").replaceAll("bytes=", "").replaceAll("-", ""));
}
// 下载的文件(或块)长度
// 响应的格式是:
// Content-Length: [文件的总大小] - [客户端请求的下载的文件块的开始字节]
response.setHeader("Content-Length", new Long(l - p).toString());
if (p != 0) {
// 不是从最开始下载,
// 响应的格式是:
// Content-Range: bytes [文件块的开始字节]-[文件的总大小 - 1]/[文件的总大小]
response.setHeader(
"Content-Range",
"bytes " + new Long(p).toString() + "-" + new Long(l - 1).toString() + "/"
+ new Long(l).toString());
}
// response.setHeader("Connection", "Close"); //如果有此句话不能用 IE 直接下载
// 使客户端直接下载
// 响应的格式是:
// Content-Type: application/octet-stream
response.setContentType("application/octet-stream");
// 为客户端下载指定默认的下载文件名称
// 响应的格式是:
// Content-Disposition: attachment;filename="[文件名]"
// response.setHeader("Content-Disposition",
// "attachment;filename=\"" + s.substring(s.lastIndexOf("\\") + 1) +
// "\""); //经测试 RandomAccessFile 也可以实现,有兴趣可将注释去掉,并注释掉
// FileInputStream 版本的语句
// response.setHeader("Content-Disposition", "attachment;filename=\"" + app.getName() + ".apk\"");
// 可选
setFileAttachmentHeader(response, f.getName());
// raf.seek(p);
fis.skip(p);
byte[] b = new byte[1024];
int i;
// while ( (i = raf.read(b)) != -1 ) //经测试 RandomAccessFile
// 也可以实现,有兴趣可将注释去掉,并注释掉 FileInputStream 版本的语句
while ((i = fis.read(b)) != -1) {
response.getOutputStream().write(b, 0, i);
}
// raf.close();//经测试 RandomAccessFile 也可以实现,有兴趣可将注释去掉,并注释掉
// FileInputStream 版本的语句
fis.close();
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
download2(request, response);
// download2(request, response);
}
private void download2(HttpServletRequest request, HttpServletResponse response) throws IOException {
// String fileName = "/smack_3_3_1.zip";
String fileName = "/115com_v2.1.1.exe";
String filePath = request.getSession().getServletContext().getRealPath(fileName);
System.out.println("[" + Thread.currentThread().getName() + "]" + filePath);
File f = new File(filePath);
response.setHeader("Content-Length", String.valueOf(f.length()));
// 可选
setFileAttachmentHeader(response, f.getName());
System.out.println("Range--->" + request.getHeader("Range"));
byte[] content = FileUtils.readFileToByteArray(f);
System.out.println("文件总长度content.length-->" + content.length);
String rangeHeader = request.getHeader("Range");
if (rangeHeader != null) {
String[] split = rangeHeader.split("=");
String[] range = split[1].split("-");
int start = Integer.valueOf(range[0]);
int end = Integer.valueOf(range[1]);
System.out.println("start:" + start + ", end:" + end);
byte[] temp = new byte[end - start];
// 截取数组
temp = ArrayUtils.subarray(content, start, end + 1);
response.setHeader("Content-Length", String.valueOf(end - start));
responseFileContent(response, temp);
} else {
response.setHeader("Content-Length", String.valueOf(f.length()));
responseFileContent(response, content);
}
}
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException,
IOException {
this.doGet(request, response);
}
/*
* 返回文件内容
*/
private void responseFileContent(HttpServletResponse response, byte[] content) {
try {
OutputStream outStream = response.getOutputStream();
outStream.write(content);
outStream.flush();
outStream.close();
} catch (Exception e) {
// e.printStackTrace();
}
}
/*
* 以附件形式下载(用浏览器下载会弹出对话框)
*/
private static void setFileAttachmentHeader(HttpServletResponse response, String fileName) {
try {
String encodedFileName = new String(fileName.getBytes(), "ISO8859-1");
response.setHeader("Content-Disposition", "attachment; filename=\"" + encodedFileName + "\"");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
}
}
客户端代码：
package org.wenchj.servlet;
import java.io.File;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
public class MulThreadDownloader {
public static void main(String[] args) throws Exception {
String path = "http://localhost:8088/download/DownloadServlet";
int threadsize = 3;
new MulThreadDownloader().download(path, threadsize);
}
private void download(String path, int threadsize) throws Exception {
URL downpath = new URL(path);
HttpURLConnection conn = (HttpURLConnection) downpath.openConnection();
conn.setConnectTimeout(5000);
conn.setRequestMethod("GET");
if (conn.getResponseCode() == 200) {
int length = conn.getContentLength();// 获取网络文件的长度
System.out.println("获取网络文件的长度" + length);
File file = new File("115com_v2.1.1.exe");
RandomAccessFile accessFile = new RandomAccessFile(file, "rwd");// 生成本地文件
accessFile.setLength(length);
accessFile.close();
// 计算每条线程负责下载的数据量
int block = (length % threadsize) == 0 ? length / threadsize : (length / threadsize) + 1;
System.out.println("block:" + block);
for (int threadid = 0; threadid < threadsize; threadid++) {
new DownloadThread(threadid, downpath, block, file).start();
}
}
}
// 负责下载操作
private final class DownloadThread extends Thread {
private int threadid;
private URL downpath;
private int block;
private File file;
public DownloadThread(int threadid, URL downpath, int block, File file) {
this.threadid = threadid;
this.downpath = downpath;
this.block = block;
this.file = file;
}
@Override
public void run() {
// if (threadid == 0) {
// try {
// System.out.println("线程" + threadid + "睡眠20s...");
// Thread.sleep(20 * 1000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// }
int startposition = threadid * block;// 从网络文件的什么位置开始下载数据
int endposition = ((threadid + 1) * block) - 1;// 下载到网络文件的什么位置结束
// 指示该线程要从网络文件的startposition位置开始下载，下载到endposition位置结束
// Range:bytes=startposition-endposition
try {
RandomAccessFile accessFile = new RandomAccessFile(file, "rwd");
accessFile.seek(startposition);// 移动指针到文件的某个位置
HttpURLConnection conn = (HttpURLConnection) downpath.openConnection();
conn.setConnectTimeout(5000);
conn.setRequestMethod("GET");
conn.setRequestProperty("Range", "bytes=" + startposition + "-" + endposition);
InputStream inStream = conn.getInputStream();
System.out.println(Thread.currentThread().getName() + ", ContentLength:" + conn.getContentLength());
byte[] buffer = new byte[1024];
int len = 0;
while ((len = inStream.read(buffer)) != -1) {
accessFile.write(buffer, 0, len);
}
accessFile.close();
inStream.close();
System.out.println("线程" + (threadid) + "下载完成");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
分享到：
发表评论
相关推荐
采用apache commons开发包，实现了FTP多线程下载，并有简单的包括进度条的界面，代码的运行：1 把自己的PC配置成FTP服务器(只需下载Serc-U软件)2 建立用户，用户名：zhangyu，密码：123，设置根目录，并拷贝进一些...
基于libcurl/pthreads的多线程下载器，跨平台，支持暂停、还原、中止，断点续传，支持HTTP,HTTPS协议链接，http://blog.csdn.net/u012532305/article/details/46709495也是这篇文章的源码
新鲜出炉的SpringBoot版本的多线程下载文件，可以拿来整合SpringBoot项目或者SSM项目，可直接运行测试！！！
[C#]多线程下载 代码注释：http://www.cnblogs.com/wangxinsheng/articles/4214600.html 程序具体功能（流程）： 1.检测系统托盘图标内的进程名是否符合要求 （xp时可以，win7部分机器可以，该功能无意义） 2.抓取...
基于golang实现的多线程下载器，用于下载支持http/https协议的资源，具体源码可移步个人博客（地址：http://t.csdn.cn/0aR0i）。
java多线程下载源代码 java多线程下载源代码
winform实现多线程下载 winform实现多线程下载 winform实现多线程下载
MFC多线程下载MFC多线程下载
多线程下载步骤： （1）在本地创建一个大小跟服务器文件的大小相同的临时文件 （2）计算分配几个线程下载服务器的资源，知道每个线程下载的文件的位置 每个线程开始位置、结束为止 计算公式 （3）开启多个线程，每个...
Java多线程下载Java多线程下载Java多线程下载Java多线程下载Java多线程下载
Asp.net多线程下载示例源码 （包含完整的CS文件！） <br>1. 支持多线程: 多个线程某时刻下载同一个文件的不同块. 2. 断点续传: 如果下载了一个文件的某些块(一半), 则下次下载时只需下载未完成的块;文件块的...
c#实现unity下可用的http多线程下载。主要是WWW接口的bundle函数不好用，而且性能也不高。支持多线程。支持单个文件和多个文件下载
Java多线程下载器
多线程下载的试做demo，主要是帮助理解多线程下载的原理，以及断点的处理。
使用HttpURLConnection写的一个多线程下载工具，支持断点续传
多线程下载：1、创建URL对象； 2、获取指定URL对象所指向资源的大小； 3、在本地磁盘上创建一个与网络资源相同大小的空文件； 4、计算每条线程应该下载网络资源的哪个部分； 5、依次创建、启动多线程来下载网络资源...
基于python，多线程下载m3u8链接，可下载简单加密资源。 *-cmd.exe文件显示命令行窗内，便于定位下载\合并失败的问题 *.exe文件不显示命令行窗口
支持多个下载任务，分块多线程下载，断点续传。 （对比上个版本，完成了遗留的功能，修改了事件触发过程及处理方式，重新整理了代码及注释） 内含两个窗体，可视为演示程序。 DownloadForm 下载窗体，含相关事件...
android多线程下载，下载速度相对快的多
易语言多线程下载源码 其实也没什么简单下载例程