springboot实现minio分片上传和断点续传

在Spring Boot中实现MinIO文件服务器的分片上传和断点续传，可以使用MinIO Java SDK提供的API和Spring Boot提供的Multipart File上传功能。具体实现步骤如下：

1. 引入MinIO Java SDK和Spring Boot的依赖

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.0.4</version>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

2. 配置MinIO客户端

在Spring Boot的配置文件中，配置MinIO客户端的连接信息。

minio:
  endpoint: minio.example.com
  access-key: ACCESS_KEY
  secret-key: SECRET_KEY
  secure: false

3. 初始化Multipart上传

在上传大文件之前，使用 `InitiateMultipartUpload` API 方法初始化一个Multipart上传会话，并获取一个上传ID。上传ID用于标识一个Multipart上传会话。

import io.minio.MinioClient;
import io.minio.errors.MinioException;
import io.minio.messages.Part;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

@Service
public class MinioService {

    @Autowired
    private MinioClient minioClient;

    @Value("${minio.bucket-name}")
    private String bucketName;

    public String initiateMultipartUpload(String objectName) throws MinioException {
        String uploadId = minioClient.initiateMultipartUpload(bucketName, objectName).uploadId();
        return uploadId;
    }
}

4. 上传文件块

将大文件分成多个小块，每个小块的大小可以根据需求自定义。使用 `UploadPart` API 方法将每个小块独立上传。上传时需要指定上传的文件名、块编号、块大小以及上传ID等信息。

public class MinioService {

    // ...

    public List<Part> uploadParts(String objectName, String uploadId, MultipartFile file, int partSize) throws IOException, MinioException {
        List<Part> parts = new ArrayList<>();
        int partNumber = 1;
        byte[] buffer = new byte[partSize];
        while (true) {
            int bytesRead = file.getInputStream().read(buffer);
            if (bytesRead < 0) {
                break;
            }
            byte[] partData = new byte[bytesRead];
            System.arraycopy(buffer, 0, partData, 0, bytesRead);
            Part part = minioClient.uploadPart(
                    bucketName, objectName, partNumber, uploadId, partData, bytesRead);
            parts.add(part);
            partNumber++;
        }
        return parts;
    }
}

5. 完成Multipart上传

上传所有文件块后，使用 `CompleteMultipartUpload` API 方法将它们合并成一个完整的文件，最终得到上传的文件。

public class MinioService {

    // ...

    public void completeMultipartUpload(String objectName, String uploadId, List<Part> parts) throws MinioException {
        minioClient.completeMultipartUpload(bucketName, objectName, uploadId, parts);
    }
}

6. 断点续传

如果上传中断，可以使用 `ListParts` API 方法获取已上传的文件块信息，然后从中断处继续上传。

public class MinioService {

    // ...

    public List<Part> listParts(String objectName, String uploadId) throws MinioException {
        return minioClient.listParts(bucketName, objectName, uploadId).getParts();
    }
}

使用Spring Boot的Multipart File上传功能上传文件时，需要在Controller中添加 `@RequestParam("file") MultipartFile file` 注解，自动将文件转换为MultipartFile类型。

@RestController
@RequestMapping("/file")
public class FileController {

    @Autowired
    private MinioService minioService;

    @PostMapping("/upload")
    public void uploadFile(@RequestParam("file") MultipartFile file) throws IOException, MinioException {
        // 获取文件名和文件大小
        String fileName = file.getOriginalFilename();
        long fileSize = file.getSize();
        // 定义块大小（5MB）
        int partSize = 5 * 1024 * 1024;
        // 初始化Multipart上传会话
        String uploadId = minioService.initiateMultipartUpload(fileName);
        // 上传文件块
        List<Part> parts = minioService.uploadParts(fileName, uploadId, file, partSize);
        // 完成Multipart上传
        minioService.completeMultipartUpload(fileName, uploadId, parts);
    }

    @PostMapping("/resume")
    public void resumeUpload(@RequestParam("file") MultipartFile file, String objectName, String uploadId) throws IOException, MinioException {
        // 获取已上传的文件块信息
        List<Part> parts = minioService.listParts(objectName, uploadId);
        // 上传文件块
        parts = minioService.uploadParts(objectName, uploadId, file, partSize);
        // 完成Multipart上传
        minioService.completeMultipartUpload(objectName, uploadId, parts);
    }
}

以上是使用Spring Boot实现MinIO文件服务器的分片上传和断点续传的基本步骤，具体实现还需要根据实际需求进行调整。