springboot 封装 minio

### 封装 MinIO 实现对象存储功能 为了在 Spring Boot 项目中实现 MinIO 的集成并提供对象存储的功能，可以按照如下方式构建应用。 #### 添加依赖 首先，在 `pom.xml` 中加入 MinIO SDK 的 Maven 依赖： ```xml <dependency> <groupId>io.minio</groupId> <artifactId>minio</artifactId> <version>8.4.4</version> </dependency> ``` 这段代码定义了用于访问 MinIO 服务器所需的库文件[^2]。 #### 配置属性 接着设置应用程序的配置文件 (`application.yml`) 来指定 MinIO 连接参数： ```yaml minio: endpoint: http://localhost:9000 accessKey: minioadmin secretKey: minioadmin bucketName: my-bucket-name ``` 这些配置项指定了 MinIO 服务的位置以及认证凭证等信息[^3]。 #### 创建 MinIO 客户端 Bean 通过编写 Java 类来初始化 MinIO Client 对象作为 Spring 上下文中可注入的一个 bean: ```java import io.minio.MinioClient; import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; @Component public class MinioConfig { private final String endpoint; private final String accessKey; private final String secretKey; public MinioConfig( @Value("${minio.endpoint}") String endpoint, @Value("${minio.accessKey}") String accessKey, @Value("${minio.secretKey}") String secretKey) { this.endpoint = endpoint; this.accessKey = accessKey; this.secretKey = secretKey; } @Bean public MinioClient minioClient() throws Exception { return MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); } } ``` 上述代码展示了如何利用构造函数注入的方式读取配置中的值，并据此建立与 MinIO Server 的连接实例[^4]。 #### 提供上传/下载接口 最后一步是开发具体业务逻辑的服务层组件，这里给出简单的例子展示怎样上传和下载文件至 MinIO 存储空间内： ```java import io.minio.PutObjectArgs; import io.minio.GetObjectArgs; import java.io.InputStream; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; @Service @RequiredArgsConstructor public class FileService { private final MinioClient minioClient; // Upload file to specified bucket. public void uploadFile(String fileName, InputStream inputStream){ try{ PutObjectArgs objectWriteResponse = PutObjectArgs.builder() .bucket("my-bucket-name") .object(fileName) .stream(inputStream, -1, 10485760)//chunk size is set as 10MB here .contentType("application/octet-stream") .build(); minioClient.putObject(objectWriteResponse); } catch (Exception e){ throw new RuntimeException(e.getMessage()); } } // Download file from the given bucket name and save it into output stream. public InputStream downloadFile(String fileName){ GetObjectArgs getObjectArgs = GetObjectArgs.builder() .bucket("my-bucket-name") .object(fileName).build(); try { return minioClient.getObject(getObjectArgs); } catch (Exception ex) { throw new RuntimeException(ex.getMessage()); } } } ``` 以上实现了两个基本操作——向特定桶里放置新文件(`uploadFile`) 和获取已存档的数据流(`downloadFile`)。注意这里的异常处理采用了最简单形式；实际生产环境中应当更加严谨地对待可能出现的各种状况。