`

Java多线程下载文件

阅读更多

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.RandomAccessFile;

import java.net.HttpURLConnection;

import java.net.URL;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

import java.util.Set;

 

/**

* @author EX-QINCIDONG001 多线程下载文件。 思想:开启5个线程,每个线程下载文件大小的1/5,<br>

* 每个线程生成的文件以文件名_编号作为文件名。<br>

* 每个线程结束后都检查自己是否是最后一个线程。<br>

* 如果是最后一个线程,就启动合并文件的线程<br>

* 用RandomAccessFile类,有追加文件的方法。<br>

* 扫描所有的文件,合并为一个文件。

*

* 例:<br>

* Thread File Name File Size

* Thread-1 test_1.mp3 300kb

* Thread-2 test_2.mp3 300kb

* Thread-3 test_3.mp3 200kb

*

* 最终的文件:test.mp3

*/

publicclass ThreadDownloadFile {

// 要下载的文件的URL

private String fileUrl;

// 要保存的文件名

private String saveName;

// 要创建的线程数量

privatestaticfinalintTHREAD_COUNT = 5;

// 保存线程运行的状态(0标识线程还在运行,1标识结束)

Map<Integer, Integer> threadStatusMap = new HashMap<Integer, Integer>();

 

public ThreadDownloadFile(String fileUrl,String saveName) {

this.fileUrl = fileUrl;

this.saveName = saveName;

// 初始化线程运行状态

for (int i=0;i<THREAD_COUNT;i++) {

// key:线程编号,value:线程运行状态

threadStatusMap.put(i, 0);

}

}

 

privatevoid download() throws IOException {

URL url = new URL(this.fileUrl);

HttpURLConnection conn = (HttpURLConnection) url.openConnection();

conn.setAllowUserInteraction(true);

conn.connect();

// 文件总的长度

int contentLength = conn.getContentLength();

// 每个线程应该分配的长度

int partLength = contentLength / this.THREAD_COUNT + 1;

 

conn.disconnect();

 

System.out.println("开始下载文件...");

 

for (int i = 0; i < this.THREAD_COUNT; i++) {

int length = partLength;

if (i == this.THREAD_COUNT - 1) { // 最后一个的长度

length = contentLength - partLength * i;

}

int index1 = saveName.lastIndexOf("/");

int index2 = saveName.lastIndexOf(".");

String partFileName = saveName.substring(0, index1+1)

+ saveName.substring(index1+1, index2) + "_"+(i + 1)

+ saveName.substring(index2, saveName.length());

DownloadThread dt = new DownloadThread(conn,contentLength,this.THREAD_COUNT,i,length,i*length, url, partFileName,threadStatusMap,this.saveName);

dt.start();

}

}

 

/**

* @param args

*/

publicstaticvoid main(String[] args) {

// String saveName = "http://www.a.b/c/d.mp3";

// int index1 = saveName.lastIndexOf("/");

// int index2 = saveName.lastIndexOf(".");

// int i = 0;

// String partFileName = saveName.substring(0, index1+1)

// + saveName.substring(index1+1, index2) +"_"+ (i + 1)

// + saveName.substring(index2, saveName.length());

// System.out.println(partFileName);

String fileUrl = "http://www.baidu.com";//"http://localhost:8080/filedownload/download1.jsp";

String saveName = "D:/Users/ex-qincidong001/Desktop/outlook邮件归类.docx";

ThreadDownloadFile tdf = new ThreadDownloadFile(fileUrl,saveName);

try {

tdf.download();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

 

}

 

class DownloadThread extends Thread {

// 总长度

privateintcontentLength;

// 线程数

privateintthreadNum;

// 当前线程编号

privateintcurrentThreadNum;

privateintlength;

privateintoffset;

private URL url;

private String partFileName;

// 要保存的文件名

private String saveName;

private Map<Integer,Integer> threadStatusMap;

HttpURLConnection conn;

 

DownloadThread(HttpURLConnection conn,int contentLength,int threadNum,int currentThreadNum,int length,int offset, URL url, String partFileName,Map<Integer,Integer> threadStatusMap,String saveName) {

this.conn = conn;

this.contentLength = contentLength;

this.threadNum = threadNum;

this.currentThreadNum = currentThreadNum;

this.length = length;

this.offset = offset;

this.url = url;

this.partFileName = partFileName;

this.threadStatusMap = threadStatusMap;

this.saveName = saveName;

}

 

publicvoid run() {

System.out.println("线程【" +this.currentThreadNum + "】开启...");

// HttpURLConnection conn;

try {

conn = (HttpURLConnection) url.openConnection();

conn.setAllowUserInteraction(true);

conn.setRequestProperty("RANGE", "bytes=" + offset );

conn.connect();

// 设置断点续传的开始位置

 

FileOutputStream fos = new FileOutputStream(partFileName);

InputStream is = conn.getInputStream();

byte[] data = newbyte[1024];

int len = -1;

int readSize = 0;

 

while ((len = is.read(data)) != -1) {

readSize += len;

 

if (readSize > length) { // 只读取length长度

len = len - (readSize - length);

}

fos.write(data, 0, len);

 

if (readSize > length) {

break;

}

}

 

fos.flush();

is.close();

// 将线程运行状态改为1(结束)

this.threadStatusMap.remove(currentThreadNum);

this.threadStatusMap.put(currentThreadNum, 1);

 

// 检查是否全部想线程都运行完毕

boolean flag = true;

Set<Integer> keys = this.threadStatusMap.keySet();

Iterator<Integer> its = keys.iterator();

while (its.hasNext()) {

Integer key = its.next();

Integer value = this.threadStatusMap.get(key);

if (value == 0) {

flag = false;

break;

}

}

 

System.out.println("线程【" +this.currentThreadNum + "】结束...");

 

if (flag) { // 所有的下载线程均结束,可以开始合并文件的线程

MergeThread mt = new MergeThread(this.contentLength,this.threadNum,this.saveName);

mt.start();

System.out.println("文件下载完毕...\n文件保存位置:" + this.saveName);

}

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

 

}

}

 

/**

* 合并文件的线程。

* @author EX-QINCIDONG001

*

*/

class MergeThread extends Thread {

// 文件总长度

privateintcontentLength;

// 线程的数量,以便于知道,生成了几个子文件。

privateintthreadNum;

// 要保存的最终的文件名

private String saveName;

 

public MergeThread(int contentLength,int threadNum,String saveName) {

this.contentLength = contentLength;

this.threadNum = threadNum;

this.saveName = saveName;

}

publicvoid run() {

int index1 = saveName.lastIndexOf("/");

int index2 = saveName.lastIndexOf(".");

RandomAccessFile accessFile = null;

try {

accessFile = new RandomAccessFile(saveName,"rw");

} catch (FileNotFoundException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

// 每个线程应该分配的长度

int partLength = contentLength / this.threadNum + 1;

for (int i=0;i<threadNum;i++) {

// 子文件文件名

String partFileName = saveName.substring(0, index1+1)

+ saveName.substring(index1+1, index2) +"_"+ (i + 1)

+ saveName.substring(index2, saveName.length());

 

int length = partLength;

if (i == this.threadNum - 1) { // 最后一个的长度

length = contentLength - partLength * i;

}

 

try {

accessFile.seek(i*length);

FileInputStream fis = new FileInputStream(partFileName);

byte[] data = newbyte[1024];

int len = -1;

 

while ((len = fis.read(data)) != -1) {

accessFile.write(data,0,len);

}

 

fis.close();

accessFile.close();

} catch (FileNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

分享到:
评论

相关推荐

    java多线程下载文件

    ### Java多线程断点下载文件:关键技术与实现 在当今高速互联网环境下,高效的数据传输技术变得至关重要。Java多线程断点续传文件下载技术就是一种能够显著提高下载速度和稳定性的方法。本文将深入解析Java多线程...

    java实现多线程下载文件

    通过以上步骤,我们可以设计并实现一个高效的多线程文件下载系统。在实际项目中,还可以考虑使用成熟的库,如Apache HttpClient或OkHttp,它们提供了对多线程下载的良好支持。同时,结合Java的并发库,可以构建出更...

    Java多线程设计模式上传文件

    Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式...

    Android Java 多线程下载文件 demo

    在Android平台上,Java多线程下载文件是一种常见的优化方法,特别是在处理大文件或者网络环境不稳定时,能够提高下载效率并减少资源消耗。本教程将详细解释如何实现这一功能。 首先,理解多线程下载的基本原理。...

    Java多线程文件下载

    Java多线程文件下载是一种高效的下载策略,它通过将大文件分割成多个部分,然后创建多个线程分别下载这些部分,来实现并行下载。这种技术可以显著提高下载速度,尤其是在网络条件不稳定或者带宽有限的情况下。下面...

    java多线程读取文件

    Java多线程读大文件 java多线程写文件:多线程往队列中写入数据

    java多线程下载文件源码

    在Java编程中,多线程下载文件是一种优化大文件下载效率的技术。它通过将一个大文件分割成多个小部分,然后在不同的线程中并行下载这些部分,从而充分利用网络带宽,加快下载速度。本源码实现了这样一个功能,让下载...

    Java多线程下载器

    Java多线程下载器是一种利用Java编程语言实现的高效文件下载工具,它通过将大文件分割成多个部分并同时下载,显著提高了下载速度。在Java中实现多线程下载器涉及许多关键概念和技术,包括线程、并发控制、网络I/O...

    java 多线程下载 (单文件)

    Java多线程下载技术主要应用于提高大文件下载的效率,通过将文件分割成多个部分,同时启动多个线程分别下载这些部分,从而实现并行下载,加快下载速度。以下是对这个主题的详细解释: 1. **Java多线程基础**: 在...

    Java多线程文件分片下载实现的示例代码

    Java多线程文件分片下载实现的示例代码 本文将详细介绍Java多线程文件分片下载的实现示例代码,通过示例代码,大家可以学习和理解多线程文件分片下载的技术难点和解决方案。 多线程下载的技术难点 ---------------...

    Java多线程下载

    Java多线程下载技术是Java开发中用于提升大文件下载效率的一种常见方法。在传统的单线程下载过程中,网络请求可能会因为各种原因中断,如网络波动、服务器问题或用户操作等,这会导致需要从头开始下载,浪费时间和...

    java多线程下载器

    Java多线程下载器是一种利用Java编程语言实现的高效文件下载工具,它通过将大文件分割成多个小部分,然后创建多个线程同时下载这些部分,以提高下载速度。这种技术在处理大文件或者网络带宽有限的情况下尤其有用,...

    Java多线程下载文件实现案例详解

    "Java多线程下载文件实现案例详解" Java多线程下载文件实现案例详解是Java多线程编程中的一种常见应用场景。本文将通过示例代码对Java多线程下载文件实现案例进行详细的解释,对大家的学习或者工作具有一定的参考...

    java多线程URL方式下载单个大文件

    在Java编程中,多线程下载大文件是一种常见的优化策略,尤其对于网络资源如文件或图片的下载。这种策略能够利用多核处理器的优势,通过并发处理来提高下载速度。本篇将详细介绍如何使用Java实现基于URL的单个大文件...

    java多线程简单下载器

    【Java多线程简单下载器】是一个初学者的编程作业,虽然代码可能较为混乱,但其核心功能已经实现,即通过多线程技术进行文件的下载。在Java中,多线程是并发处理的重要手段,它允许多个任务在同一时间执行,从而提高...

    java多线程下载源代码

    Java多线程下载是利用Java编程语言实现的一种高效下载大文件的技术。在传统的单线程下载方式中,如果网络环境不稳定或文件较大,下载过程可能会很慢,甚至中断。而多线程下载则是将文件分割成多个部分,每个部分由一...

    Java 利用多线程实现文件的分片下载

    刚学完多线程和线程池,以及线程爱好者。 使用场景及目标: 大文件的快速下载,经测试在100M带宽的网络下,下载一个40M的文件,不超过两秒钟,当然还得根据自己电脑的配置来讲。 其他说明: 文件如果特别小,而...

    java多线程下载图片

    在这个场景中,"java多线程下载图片"意味着我们将探讨如何使用Java来实现一个能够异步下载多个图片的系统。 首先,我们需要理解Java中的线程是如何创建和运行的。Java提供了两种创建线程的方式:继承Thread类和实现...

    Java 多线程下载网站

    这个Java多线程下载网站项目结合了网络编程、HTML解析、文件操作等多个Java核心概念,对于提升Java程序员的全栈开发能力具有很高的实践价值。通过学习和实践这个项目,开发者不仅可以掌握多线程下载的技巧,还能深入...

Global site tag (gtag.js) - Google Analytics