Java多线程断点续传下载实现详解

实现目标与核心逻辑

实现多线程断点续传主要解决两个问题：一是并发加速，将文件分块由不同线程并行下载；二是状态保持，在每次操作失败或中断时，能够知道从哪个字节位置继续。实现过程分为准备阶段、多线程序划分、以及子线程的具体执行逻辑。

第一阶段：主线程初始化与任务拆分

主线程负责建立与服务器的连接，获取文件总大小，并将下载任务分配给各个子线程。同时，需要在磁盘上创建一个与远程文件等大的临时容器，以便后续各线程可以按偏移量写入数据。

第1步：建立连接并获取文件信息

首先使用HttpURLConnection发起GET请求，验证连接状态码是否为200（成功），并通过getContentLength()获取目标文件的总字节长度。这是计算每个线程下载范围的基础参数。

第2步：创建本地存储与线程池映射

实例化RandomAccessFile对象，以"rwd"模式打开本地目标文件，并通过setLength(length)预先分配文件大小，确保磁盘空间足够。接着，根据设定的线程数threadCount，计算每个线程应承担的数据块大小size。遍历所有线程ID，计算出每个线程负责的起始位置startIndex和结束位置endIndex。特别注意最后一个线程，其结束位置应修正为文件末尾索引length - 1，以防止数据遗漏。

package com.edu.thread;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;

public class MultiDownload2 {
	static String path = "http://localhost:8080/wlan.zip";
	//开启线程的数量
	static int threadCount = 6;
	//下载结束的线程数
	static int threadFinished = 0;
	public static void main(String[] args) {
	try {
		URL url = new URL(path);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		conn.setRequestMethod("GET");
		conn.setConnectTimeout(5000);
		conn.setReadTimeout(5000);
		//此时只是确定和服务器建立了连接，但并没有开始下载任务
		if (conn.getResponseCode()==200) {
			//拿到文件的长度
			int length = conn.getContentLength();
			//指定文件路径和文件名
			File file = new File("d://文件测试", getFileName(path));
			//创建随机存储文件大小，为了建立一个和源文件大小相同的存储区间
			RandomAccessFile raf = new RandomAccessFile(file, "rwd");
			//设置临时文件的大小，和服务器文件一模一样
			raf.setLength(length);
			//计算每个线程下载的字节数
			int size = length / threadCount;
			//计算三个线程下载的开始位置和结束位置
			for (int i = 0; i < threadCount; i++) {
				int startIndex = i * size;
				int endIndex = (i + 1) * size-1;
				//如果是最后一个线程，要把结尾读完
				if (i == threadCount-1) {
					//length从0开始读，所以length-1表示最后一个字节
					endIndex = length-1;
				}
				//打印三个线程的开始与结束位置
				System.out.println("线程"+i+"的开始和结束位置："+startIndex+"----"+endIndex);
				//开启线程，传入线程ID，下载的开始位置和下载的结束位置
				new DownloadThread(i, startIndex, endIndex).start();;
			}
		}
	} catch (Exception e) {
		e.printStackTrace();
	}
}
/*
* 获取文件名
*/
public static String getFileName(String path){
	int index=path.lastIndexOf("/");
	return path.substring(index + 1);
}
}