如何使用Java实现断点续传下载 Java处理分块数据传输实例

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;

public class ResumableDownloader {

    public void downloadFile(String urlString, String savePath) throws IOException {
        File outputFile = new File(savePath);
        long downloadedSize = 0; // 记录已下载的字节数

        // 检查本地文件是否存在，如果存在则获取其大小，作为断点续传的起点
        if (outputFile.exists()) {
            downloadedSize = outputFile.length();
            System.out.println("检测到文件已存在，尝试从断点续传，已下载: " + downloadedSize + " 字节");
        } else {
            System.out.println("文件不存在，开始全新下载。");
        }

        HttpURLConnection connection = null;
        InputStream is = null;
        RandomAccessFile raf = null; // 使用RandomAccessFile进行随机写入

        try {
            URL url = new URL(urlString);
            connection = (HttpURLConnection) url.openConnection();
            connection.setRequestMethod("GET");
            connection.setConnectTimeout(10000); // 连接超时
            connection.setReadTimeout(15000);    // 读取超时

            // 设置Range头部，实现断点续传的关键
            if (downloadedSize > 0) {
                connection.setRequestProperty("Range", "bytes=" + downloadedSize + "-");
            }

            int responseCode = connection.getResponseCode();
            long totalSize = -1; // 总文件大小

            // 处理服务器响应
            if (responseCode == HttpURLConnection.HTTP_PARTIAL) { // 206 Partial Content
                // 服务器支持断点续传，且返回部分内容
                String contentRange = connection.getHeaderField("Content-Range");
                if (contentRange != null && contentRange.startsWith("bytes")) {
                    // 解析Content-Range获取总文件大小，例如 "bytes 0-100/2000"
                    int slashIndex = contentRange.indexOf('/');
                    if (slashIndex != -1) {
                        totalSize = Long.parseLong(contentRange.substring(slashIndex + 1));
                    }
                }
                System.out.println("服务器返回206 Partial Content，继续下载。总文件大小预估: " + (totalSize == -1 ? "未知" : totalSize + " 字节"));
            } else if (responseCode == HttpURLConnection.HTTP_OK) { // 200 OK
                // 服务器不支持断点续传，或者Range请求被忽略，或者这是一个全新的下载
                // 此时，需要重新开始下载，清空之前可能存在的半成品文件
                System.out.println("服务器返回200 OK，可能不支持断点续传或Range请求被忽略，将重新下载。");
                downloadedSize = 0; // 重置已下载大小
                if (outputFile.exists()) {
                    outputFile.delete(); // 删除旧的、不完整的或错误的文件
                }
                totalSize = connection.getContentLength(); // 获取完整的总文件大小
            } else {
                // 其他非成功响应码
                throw new IOException("下载失败，服务器返回非成功响应码: " + responseCode);
            }

            // 如果Content-Length可用，更新总大小（200 OK时直接获取，206时需要计算）
            if (totalSize == -1) { // 如果之前没能从Content-Range获取到总大小
                 long contentLengthHeader = connection.getContentLength();
                 if (contentLengthHeader != -1) {
                     // 对于206，Content-Length是剩余部分的大小
                     // 对于200，Content-Length是全部大小
                     if (responseCode == HttpURLConnection.HTTP_PARTIAL) {
                         totalSize = downloadedSize + contentLengthHeader;
                     } else {
                         totalSize = contentLengthHeader;
                     }
                 }
            }


            is = connection.getInputStream();
            raf = new RandomAccessFile(outputFile, "rw");
            raf.seek(downloadedSize); // 将文件指针移动到已下载内容的末尾

            byte[] buffer = new byte[8192]; // 缓冲区大小，可以根据实际情况调整
            int bytesRead;
            long currentDownloaded = downloadedSize; // 用于实时更新进度

            while ((bytesRead = is.read(buffer)) != -1) {
                raf.write(buffer, 0, bytesRead);
                currentDownloaded += bytesRead;
                // 这里可以加入进度回调，例如：
                // System.out.printf("\r正在下载: %.2f%% (%d/%d 字节)", 
                //     (double)currentDownloaded / totalSize * 100, currentDownloaded, totalSize);
            }
            System.out.println("\n文件下载完成。总大小: " + currentDownloaded + " 字节");

        } catch (IOException e) {
            System.err.println("下载过程中发生错误: " + e.getMessage());
            // 错误发生时，已下载的大小仍然保留在文件中，下次可以继续
        } finally {
            // 确保所有资源被关闭
            if (is != null) {
                try { is.close(); } catch (IOException e) { /* ignore */ }
            }
            if (raf != null) {
                try { raf.close(); } catch (IOException e) { /* ignore */ }
            }
            if (connection != null) {
                connection.disconnect();
            }
        }
    }

    public static void main(String[] args) {
        ResumableDownloader downloader = new ResumableDownloader();
        String fileUrl = "http://example.com/large_file.zip"; // 替换为你要下载的实际URL
        String savePath = "downloaded_file.zip"; // 替换为你要保存的路径

        // 模拟下载
        try {
            downloader.downloadFile(fileUrl, savePath);
        } catch (IOException e) {
            System.err.println("主程序执行异常: " + e.getMessage());
        }
    }
}