Java多线程下载的实现方法
package cn.me.test;
import java.io.inputstream;
import java.io.randomaccessfile;
import java.net.httpurlconnection;
import java.net.url;
/**
* 多线程下载
* 1：使用randomaccessfile在任意的位置写入数据。
* 2：需要计算第一个线程下载的数据量，可以平均分配。如果不够平均时，
* 则直接最后一个线程处理相对较少的数据
* 3：必须要在下载之前准备好相同大小的文件，通过文件头获取
*/
public class multithreaddownload {
public static void main(string[] args) throws exception {
//1：声明文件名和下载的地址
string filename = "aa.rar";
string urlstr = "http://localhost:7777/day18";
//2：声明url
url url = new url(urlstr+"/"+filename);
//3：获取连接
httpurlconnection con =
(httpurlconnection) url.openconnection();
//4:设置请求方式
con.setrequestmethod("get");
//5:获取请求头,即文件的长度
int length = con.getcontentlength();//获取下载文件的长度，以计算每个线程应该下载的数据量。
//6：在指定的目录下，创建一个同等大小的文件
randomaccessfile file = new randomaccessfile("d:/a/"+filename, "rw");//创建一个相同大小的文件。
//7:设置文件大小，占位
file.setlength(length);//设置文件大小。
file.close();
//8：定义线程个数
int size = 3;
//9:计算每一个线程应该下载多少字节的数据，如果正好整除则最好，否则加1
int block = length/size==0?length/size:length/size+1;//计算每个线程应该下载的数据量。
system.err.println("每个线程应该下载："+block);
//10：运行三个线程并计算从哪个字节开始到哪一个字节结束
for(int i=0;i<size;i++){
int start = i*block;
int end = start+(block-1);//计算每一个线程的开始和结束字节。
system.err.println(i+"="+start+","+end);
new mydownthread(filename, start, end,url).start();
}
}
static class mydownthread extends thread{
//定义文件名
private string filename;
//定义从何地开始下载
private int start;
//定义下载到哪一个字节
private int end;
private url url;
public mydownthread(string filename,int start,int end,url url){
this.filename=filename;
this.start=start;
this.end=end;
this.url=url;
}
@override
public void run() {
try{
//11:开始下载
httpurlconnection con =
(httpurlconnection) url.openconnection();
con.setrequestmethod("get");
//12：设置分段下载的请求头
con.setrequestproperty("range","bytes="+start+"-"+end);//设置从服务器上读取的文件块。
//13:开始下载，需要判断206
if(con.getresponsecode()==206){//访问成功，则返回的状态码为206。
inputstream in = con.getinputstream();
//14:声明随机写文件对象，注意rwd是指即时将数据写到文件中，而不使用缓存区
randomaccessfile out = new randomaccessfile("d:/a/"+filename,"rwd");
out.seek(start);//设置从文件的某个位置开始写数据。
byte[] b=new byte[1024];
int len = 0;
while((len=in.read(b))!=-1){
out.write(b,0,len);
}
out.close();
in.close();
}
system.err.println(this.getname()+"执行完成");
}catch(exception e){
throw new runtimeexception(e);
}
}
}
}