主程序,获得欲下载文件的大小,根据其大小分配线程数量和下载的偏移量
package mulithreaddownload;
import java.net.URL;
import java.net.HttpURLConnection;
import java.io.File;
import java.io.RandomAccessFile;
import java.io.IOException;
public class DownloadManager {
static final long unitSize = 100 * 1024; // 分配给每个下载线程的字节数
public static void main(String[] args) throws IOException {
if (args.length != 2) {
System.out
.println("Usage java DownloadManager URL local_file_name");
return;
}
DownloadManager downloadManager = new DownloadManager();
downloadManager.doDownload(args[0], args[1]);
}
public void doDownload(String remoteFileUrl, String localFileName)
throws IOException {
long fileSize = this.getRemoteFileSize(remoteFileUrl);
this.createFile(localFileName, fileSize);
long threadCount = fileSize / unitSize;
System.out.println("共启动线程"
+ (fileSize % unitSize == 0 ? threadCount : threadCount + 1)
+ "个");
long offset = 0;
if (fileSize <= unitSize) // 如果远程文件尺寸小于等于unitSize
{
DownloadThread downloadThread = new DownloadThread(remoteFileUrl,
localFileName, offset, fileSize);
downloadThread.start();
} else // 如果远程文件尺寸大于unitSize
{
for (int i = 1; i <= threadCount; i++) {
DownloadThread downloadThread = new DownloadThread(
remoteFileUrl, localFileName, offset, unitSize);
downloadThread.start();
offset = offset + unitSize;
}
if (fileSize % unitSize != 0) // 如果不能整除,则需要再创建一个线程下载剩余字节
{
DownloadThread downloadThread = new DownloadThread(
remoteFileUrl, localFileName, offset, fileSize
- unitSize * threadCount);
downloadThread.start();
}
}
}
// 获取远程文件尺寸
private long getRemoteFileSize(String remoteFileUrl) throws IOException {
long result = 0;
HttpURLConnection httpConnection = (HttpURLConnection) new URL(
remoteFileUrl).openConnection();
httpConnection.setRequestMethod("HEAD");
for (int i = 1; i <= 10; i++) {
if (httpConnection.getHeaderFieldKey(i).equalsIgnoreCase(
"Content-Length")) {
result = Long.parseLong(httpConnection.getHeaderField(i));
break;
}
}
return result;
}
// 创建指定大小的文件
private void createFile(String fileName, long fileSize) throws IOException {
File newFile = new File(fileName);
RandomAccessFile raf = new RandomAccessFile(newFile, "rw");
raf.setLength(fileSize);
raf.close();
}
}
下载的具体实现有线程实现
package mulithreaddownload;
import java.net.URL;
import java.net.HttpURLConnection;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.RandomAccessFile;
import java.io.IOException;
public class DownloadThread extends Thread {
private String url = null; // 待下载的文件
private String file = null; // 本地存储路径
private long offset = 0; // 偏移量
private long length = 0; // 分配给本线程的下载字节数
public DownloadThread(String url, String file, long offset, long length) {
this.url = url;
this.file = file;
this.offset = offset;
this.length = length;
System.out.println("偏移量=" + offset + ";字节数=" + length);
}
public void run() {
try {
HttpURLConnection httpConnection = (HttpURLConnection) new URL(
this.url).openConnection();
httpConnection.setRequestMethod("GET");
httpConnection.setRequestProperty("RANGE", "bytes=" + this.offset
+ "-" + (this.offset + this.length - 1));
BufferedInputStream bis = new BufferedInputStream(httpConnection
.getInputStream());
byte[] buff = new byte[1024]; // 分段读取,防止内容泄露
int bytesRead;
while (-1 != (bytesRead = bis.read(buff, 0, buff.length))) {
this.writeFile(this.file, this.offset, buff, bytesRead);
this.offset = this.offset + bytesRead;
}
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
// 将字节数组以随机存取方式写入文件
// fileName是被写入的文件
// offset代表写入文件的位置偏移量
// bytes是待写入的字节数组
// realLength是实际需要写入的字节数(realLength<=bytes.length)
private void writeFile(String fileName, long offset, byte[] bytes,
int realLength) throws IOException {
File newFile = new File(fileName);
RandomAccessFile raf = new RandomAccessFile(newFile, "rw");
raf.seek(offset);
raf.write(bytes, 0, realLength);
raf.close();
}
}
分享到:
相关推荐
《JDK 6.0线程入门到精通——Chapter 7》 在Java开发中,线程是程序执行的最小单元,它使得一个程序能够同时处理多个任务,从而提高了程序的效率和响应性。在JDK 6.0中,线程的管理和使用有了更加完善的特性,对于...
本章“jdk6.0从入门到精通-----chapter8并发多线程(1)”着重讲解了Java 6中关于多线程的基本知识和实践技巧。通过源码下载,读者可以更直观地理解多线程的实现方式。 首先,我们要理解什么是多线程。在单线程环境...
《JDK 6.0从入门到精通——Chapter 17 动态编程》 在Java编程领域,JDK 6.0版本引入了许多新特性,其中动态编程是提升开发效率和灵活性的重要方面。本章将深入探讨动态编程的概念、用途以及如何在JDK 6.0中利用这些...
标题中的“jdk6.0从入门到精通-----chapter18与动态语言结合”指的是Java开发工具包(JDK)6.0版本中的一个章节,主要探讨了如何将Java与动态编程语言集成。在Java 6中,引入了一个重要的特性,即Java平台标准版6...
在Java编程领域,JDK(Java Development Kit)是开发和运行Java应用程序的...总的来说,"JDK6.0从入门到精通-----chapter5网络编程 新I/O"是一个极好的学习资源,无论你是初学者还是有经验的开发者,都能从中获益良多。
标题 "(源码下载)jdk6.0从入门到精通-----chapter2--输入输出,克隆对象" 提供了我们要探讨的主题,即Java中的输入输出流(I/O Stream)和对象克隆。在这个章节中,我们将深入理解这两个关键概念。 **输入输出流...
在Java编程语言中,JDK(Java Development Kit)是核心组件,它包含了开发和运行Java应用程序所需的工具和...同时,随着Java版本的更新,如JDK 7和8引入了更多的文件操作改进,开发者也需要持续学习和掌握最新的技术。
在Java编程领域,JDK6.0是一个重要的版本,它为开发者提供了丰富的特性和改进。本章我们将深入探讨“反射机制”以及如何结合Spring AOP(面向切面编程)进行应用。反射是Java中的一种强大工具,允许程序在运行时检查...
微信开发平台开发工具 JDK jdk 6.0 jdk-6u10-rc2-bin-b32-windows-i586-p-12_sep_2008
- 首先,从官方或可信渠道下载JDK 6.0的安装程序。 - 运行安装程序,按照提示完成安装过程。 - 配置环境变量,如JAVA_HOME指向JDK安装目录,PATH添加bin子目录,确保系统能够找到Java命令。 - 检验安装是否成功,...
java6.0文档chm版,分成三部分,分别为JDK6.0+中文文档-lytim24.part1.rar、JDK6.0+中文文档-lytim24.part2.rar、JDK6.0+中文文档-lytim24.part3.rar
这个压缩包“JDK 6.0.zip”显然是为了方便用户下载和安装这一特定版本的JDK。 JDK 6.0在2006年发布,它是Java SE(Standard Edition)的一部分,主要用于桌面应用开发。这一版本引入了许多新特性和改进,包括: 1....
tar -zxvf jdk-7u80-linux-x64.tar.gz ``` 这会创建一个名为`jdk1.7.0_80`的目录,其中包含了JDK的所有文件。 ##### 4.3 设置环境变量 为了让操作系统能够找到JDK,需要将JDK的路径添加到系统的环境变量中。可以...
这个是安装开发工具java jdk 有很多用途
【标题】"jdk-7u80-windows-x64.exe" 指的是Java Development Kit (JDK) 的第7个版本更新80的64位Windows安装程序。JDK是Oracle公司提供的一个用于开发和运行Java应用程序的核心工具集。 【描述】"jdk-7u80-windows...
1. **概述**:介绍JDK 6.0的基本概念、系统需求和安装指南,帮助初学者快速入门。 2. **Java语言规范**:详细解释了Java语言的语法和特性,包括类、对象、接口、异常处理等。 3. **API参考**:这是文档的核心部分...
1. 下载与操作系统匹配的JDK安装包,如"jdk-8u202-windows-x64.exe"。 2. 双击执行安装程序,按照向导指示进行操作,选择安装路径。 3. 在安装过程中,确保勾选"将Java添加到系统PATH"选项,以便在命令行中直接运行...
jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u...
在这个特定的压缩包中,我们找到了"jdk-7u80-windows-x64.exe",这正是JDK 1.7的64位版本,适用于Windows操作系统。这个版本的JDK是Java 7的更新版本,编号为u80,代表Update 80,意味着它包含了自初始发布以来的...
该资源为jdk-7u60-windows-x64.exe jdk1.7 64位 欢迎大家下载!