SpringBoot中實現(xiàn)大文件分片下載和斷點續(xù)傳功能的完整指南

更新時間：2025年09月08日 09:15:25 作者：IT界Tony哥

在Spring Boot中實現(xiàn)大文件分片下載和斷點續(xù)傳功能,需結(jié)合HTTP Range協(xié)議和文件流處理技術(shù),本文將展示完整的實現(xiàn)方法,有需要的小伙伴可以參考一下

??一、核心原理??

??HTTP Range協(xié)議??

通過Range請求頭指定下載范圍（如Range: bytes=0-999），服務(wù)器返回206 Partial Content狀態(tài)碼及對應(yīng)內(nèi)容片段。

??斷點續(xù)傳機制??

客戶端記錄已下載的字節(jié)范圍，網(wǎng)絡(luò)中斷后通過Range頭續(xù)傳未完成部分。

??二、服務(wù)端實現(xiàn)??

??1. 分片下載接口??

@GetMapping("/download")
public ResponseEntity<InputStreamResource> downloadFile(
    @RequestHeader(value = "Range", required = false) String rangeHeader,
    HttpServletRequest request) throws IOException {
    
    // 獲取文件信息
    File file = new File("/path/to/largefile.zip");
    long fileSize = file.length();
    
    // 解析Range頭
    long start = 0, end = fileSize - 1;
    if (rangeHeader != null) {
        String[] ranges = rangeHeader.replace("bytes=", "").split("-");
        start = Long.parseLong(ranges[0]);
        if (ranges.length > 1) {
            end = Long.parseLong(ranges[1]);
        }
    }
    
    // 校驗范圍合法性
    if (start >= fileSize || end >= fileSize || start > end) {
        return ResponseEntity.status(HttpStatus.REQUESTED_RANGE_NOT_SATISFIABLE)
                .header("Content-Range", "bytes */" + fileSize)
                .build();
    }
    
    // 設(shè)置響應(yīng)頭
    HttpHeaders headers = new HttpHeaders();
    headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
    headers.setContentLength(end - start + 1);
    headers.setHeader("Content-Range", "bytes " + start + "-" + end + "/" + fileSize);
    headers.setHeader("Accept-Ranges", "bytes");
    
    // 返回分片數(shù)據(jù)流
    try (InputStream is = new FileInputStream(file);
         InputStreamResource resource = new InputStreamResource(is)) {
        is.skip(start);
        return new ResponseEntity<>(resource, headers, HttpStatus.PARTIAL_CONTENT);
    }
}

??2. 斷點續(xù)傳支持??

??客戶端記錄進(jìn)度??：保存已下載的字節(jié)范圍（如0-999）。

??續(xù)傳請求??：重新發(fā)起請求時攜帶Range: bytes=1000-，服務(wù)器從斷點處繼續(xù)傳輸。

??三、客戶端實現(xiàn)（JavaScript示例）??

// 分片下載邏輯
async function downloadFileWithResume(fileId, fileName) {
  const CHUNK_SIZE = 5 * 1024 * 1024; // 5MB
  let downloadedBytes = 0;
  
  // 獲取文件總大小
  const response = await fetch(`/api/files/${fileId}/size`);
  const totalSize = parseInt(await response.text());
  
  // 檢查本地是否有已下載部分
  const tempFile = await checkLocalProgress(fileName);
  if (tempFile) {
    downloadedBytes = tempFile.size;
  }
  
  // 分片下載
  while (downloadedBytes < totalSize) {
    const end = Math.min(downloadedBytes + CHUNK_SIZE - 1, totalSize - 1);
    const response = await fetch(`/api/files/${fileId}/download`, {
      headers: { Range: `bytes=${downloadedBytes}-${end}` }
    });
    
    if (!response.ok) throw new Error("下載失敗");
    
    const blob = await response.blob();
    await appendToFile(tempFile, blob);
    downloadedBytes += blob.size;
    
    // 更新進(jìn)度
    updateProgress(downloadedBytes / totalSize);
  }
  
  // 完成后重命名文件
  await renameTempFile(tempFile, fileName);
}

// 檢查本地進(jìn)度
async function checkLocalProgress(fileName) {
  const tempPath = `/temp/${fileName}.part`;
  return new Promise(resolve => {
    fs.stat(tempPath, (err, stats) => {
      if (err) resolve(null);
      else resolve(fs.createWriteStream(tempPath, { flags: 'a' }));
    });
  });
}

??四、關(guān)鍵優(yōu)化點??

??內(nèi)存管理??

使用InputStream流式傳輸，避免大文件加載到內(nèi)存。

??并發(fā)控制??

通過線程池限制同時下載的分片數(shù)：

@Service
public class DownloadService {
    private final ExecutorService executor = Executors.newFixedThreadPool(10);
    
    public void downloadChunk(String fileId, long start, long end) {
        executor.submit(() -> {
            // 分片下載邏輯
        });
    }
}

??進(jìn)度存儲??

使用Redis記錄每個文件的下載進(jìn)度：

@Autowired
private RedisTemplate<String, String> redisTemplate;

public void saveProgress(String fileId, long downloadedBytes) {
    redisTemplate.opsForValue().set(fileId, String.valueOf(downloadedBytes));
}

??五、測試方案??

??正常下載??

curl -H "Range: bytes=0-999" http://localhost:8080/download

??斷點續(xù)傳??

中斷后重新發(fā)起相同請求，驗證是否從斷點續(xù)傳。

??多線程下載??

使用工具（如Postman）模擬多線程分片請求。

??六、擴展場景??

??視頻流播放??：通過Content-Range實現(xiàn)視頻邊下邊播。
??大文件秒傳??：基于文件MD5校驗，避免重復(fù)傳輸。
??分布式存儲??：結(jié)合MinIO/S3實現(xiàn)分片存儲與合并。

通過上述方案，可高效實現(xiàn)大文件的分片下載和斷點續(xù)傳，支持弱網(wǎng)環(huán)境和超大文件傳輸。完整代碼示例可參考GitHub倉庫（需替換實際存儲路徑）。

到此這篇關(guān)于SpringBoot中實現(xiàn)大文件分片下載和斷點續(xù)傳功能的完整指南的文章就介紹到這了,更多相關(guān)SpringBoot大文件分片下載和斷點續(xù)傳內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持

您可能感興趣的文章: