# Spring Boot 實(shí)現(xiàn)分片上傳、斷點(diǎn)續(xù)傳與進(jìn)度條  
## —— 支持 MinIO / RustFS / SeaweedFS 可配置切換
在大文件上傳場景下，傳統(tǒng)單次上傳存在明顯問題：
- 文件過大，失敗后需要整體重傳
- 網(wǎng)絡(luò)不穩(wěn)定，用戶體驗(yàn)差
- 無法展示上傳進(jìn)度
本文基于 **Spring Boot**，實(shí)現(xiàn)一套**生產(chǎn)可用**的大文件上傳方案，支持：
- 分片上傳
- 斷點(diǎn)續(xù)傳
- 上傳進(jìn)度查詢
- MinIO / RustFS / SeaweedFS / 本地存儲
- 通過 yml 配置文件切換存儲類型
---
## 一、整體架構(gòu)設(shè)計(jì)
系統(tǒng)整體采用「接口隔離 + 策略模式」設(shè)計(jì)：

**核心思想：上傳邏輯與底層存儲解耦。**
---
## 二、統(tǒng)一配置設(shè)計(jì)
### 1. 存儲類型切換
```yaml
file:
  path: file/
  prefix: pre
  domain: domain/
  storage:
    type: minio   # minio / rustfs / seaweedfs / local

minio:
  url: http://localhost:9000
  accessKey: minioadmin
  secretKey: minioadmin123
  bucketName: xxx

rustfs:
  url: http://localhost:9000
  accessKey: rustfsadmin
  secretKey: rustfsadmin
  bucketName: xxx

seaweedfs:
  url: http://127.0.0.1:8333
  accessKey: weed
  secretKey: weed
  bucketName: xxx

file
├── chunk_0
├── chunk_1
├── chunk_2
└── chunk_n

POST /file/chunk/upload

GET /file/chunk/uploaded?guid=xxx

[0,1,3,5]

進(jìn)度 = 已上傳分片數(shù) / 總分片數(shù) × 100%

{
  "uploaded": 6,
  "total": 10,
  "percent": 60
}

public interface StorageService {
    void uploadChunk(String path, InputStream inputStream);
    boolean exists(String path);
    List<Integer> listChunks(String prefix);
    void mergeChunks(String chunkPrefix, String targetPath, int totalChunk);
    void deleteChunks(String chunkPrefix);
}

@Slf4j
public class MinioStorageService implements StorageService {
    private final MinioClient minioClient;
    private final String bucket;
    public MinioStorageService(MinioClient client, String bucket) {
        this.minioClient = client;
        this.bucket = bucket;
    }
    @Override
    public void uploadChunk(String path, InputStream inputStream) {
        try {
            minioClient.putObject(
                PutObjectArgs.builder()
                    .bucket(bucket)
                    .object(path)
                    .stream(inputStream, -1, 5 * 1024 * 1024)
                    .build()
            );
        } catch (Exception e) {
            throw new RuntimeException("分片上傳失敗", e);
        }
    }
    @Override
    public boolean exists(String path) {
        try {
            minioClient.statObject(
                StatObjectArgs.builder()
                    .bucket(bucket)
                    .object(path)
                    .build()
            );
            return true;
        } catch (Exception e) {
            return false;
        }
    }
    @Override
    public List<Integer> listChunks(String prefix) {
        List<Integer> chunks = new ArrayList<>();
        Iterable<Result<Item>> results =
            minioClient.listObjects(
                ListObjectsArgs.builder()
                    .bucket(bucket)
                    .prefix(prefix)
                    .build()
            );
        for (Result<Item> r : results) {
            String name = r.get().objectName();
            chunks.add(Integer.parseInt(
                name.substring(name.lastIndexOf("_") + 1)));
        }
        return chunks;
    }
    @Override
    public void mergeChunks(String chunkPrefix,
                            String targetPath,
                            int totalChunk) {
        try {
            ByteArrayOutputStream out = new ByteArrayOutputStream();
            for (int i = 0; i < totalChunk; i++) {
                InputStream in = minioClient.getObject(
                    GetObjectArgs.builder()
                        .bucket(bucket)
                        .object(chunkPrefix + "/chunk_" + i)
                        .build()
                );
                IOUtils.copy(in, out);
            }
            uploadChunk(
                targetPath,
                new ByteArrayInputStream(out.toByteArray()));
        } catch (Exception e) {
            throw new RuntimeException("分片合并失敗", e);
        }
    }
    @Override
    public void deleteChunks(String chunkPrefix) {
        // 可按需實(shí)現(xiàn)批量刪除
    }
}

@Service
public class FileUploadServiceImpl implements FileUploadService {
    @Autowired
    private StorageService storageService;
    @Override
    public void uploadChunk(ChunkUploadDTO dto) throws IOException {
        String path = dto.getGuid() + "/chunk_" + dto.getChunkIndex();
        if (storageService.exists(path)) {
            return;
        }
        storageService.uploadChunk(
            path, dto.getFile().getInputStream());
    }
    @Override
    public List<Integer> uploadedChunks(String guid) {
        return storageService.listChunks(guid + "/");
    }
    @Override
    public void merge(String guid, int totalChunk) {
        storageService.mergeChunks(
            guid, guid + ".final", totalChunk);
        storageService.deleteChunks(guid + "/");
    }
}

@RestController
@RequestMapping("/file/chunk")
public class FileUploadController {
    @Autowired
    private FileUploadService fileUploadService;
    @PostMapping("/upload")
    public void upload(ChunkUploadDTO dto) throws IOException {
        fileUploadService.uploadChunk(dto);
    }
    @GetMapping("/uploaded")
    public List<Integer> uploaded(@RequestParam String guid) {
        return fileUploadService.uploadedChunks(guid);
    }
    @PostMapping("/merge")
    public void merge(@RequestParam String guid,
                      @RequestParam Integer totalChunk) {
        fileUploadService.merge(guid, totalChunk);
    }
}