package com.test;
import java.io.IOException;
public class Main {
// public static final String ADD = "http://mat1.gtimg.com/www/iskin960/s01/s_b_1.1.0.png";
// public static final String ADD = "http://mat1.gtimg.com/www/iskin960/logo_soso.png";
// public static final String ADD = "http://ossweb-img.qq.com/upload/qqgg/dancer/1305786311_1837963180_10218_sPicName.jpg";
// public static final String ADD = "http://dl_dir.qq.com/qqfile/qq/QQ2011/QQ2011Beta2.exe";
public static final String FILE = "jay_picture_90.jpg";
public static final String ADD = "http://www.ppig.com.cn/images/jay_picture_90.jpg";
public static void main(String[] args) throws IOException {
DownMain main=new DownMain(ADD,4);//package com.test;
import java.io.IOException;
public class Main {
// public static final String ADD = "http://mat1.gtimg.com/www/iskin960/s01/s_b_1.1.0.png";
// public static final String ADD = "http://mat1.gtimg.com/www/iskin960/logo_soso.png";
// public static final String ADD = "http://ossweb-img.qq.com/upload/qqgg/dancer/1305786311_1837963180_10218_sPicName.jpg";
// public static final String ADD = "http://dl_dir.qq.com/qqfile/qq/QQ2011/QQ2011Beta2.exe";
public static final String FILE = "jay_picture_90.jpg";
public static final String ADD = "http://www.ppig.com.cn/images/jay_picture_90.jpg";
public static void main(String[] args) throws IOException {
DownMain main=new DownMain(ADD,4);//参数1，下载地址，参数2：用多少线程
main.download();
}
}
main.download();
}
}
闲来无事 搞下java多线程下载，发发代码，以后改进改进
下载线程类：
package com.test;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.Properties;
public class DownTread implements Runnable {
private String address;//链接地址
private long start;//开始字节
private long end;//结束字节数
private ArrayList<DownData> data;//下载的文件数据
private CallBack callBack;//下载完成,回调写入下载容
private int cache;//缓存
public DownTread(String address,long start,long end,CallBack callBack){
this.address=address;
this.start=start;
this.end=end;
this.callBack=callBack;
Properties properties=new Properties();
try {
properties.load(this.getClass().getResourceAsStream("/sys.properties"));//读取配置文件的缓存
cache=Integer.parseInt(properties.getProperty("cache"));
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void run() {
try {
callBack.befor(this);
down();
} catch (IOException e) {
e.printStackTrace();
callBack.error(this);
}
callBack.allFinish(this);
}
private void down()throws IOException{
URL url=new URL(address);
HttpURLConnection conn=(HttpURLConnection) url.openConnection();
conn.setUseCaches(false);
conn.setDoInput(true);
conn.setDoOutput(false);
conn.setRequestMethod("GET");
conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 5.1; rv:2.0.1) Gecko/20100101 Firefox/4.0.1");
conn.setRequestProperty("Range", "bytes="+start+"-"+end);
conn.connect();
System.out.println("线程:"+Thread.currentThread().getName()+conn.getHeaderFields().get("Content-Range"));
data=new ArrayList<DownData>();
InputStream bins=conn.getInputStream();
byte [] bs=new byte[cache];
long len=end-start+1;
int dlen=0;
long dstart=start;
while((dlen=bins.read(bs))!=-1){
if(dlen<len){
data.add(new DownData(dstart,bs, dlen));
len-=dlen;
dstart+=dlen;
}
else {
data.add(new DownData(dstart,bs, len));
dstart+=len;
}
if(DownMain.isWriteing){
callBack.finish(this);
data.clear();
}
bs=new byte[cache];
}
bins.close();
conn.disconnect();
}
public long getStart() {
return start;
}
public long getEnd() {
return end;
}
public ArrayList<DownData> getData() {
return data;
}
interface CallBack {
void befor(DownTread thread);
void finish(DownTread downTread);//读取到一次数据
void allFinish(DownTread thread);//该线程分配的任务下载完成
void error(DownTread thread);//出现错误
}
}
下载的数据包
package com.test;
public class DownData {
private long start;//该段数据在总文件中的位置
private long len;
private byte [] data;
public DownData(long start,byte []data,long len){
this.start=start;
this.data=data;
this.len=len;
}
public long getLen() {
return len;
}
public byte[] getData() {
return data;
}
public long getStart() {
return start;
}
}
下载主线程类：管理，把下载的文件数据写入文件
package com.test;
import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
import com.test.DownTread.CallBack;
public class DownMain implements CallBack {
private String address;
private RandomAccessFile af;
public static boolean isWriteing=true;
private int dts=0;
private int thread;
public DownMain(String address,int thread) {
this.address = address;
this.thread=thread;
}
public void download() throws IOException {
System.out.println("开始下载文件");
URL url = new URL(this.address);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setUseCaches(false);
conn.setDoInput(true);
conn.setDoOutput(false);
conn.setRequestMethod("GET");
conn.setConnectTimeout(20000);
conn.setRequestProperty("User-Agent",
"Mozilla/5.0 (Windows NT 5.1; rv:2.0.1) Gecko/20100101 Firefox/4.0.1");
System.out.println("开始连接文件");
conn.connect();
System.out.println(conn.getHeaderFields());
if(conn.getResponseCode()==HttpURLConnection.HTTP_NOT_FOUND){
System.out.println("找不到文件,连接失败！");
return;
}
System.out.println("连接成功");
System.out.println("文件大小：" + conn.getContentLength() + "字节");
System.out.println("文件类型：" + conn.getContentType());
long fileLength = conn.getContentLength();
conn.disconnect();
File file = new File("d:\\jay\\" + Main.FILE);
if (!file.exists()) {
file.createNewFile();
} else {
file.delete();
file.createNewFile();
}
af = new RandomAccessFile(file, "rw");
long unit = fileLength / thread;
long start = 0;
long[][] task = new long[thread][2];
for (int i = 0; i < thread; i++) {
task[i][0] = start;
start += unit;
task[i][1] = start - 1;
if (i == thread-1 && task[i][1] < fileLength) {
task[i][1] = fileLength;
}
}
/**/
System.out.println("开始分段下载");
for (int i = 0; i < thread; i++) {
new Thread(new DownTread(address, task[i][0], task[i][1], this),"线程"+i).start();
start += unit;
dts++;
}
}
@Override
public void finish(DownTread down) {
try {
synchronized (af) {
isWriteing=false;
for (DownData d : down.getData()) {
af.seek(d.getStart());
System.out.print("线程"+Thread.currentThread().getName()+"写入位置："+af.getFilePointer());
af.write(d.getData(), 0, (int)d.getLen());
System.out.println("-"+af.getFilePointer());
}
System.gc();
isWriteing=true;
}
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void allFinish(DownTread thread) {
System.out.println("线程："+Thread.currentThread().getName()+"开始完成");
synchronized (af) {
dts--;
if(dts==0){
try {
finish();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
@Override
public void befor(DownTread thread) {
System.out.println("线程："+Thread.currentThread().getName()+"开始下载");
}
@Override
public void error(DownTread thread) {
System.out.println("线程："+Thread.currentThread().getName()+"出现错误");
}
private void finish() throws IOException{
System.out.println("全部下载完成！");
af.close();
}
}
使用方法：
分享到：
相关推荐
Java多线程下载技术是Java开发中用于提升大文件下载效率的一种常见方法。在传统的单线程下载过程中，网络请求可能会因为各种原因中断，如网络波动、服务器问题或用户操作等，这会导致需要从头开始下载，浪费时间和...
Java多线程下载器是一种利用Java编程语言实现的高效文件下载工具，它通过将大文件分割成多个部分并同时下载，显著提高了下载速度。在Java中实现多线程下载器涉及许多关键概念和技术，包括线程、并发控制、网络I/O...
Java多线程下载技术主要应用于提高大文件下载的效率，通过将文件分割成多个部分，同时启动多个线程分别下载这些部分，从而实现并行下载，加快下载速度。以下是对这个主题的详细解释： 1. **Java多线程基础**： 在...
在Java编程中，多线程是一项关键技能，尤其在处理并发任务时，如我们的示例——"Java多线程下载网络图片"。这个场景展示了如何利用多线程技术提高程序性能，减少用户等待时间，同时优化系统资源的使用。下面我们将...
Java多线程下载器是一种利用Java编程语言实现的高效文件下载工具，它通过将大文件分割成多个小部分，然后创建多个线程同时下载这些部分，以提高下载速度。这种技术在处理大文件或者网络带宽有限的情况下尤其有用，...
Java多线程下载工具，其核心思想是利用Java的并发特性来提高文件下载速度，模拟类似迅雷的高效下载体验。在实现这样的工具时，我们需要理解并掌握以下几个关键知识点： 1. **线程与并发**：Java中的多线程是通过`...
Java多线程下载是一种高效的文件下载技术，它利用了Java多线程编程的优势来提高文件下载的速度和效率。在单线程下载中，文件的下载是连续的，而在多线程下载中，文件被分割成多个部分，每个部分由一个独立的线程负责...
本文将深入解析Java多线程下载文件的关键技术和实现细节。 #### 一、Java多线程下载原理 多线程下载的核心思想是将一个大文件分割成多个小的部分，每个部分由一个独立的线程进行下载，最后将这些部分合并成完整的...
在这个场景中，"java多线程下载图片"意味着我们将探讨如何使用Java来实现一个能够异步下载多个图片的系统。 首先，我们需要理解Java中的线程是如何创建和运行的。Java提供了两种创建线程的方式：继承Thread类和实现...
Java多线程下载是利用Java编程语言实现的一种高效下载大文件的技术。在传统的单线程下载方式中，如果网络环境不稳定或文件较大，下载过程可能会很慢，甚至中断。而多线程下载则是将文件分割成多个部分，每个部分由一...
这个Java多线程下载网站项目结合了网络编程、HTML解析、文件操作等多个Java核心概念，对于提升Java程序员的全栈开发能力具有很高的实践价值。通过学习和实践这个项目，开发者不仅可以掌握多线程下载的技巧，还能深入...
下面将详细讲解Java多线程下载的相关知识点： 1. **线程基础**：在Java中，线程是程序中的执行流。`Thread`类是所有线程的基类，我们可以通过继承它或实现`Runnable`接口来创建线程。创建线程主要有两种方式：直接...
Java多线程下载课程设计是一项常见且实用的项目，它涉及到计算机网络、操作系统以及Java编程语言的核心特性。在这个工程源码中，开发者可能利用了Java的并发能力来提高下载效率，实现了多线程同时下载文件的不同部分...
这是一个用于java多线程下载的帮助类 封装了多线程下载的方法
总之，这个Java多线程下载工具是一个结合了网络协议、多线程技术和文件处理的实用程序，它通过并发下载和断点续传特性，提供了高效且灵活的文件下载体验。对于学习Java并发编程、网络编程和文件操作的开发者来说，这...
Java多线程下载工具是一种利用Java编程语言实现的软件，它可以将大文件分割成多个部分并行下载，从而显著提高下载速度。这种技术是通过利用Java的多线程特性来实现的，对于处理网络资源的大量请求，尤其是在带宽有限...
在这个“另外一个java多线程下载程序源代码”中，我们可以深入学习如何利用Java的多线程特性来创建一个高效的文件下载应用。 首先，我们了解Java中创建线程的两种主要方式： 1. 继承`Thread`类：自定义一个新的类...
在Java编程中，多线程下载是一种常见的优化技术，它能有效地提高文件下载速度，特别是在处理大文件或网络带宽有限的情况下。...同时，这也是一个很好的实践案例，可以帮助你深入理解Java多线程编程和文件操作的知识。