SpringBoot笔记：SpringBoot集成MinIO分布式文件系统

最新推荐文章于 2025-11-13 15:30:16 发布

原创

最新推荐文章于 2025-11-13 15:30:16 发布 · 2k 阅读

6 ·

CC 4.0 BY-SA版权

本文档详细介绍了如何在SpringBoot应用中集成MinIO，用于搭建分布式文件存储集群，并提供了完整的MinIOUtils工具类代码，涵盖了创建、删除存储桶，上传、下载、删除文件，以及获取预签名URL等功能。

文章目录

搭建MinIO集群
SpringBoot集成

搭建MinIO集群

首先搭建MinIO的分布式集群，集群搭建参考《CentOS7安装笔记：minio分布式集群搭建》

SpringBoot集成

添加依赖

首先，添加如下依赖

		<!-- Springoot集成Minio工具-->
		<dependency>
			<groupId>io.minio</groupId>
			<artifactId>minio</artifactId>
			<version>7.1.0</version>
		</dependency>

添加配置

在yml中添加如下配置：

# minio 连接参数
minio:
  # URL,域名，或者ip地址
  endpoint: minio-1
  # 端口号
  port: 9000
  # 用户名
  accessKey: myminio
  # 密码
  secretKey: Leo825Test
  # 默认的存储桶
  bucketName: testbucket

获取MinioClient

    @Value("${minio.endpoint}")
    private String endpoint;
    @Value("${minio.port}")
    private Integer port;
    @Value("${minio.accessKey}")
    private String accessKey;
    @Value("${minio.secretKey}")
    private String secretKey;
    @Value("${minio.bucketName}")
    private String bucketName;

    /**
     * 定义一个单例的MinioClient对象
     */
    private static MinioClient minioClient;

    public MinioClient getInstance() {
   
   
        if (minioClient == null) {
   
   
            minioClient = MinioClient.builder().endpoint(endpoint, port, false).credentials(accessKey, secretKey).build();
        }
        return minioClient;
    }

以上就是核心代码实现了，具体是怎么实现可以根据个人喜好。

MinioUtils完整工具类

package com.demo.util;

import io.minio.*;
import io.minio.errors.ErrorResponseException;
import io.minio.errors.InvalidExpiresRangeException;
import io.minio.messages.Bucket;
import io.minio.messages.DeleteError;
import io.minio.messages.Item;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;

/**
 * springboot集成MinIO工具类
 */
@Slf4j
@Component
public class MinioUtils {
   
   

    @Value("${minio.endpoint}")
    private String endpoint;
    @Value("${minio.port}")
    private Integer port;
    @Value("${minio.accessKey}")
    private String accessKey;
    @Value("${minio.secretKey}")
    private String secretKey;
    @Value("${minio.bucketName}")
    private String bucketName;

    /**
     * 定义一个单例的MinioClient对象
     */
    private static MinioClient minioClient;

    /**
     * 默认超时时间
     */
    private static final int DEFAULT_EXPIRY_TIME = 7 * 24 * 3600;

    public MinioClient getInstance() {
   
   
        if (minioClient == null) {
   
   
            minioClient = MinioClient.builder().endpoint(endpoint, port, false).credentials(accessKey, secretKey).build();
        }
        return minioClient;
    }

    /**
     * 检查存储桶是否存在
     *
     * @param bucketName 存储桶名称
     * @return
     */
    @SneakyThrows
    public boolean bucketExists(String bucketName) {
   
   
        boolean flag = minioClient.bucketExists(bucketName);
        if (flag) {
   
   
            return true;
        }
        return false;
    }

    /**
     * 创建存储桶
     *
     * @param bucketName 存储桶名称
     */
    @SneakyThrows
    public boolean makeBucket(String bucketName) {
   
   
        boolean flag = bucketExists(bucketName);
        if (!flag) {
   
   
            minioClient.makeBucket(bucketName);
            return true;
        } else {
   
   
            return false;
        }
    }

    /**
     * 列出所有存储桶名称
     *
     * @return
     */
    @SneakyThrows
    public List<String> listBucketNames() {
   
   
        List<Bucket> bucketList =