<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();
 
 
        // 完整的對(duì)象名稱(chēng)，包括目錄路徑和文件名
        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 要?jiǎng)h除的文件對(duì)象名稱(chēng)（路徑）
     * @throws Exception 如果刪除過(guò)程中發(fā)生錯(cuò)誤
     */
    public void deleteMinioObject(String objectName) throws Exception {
        MinioClient minioClient =
                MinioClient.builder()
                        .endpoint(minioProperties.getEndpoint())
                        .credentials(minioProperties.getUsername(), minioProperties.getPassword())
                        .build();
        try {
            // 刪除對(duì)象
            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 文件對(duì)象路徑
     * @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 {
            // 設(shè)置響應(yīng)頭和內(nèi)容類(lèi)型
            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) {
            // 處理異常，設(shè)置錯(cuò)誤狀態(tài)碼
            response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
            // 可以選擇記錄日志或者發(fā)送錯(cuò)誤消息
            e.printStackTrace();
        }
    }
 
 
 
 
}