当前位置：首页 > news >正文

使用 Spring Boot 3.2 集成 MinIO 8.5：实现高效对象存储

news 来源：原创 2025/4/30 9:06:25

摘要
MinIO 是一款高性能的分布式对象存储服务，与云原生应用完美契合。本文将手把手教你如何在 Spring Boot 3.2 项目中集成 MinIO 8.5 版本，实现文件上传、下载和删除等核心功能，并提供完整代码示例和常见问题解决方案。

一、环境准备

JDK 17+（Spring Boot 3.x 要求）
Maven 3.6+ 或 Gradle
MinIO Server 8.5+（本地或远程）

二、创建 Spring Boot 项目

通过 Spring Initializr 生成项目，选择：
- Spring Boot 3.2
- 依赖：Spring Web、Lombok
添加 MinIO 依赖（pom.xml）：

<XML>

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

三、配置 MinIO 客户端

1. 配置参数（application.yml）

<YAML>

minio:
  endpoint: http://127.0.0.1:9000  #指定虚拟机ip地址
  access-key: minioadmin # 默认账号
  secret-key: minioadmin # 默认密码
  bucket-name: mybucket # 存储桶名称

2. 创建配置类

<JAVA>

@Configuration
public class MinioConfig {

    @Value("${minio.endpoint}")
    private String endpoint;
    @Value("${minio.access-key}")
    private String accessKey;
    @Value("${minio.secret-key}")
    private String secretKey;

    //虽然MinioClient对象是单例的，但是是线程安全。具体可以参考github源码
    @Bean
    public MinioClient minioClient() {
        //链式编程构建客户端对象
        return MinioClient.builder()
                .endpoint(endpoint) //指定ip地址去访问minio服务器
                .credentials(accessKey, secretKey)//指定访问账号密码
                .build();
    }
}

四、实现文件操作 Service

文件上传工具类

<JAVA>

@Service
@RequiredArgsConstructor
public class MinioService {

    private final MinioClient minioClient;
    private final MinioProperties properties;

    // 初始化存储桶
    @PostConstruct
    public void init() throws Exception {
        boolean exists = minioClient.bucketExists(BucketExistsArgs.builder()
                .bucket(properties.getBucketName())
                .build());
        if (!exists) {
            minioClient.makeBucket(MakeBucketArgs.builder()
                    .bucket(properties.getBucketName())
                    .build());
        }
    }

    // 上传文件
    public String uploadFile(MultipartFile file, String objectName) throws Exception {
        if (file.isEmpty()) {
            throw new IllegalArgumentException("文件不能为空");
        }
        minioClient.putObject(PutObjectArgs.builder()
                .bucket(properties.getBucketName())
                .object(objectName)
                .stream(file.getInputStream(), file.getSize(), -1)
                .contentType(file.getContentType())
                .build());
        return objectName;
    }

    // 下载文件
    public byte[] downloadFile(String objectName) throws Exception {
        try (InputStream stream = minioClient.getObject(GetObjectArgs.builder()
                .bucket(properties.getBucketName())
                .object(objectName)
                .build())) {
            return IOUtils.toByteArray(stream);
        }
    }

    // 删除文件
    public void deleteFile(String objectName) throws Exception {
        minioClient.removeObject(RemoveObjectArgs.builder()
                .bucket(properties.getBucketName())
                .object(objectName)
                .build());
    }
}

五、具体关于minioclient常用方法讲解可以参考该篇文章

https://blog.csdn.net/z2637305611/article/details/146523025?sharetype=blogdetail&sharerId=146523025&sharerefer=PC&sharesource=z2637305611&spm=11.2480.3001.8118

六、测试 API

使用 Postman 测试：

上传文件
- 方法: POST
- 路径: /api/files/upload
- Body → form-data → file 字段选择文件
下载文件
- 方法: GET
- 路径: /api/files/download/{objectName}
删除文件
- 方法: DELETE
- 路径: /api/files/{objectName}