Java实现多线程文件下载的代码示例
Java实现多线程文件下载思路：
1、基本思路是将文件分段切割、分段传输、分段保存。
2、分段切割用到HttpUrlConnection对象的setRequestProperty("Range","bytes="+start+"-"+end)方法。
3、分段传输用到HttpUrlConnection对象的getInputStream()方法。
4、分段保存用到RandomAccessFile的seek(intstart)方法。
5、创建指定长度的线程池，循环创建线程，执行下载操作。
首先，我们要先写一个方法，方法的参数包含URL地址，保存的文件地址，切割后的文件开始位置和结束位置，这样我们就能把分段文件下载到本地。并且这个方法要是run方法，这样我们启动线程时就直接执行该方法。
publicclassDownloadWithRangeimplementsRunnable
{
privateStringurlLocation;
privateStringfilePath;
privatelongstart;
privatelongend;
DownloadWithRange(StringurlLocation,StringfilePath,longstart,longend)
{
this.urlLocation=urlLocation;
this.filePath=filePath;
this.start=start;
this.end=end;
}
@Override
publicvoidrun()
{
try
{
HttpURLConnectionconn=getHttp();
conn.setRequestProperty("Range","bytes="+start+"-"+end);
Filefile=newFile(filePath);
RandomAccessFileout=null;
if(file!=null)
{
out=newRandomAccessFile(file,"rwd");
}
out.seek(start);
InputStreamin=conn.getInputStream();
byte[]b=newbyte[1024];
intlen=0;
while((len=in.read(b))!=-1)
{
out.write(b,0,len);
}
in.close();
out.close();
}
catch(Exceptione)
{
e.getMessage();
}
}
publicHttpURLConnectiongetHttp()throwsIOException
{
URLurl=null;
if(urlLocation!=null)
{
url=newURL(urlLocation);
}
HttpURLConnectionconn=(HttpURLConnection)url.openConnection();
conn.setReadTimeout(5000);
conn.setRequestMethod("GET");
returnconn;
}
}
然后我们创建线程池，线程池的长度可以自定义，然后循环创建线程来执行请求，每条线程的请求开始位置和结束位置都不同，本地存储的文件开始位置和请求开始位置相同，这样就可以实现多线程下载了。
publicclassDownloadFileWithThreadPool
{
publicvoidgetFileWithThreadPool(StringurlLocation,StringfilePath,intpoolLength)throwsIOException
{
ExecutorthreadPool=Executors.newFixedThreadPool(poolLength);
longlen=getContentLength(urlLocation);
for(inti=0;i<poolLength;i++)
{
longstart=i*len/poolLength;
longend=(i+1)*len/poolLength-1;
if(i==poolLength-1)
{
end=len;
}
DownloadWithRangedownload=newDownloadWithRange(urlLocation,filePath,start,end);
threadPool.execute(download);
}
}
publicstaticlonggetContentLength(StringurlLocation)throwsIOException
{
URLurl=null;
if(urlLocation!=null)
{
url=newURL(urlLocation);
}
HttpURLConnectionconn=(HttpURLConnection)url.openConnection();
conn.setReadTimeout(5000);
conn.setRequestMethod("GET");
longlen=conn.getContentLength();
returnlen;
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。