Java断点续传(文件分块)完整实现步骤

package com.xuecheng.media;

import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.io.IOUtils;
import org.junit.jupiter.api.Test;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.*;

public class BigFileTest {
    //测试文件分块方法
    @Test
    public void testChunk() throws IOException {

File sourceFile = new File("d:/develop/bigfile_test/nacos.mp4");
String chunkPath = "d:/develop/bigfile_test/chunk/";
File chunkFolder = new File(chunkPath);
if (!chunkFolder.exists()) {
    chunkFolder.mkdirs();
}

//分块大小
long chunkSize = 1024 * 1024 * 1;
//分块数量
long chunkNum = (long) Math.ceil(sourceFile.length() * 1.0 / chunkSize);
System.out.println("分块总数：" + chunkNum);

//缓冲区大小
byte[] b = new byte[1024];
//使用RandomAccessFile访问文件
RandomAccessFile raf_read = new RandomAccessFile(sourceFile, "r");
//分块
for (int i = 0; i < chunkNum; i++) {
    //创建分块文件
    File file = new File(chunkPath + i);
    if (file.exists()) {
        file.delete();
    }
    boolean newFile = file.createNewFile();
    if (newFile) {
        //向分块文件中写数据
        RandomAccessFile raf_write = new RandomAccessFile(file, "rw");
        int len = -1;
        while ((len = raf_read.read(b))!= -1) {
            raf_write.write(b, 0, len);
            if (file.length() >= chunkSize) {
                break;
            }
        }
        raf_write.close();
        System.out.println("完成分块" + i);
    }
}
raf_read.close();

File chunkFolder = new File("D:\\...\\chunk\\");  // 分块文件目录
File sourceFile = new File("D:\\...\\星际牛仔1.mp4");  // 原始文件
File mergeFile = new File("D:\\...\\星际牛仔1-1.mp4");  // 合并后的文件
mergeFile.createNewFile();  // 创建空的目标文件

RandomAccessFile raf_write = new RandomAccessFile(mergeFile, "rw");  // 以读写模式打开合并文件
byte[] buffer = new byte[1024];  // 读写缓冲区（1KB）

//listFiles（）表示返回目录中所有文件和子目录的File数组，files是包含所有分块文件的数组
File[] files = chunkFolder.listFiles();
//将数组转换为list集合，fileList是包含所以分块文件的list<File>
List<File> fileList = Arrays.asList(files);
//然后对List进行排序，Comparator.comparingInt创建一个比较器，按照指定规则排序（将文件名转换为整数进行排序）
Collections.sort(fileList, Comparator.comparingInt(o -> Integer.parseInt(o.getName())));

//循环遍历分块文件列表
for (File chunkFile : fileList) {
//以只读模式打开分块文件 "r"表示以只读模式打开
    RandomAccessFile raf_read = new RandomAccessFile(chunkFile, "r"); 
//读取分块文件内容并写入合并文件
    int len;
    while ((len = raf_read.read(buffer)) != -1) {  
        raf_write.write(buffer, 0, len);  
    }
    raf_read.close();  // 关闭分块文件流
}
raf_write.close();  // 关闭合并文件流