SpringBoot使用minio进行文件管理的流程步骤

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

dependencies {
    implementation("io.minio:minio:JAVAVERSION")
}

# minio配置
minio:
  endpoint: http://127.0.0.1:9000
  username: admin
  password: cepc_2025@admin
  bucketName: cepc

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
 
@Data
@Component
@ConfigurationProperties(prefix = "minio")
public class MinioProperties {
 
    private String endpoint;
 
    private String username;
 
    private String password;
 
    private String bucketName;
 
}

 
@Slf4j
@Component
public class UploadUtil {
 
    @Autowired
    private MinioProperties minioProperties;
 
    /**
     * 上传文件到minio并重命名
     *
     * @param multipartFile 上传文件
     * @param dirPath       文件上传路径（例如：images/pdf）
     * @param newFileName   新文件名
     * @return eTag
     * @throws Exception
     */
    public String uploadMinioRename(MultipartFile multipartFile, String dirPath, String newFileName) throws Exception {
        MinioClient minioClient =
                MinioClient.builder()
                        .endpoint(minioProperties.getEndpoint())
                        .credentials(minioProperties.getUsername(), minioProperties.getPassword())
                        .build();
 
 
        // 完整的对象名称，包括目录路径和文件名
        String objectName = dirPath + "/" + newFileName;
 
        // 上传文件
        try (InputStream is = multipartFile.getInputStream()) {
            minioClient.putObject(
                    PutObjectArgs.builder().bucket(minioProperties.getBucketName()).object(objectName).stream(
                                    is, multipartFile.getSize(), -1)
                            .contentType(multipartFile.getContentType())
                            .build());
        } catch (MinioException e) {
            log.error("Error occurred: {}", e);
            throw new Exception("Error occurred while uploading the file.", e);
        }
 
        return objectName;
    }
 
    /**
     * 删除MinIO上的文件
     *
     * @param objectName 要删除的文件对象名称（路径）
     * @throws Exception 如果删除过程中发生错误
     */
    public void deleteMinioObject(String objectName) throws Exception {
        MinioClient minioClient =
                MinioClient.builder()
                        .endpoint(minioProperties.getEndpoint())
                        .credentials(minioProperties.getUsername(), minioProperties.getPassword())
                        .build();
        try {
            // 删除对象
            minioClient.removeObject(
                    RemoveObjectArgs.builder()
                            .bucket(minioProperties.getBucketName())
                            .object(objectName)
                            .build());
        } catch (MinioException e) {
            log.error("Error occurred: {}", e);
            throw new Exception("Error occurred while deleting the file.", e);
        }
    }
 
    /**
     * 下载MinIO上的文件
     *
     * @param path 文件对象路径
     * @param fileSuffix 文件后缀
     * @throws Exception
     */
    public void downloadMinioObject(String path, HttpServletResponse response, String fileSuffix) throws Exception {
        MinioClient minioClient =
                MinioClient.builder()
                        .endpoint(minioProperties.getEndpoint())
                        .credentials(minioProperties.getUsername(), minioProperties.getPassword())
                        .build();
        try {
            // 设置响应头和内容类型
            response.setContentType("application/octet-stream");
            response.setHeader("Content-Disposition", "attachment; filename=\"" + "response."+fileSuffix + "\"");
 
            // 从MinIO获取文件
            try (InputStream is = minioClient.getObject(
                    GetObjectArgs.builder()
                            .bucket(minioProperties.getBucketName())
                            .object(path)
                            .build());
                 OutputStream os = response.getOutputStream()) {
 
                byte[] buffer = new byte[1024];
                int bytesRead;
                while ((bytesRead = is.read(buffer)) != -1) {
                    os.write(buffer, 0, bytesRead);
                }
                os.flush();
            }
        } catch (Exception e) {
            // 处理异常，设置错误状态码
            response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
            // 可以选择记录日志或者发送错误消息
            e.printStackTrace();
        }
    }
 
 
 
 
}