我们把服务器的上的文件看作水缸的水，要想取走水缸里面的水的话，那么多线程下载就相当于用多条管子抽水一样。
多线程下载大约可以分为以下几个步骤：
1.要知道服务端资源的大小。
2、在本地创建一个与服务器资源同样大小的一个文件，主要是用来占位；
Paste_Image.png
//file : 文件； mode:文件的模式，rwd：直接写到底层设备，硬盘
RandomAccessFile randomfile =new RandomAccessFile(File file,String mode)
3、要分配每个线程下载文件的开始位置和结束位置。那该如何确定每个线程下载文件的开始位置和结束位置呢？
Paste_Image.png
a、如图所示我们假设开启3个线程，去下载资源大小为10的文件
b.首先计算出每个线程下载的长度 blocKSize=资源长度/线程数量
c、每个线程下载文件的起始位置。最后一个线程的末位需要单独计算
d、那么就是i线程的下载起始位置： (i+1)*blocKSize-1
e、最后一个线程的末位为，资源长度-1
4、开启多个线程，每一个线程下载对应位置的文件即可。
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
public class DowloadFile{
private static int threadCount = 3;//开启3个线程
private static int blockSize = 0;//每个线程下载的大小
private static int runningTrheadCount = 0;//当前运行的线程数
private static String path = "http://192.168.13.83:8080/QQ.exe";
public static void main(String[] args) {
try{
//1.请求url地址获取服务端资源的大小
URL url = new URL(path);
HttpURLConnection openConnection = (HttpURLConnection) url.openConnection();
openConnection.setRequestMethod("GET");
openConnection.setConnectTimeout(10*1000);
int code = openConnection.getResponseCode();
if(code == 200){
//获取资源的大小
int filelength = openConnection.getContentLength();
//2.在本地创建一个与服务端资源同样大小的一个文件（占位）
RandomAccessFile randomAccessFile = new RandomAccessFile(new File(getFileName(path)), "rw");
randomAccessFile.setLength(filelength);//设置随机访问文件的大小
//3.要分配每个线程下载文件的开始位置和结束位置。
blockSize = filelength/threadCount;//计算出每个线程理论下载大小
for(int threadId =0 ;threadId < threadCount;threadId++){
int startIndex = threadId * blockSize;//计算每个线程下载的开始位置
int endIndex = (threadId+1)*blockSize -1;//计算每个线程下载的结束位置
//如果是最后一个线程，结束位置需要单独计算
if(threadId == threadCount-1){
endIndex = filelength -1;
}
//4.开启线程去执行下载
new DownloadThread(threadId, startIndex, endIndex).start();
}
}
}catch (Exception e) {
e.printStackTrace();
}
}
/**
* 下载文件的子线程，每个线程下载对应的文件
*
*/
public static class DownLoadThread extends Thread{
private int threadId;
private int startIndex;
private int endIndex;
/**
* @param threadId线程ID
* @param startIndex
* @param endIndex
*/
public DownLoadThread(int threadId, int startIndex, int endIndex) {
this.threadId = threadId;
this.startIndex = startIndex;
this.endIndex = endIndex;
}
@Override
public void run() {
try{
URL url = new URL(path);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");
//很重要：请求服务器下载部分的文件的指定的位置：
conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
conn.setConnectTimeout(5000);
int code = conn.getResponseCode();//从服务器请求全部资源 200ok ,如果请求部分资源 206 ok
System.out.println("code="+code);
InputStream is = conn.getInputStream();//返回资源
RandomAccessFile raf = new RandomAccessFile("QQ.exe", "rwd");
//随机写文件的时候从哪个位置开始写
raf.seek(startIndex);//定位文件
int len =0;
byte[] buffer = new byte[1024];
while((len = is.read(buffer)) != -1){
raf.write(buffer,0,len);
}
is.close();
raf.close();
System.out.println("线程"+threadId+"下载完毕");
}catch(Exception e){
e.printStackTrace();
}
}
}
}
