脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot整合Minio

SpringBoot整合Minio的过程(支持公有及私有bucket)

 更新时间：2025年03月27日 10:11:18   作者：一恍过去  
Bucket 是存储Object的逻辑空间,每个Bucket之间的数据是相互隔离的,对用户而言,相当于存放文件的顶层文件夹,这篇文章主要介绍了SpringBoot整合Minio的过程(支持公有及私有bucket),需要的朋友可以参考下

1、Bucket、Object

  • Bucket 是存储Object的逻辑空间，每个Bucket之间的数据是相互隔离的，对用户而言，相当于存放文件的顶层文件夹；
  • Object 是存储到MinIO的基本对象，对用户而言，相当于文件；

2、常用API

  • bucketExists()：用于检查指定的存储桶是否存在，返回布尔值，表示存储桶是否存在；
  • makeBucket()：用于创建一个新的存储桶（bucket），需要指定存储桶的名称；
  • listBuckets()：用于列出用户有权访问的所有存储桶，返回存储桶的列表；
  • removeBucket()：用于删除一个已存在的存储桶（bucket），删除失败会抛出异常；
  • putObject()：用于上传文件到指定的存储桶；
  • statObject()：用于检查指定的对象（文件）的状态，判断是否存在；
  • getPresignedObjectUrl()：用于生成一个对象（文件）的签名URL，以便可以通过HTTP访问；
  • getObject()：用于从指定的存储桶中下载文件；
  • listObjects()：用于列出指定存储桶中的所有对象（文件）；
  • removeObject()：用于删除指定存储桶中的对象，需要指定存储桶名称和对象键；

3、整合SpringBoot

引入POM包：

    <dependencies>
		<!-- minio -->
        <dependency>
            <groupId>io.minio</groupId>
            <artifactId>minio</artifactId>
            <version>8.5.9</version>
        </dependency>
	</dependencies>

3.1、yaml配置

minio:
  # 连接地址
  endpoint: http://127.0.0.1:9000
  # 用户名
  accessKey: admin
  # 密码
  secretKey: 123456789
  # 设置共有桶，具体名称可以在MinIo后台设置，可以直接访问，格式：http://1ip:port/bucketName/fileName
  publicBucket: public-test
  # 设置私有桶，具体名称可以在MinIo后台设置，需要通过getPresignedObjectUrl方法获取签名链接
  privateBucket: private-test

3.2、MinIo配置

MinIOInfoConfig：

@Data
@Component
@ConfigurationProperties(prefix = "minio")
public class MinIOInfoConfig {
    /**
     * 连接地址
     */
    private String endpoint;
    /**
     * 用户名
     */
    private String accessKey;
    /**
     * 密码
     */
    private String secretKey;
    /**
     * 私有bucket
     */
    private String privateBucket;
    /**
     * 公共bucket
     */
    private String publicBucket;
}

MinioConfig：

import io.minio.MinioClient;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class MinioConfig {
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
    @Bean
    public MinioClient minioClient() {
        //链式编程，构建MinioClient对象
        return MinioClient.builder()
                .endpoint(minIOInfoConfig.getEndpoint())
                .credentials(minIOInfoConfig.getAccessKey(), minIOInfoConfig.getSecretKey())
                .build();
    }
}

3.3、Bucket 操作

上传文件前，需要先进行Bucket 的创建操作，可以直接到MinIo后台进行创建，也可以通过API接口进行创建，代码示例如下

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    public void bucket() {
        try {
            String bucketName = "test-bucket";
            // 判断是否存在
            boolean bucketExists = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            System.out.println("bucketExists1 = " + bucketExists);
            // 创建
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
            // 再次判断
            bucketExists = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            System.out.println("bucketExists2 = " + bucketExists);
            // 查询列表
            List<Bucket> bucketList = minioClient.listBuckets();
            List<String> list = bucketList.stream().map(Bucket::name).toList();
            System.out.println("bucketList = " + list);
            // 删除
            minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());
            // 再次判断
            bucketExists = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            System.out.println("bucketExists3 = " + bucketExists);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}

3.4、Object操作

1. 上传文件

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
        public void upload(MultipartFile file) {
        try {
            String originalFilename = file.getOriginalFilename();
            // 上传文件
            minioClient.putObject(PutObjectArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    .object(originalFilename)
                    .stream(file.getInputStream(), file.getSize(), -1)
                    .build()
            );
            // 判断文件是否存在
            // 获取访问地址
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}

2、获取文件状态(是否存在)

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
    public void fileState(String fileName) {
        try {
            StatObjectResponse response = minioClient.statObject(StatObjectArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    .object(fileName)
                    .build());
            System.out.println("response = " + response);
        } catch (Exception e) {
            log.error("文件不存在");
        }
    }
}

3、生成带签名公共访问连接

1、通过getPresignedObjectUrl方法，生成一个带到期时间、签名的URL，这个地址可以提供给没有登录的第三方共享访问或者上传对象，针对于Bucket为私有的情况。

2、对于共有的的文件，可以通过http://1ip:port/bucketName/fileName格式直接访问。

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
    public String getPresignedObjectUrl(String fileName) {
        try {
            String presignedObjectUrl = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    .object(fileName)
                    // 设置过期时间，3分钟
                    .expiry(3, TimeUnit.MINUTES)
                    .method(Method.GET)
                    .build());
            System.out.println(presignedObjectUrl);
            return presignedObjectUrl;
        } catch (Exception e) {
            return "获取链接失败";
        }
    }
}

4、下载文件流

1、通过getObject()方法可以直接获取文件流，将文件流通过浏览器直接下；

2、使用该方式的好处是，在业务上可以由前端传入文件Id，服务端通过文件Id查询到文件名称再调用MinIO的API接口获取文件流，这样可以实现系统自身对文件的水平权限管理。

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
    public void getObjectByStream(String fileName, HttpServletResponse response) {
        try {
            GetObjectResponse getObjectResponse = minioClient.getObject(GetObjectArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    .object(fileName)
                    .build());
            // 转化为流
            getObjectResponse.transferTo(response.getOutputStream());
        } catch (Exception e) {
            log.error("获取文件失败");
        }
    }
}

5、获取文件列表

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
    public void listObjects() {
        try {
            Iterable<Result<Item>> listObjects = minioClient.listObjects(ListObjectsArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    // 以xx开头的文件名称
                    // .prefix("/")
                    .build());
            listObjects.forEach(itemResult -> {
                try {
                    Item item = itemResult.get();
                    log.info("文件名称：" + item.objectName());
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });
        } catch (Exception e) {
            log.error("获取文件失败");
        }
    }
}

6、删除文件信息

@Service
public class MinIOService {
    @Resource
    private MinioClient minioClient;
    @Resource
    private MinIOInfoConfig minIOInfoConfig;
    public void removeObject(String fileName) {
        try {
            // 单个删除
            minioClient.removeObject(RemoveObjectArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    .object(fileName)
                    .build());
            // 批量删除
            List<DeleteObject> list = new ArrayList<>();
            list.add(new DeleteObject(fileName));
            minioClient.removeObjects(RemoveObjectsArgs.builder()
                    .bucket(minIOInfoConfig.getPrivateBucket())
                    .objects(list)
                    .build());
        } catch (Exception e) {
            log.error("删除文件失败");
        }
    }
}

到此这篇关于SpringBoot整合Minio(支持公有及私有bucket)的文章就介绍到这了,更多相关SpringBoot整合Minio内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Java中Spring Boot支付宝扫码支付及支付回调的实现代码

    Java中Spring Boot支付宝扫码支付及支付回调的实现代码

    这篇文章主要介绍了Java中Spring Boot支付宝扫码支付及支付回调的实现代码,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-02-02
  • 使用 Spring Boot Admin 监控应用状态的详细过程

    使用 Spring Boot Admin 监控应用状态的详细过程

    这篇文章主要介绍了使用 Spring Boot Admin 监控应用状态,该模块采集应用的内部信息，并暴露给外部的模块，支持 HTTP 和 JMX，并可以与一些第三方监控系统（如 Prometheus）整合，需要的朋友可以参考下
    2022-09-09
  • java对象数组实现学生信息管理系统

    java对象数组实现学生信息管理系统

    这篇文章主要为大家详细介绍了java对象数组实现学生信息管理系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2021-06-06
  • JavaWeb.servlet的基本使用方法详解

    JavaWeb.servlet的基本使用方法详解

    Servlet指在服务器端执行的一段Java代码,可以接收用户的请求和返回给用户响应结果,下面这篇文章主要给大家介绍了关于JavaWeb.servlet基本使用的相关资料,需要的朋友可以参考下
    2022-04-04
  • Java中实现用户之间的通讯方式

    Java中实现用户之间的通讯方式

    在Java中实现用户间通讯主要有两种方法：Socket编程和WebSocket,Socket编程允许两个设备间进行数据交换,适用于基本的网络通讯,本文提供了两种方法的基本实现代码和相关配置,帮助开发者根据需求选择合适的通讯方式
    2024-09-09
  • 详解如何独立使用ribbon实现业务客户端负载均衡

    详解如何独立使用ribbon实现业务客户端负载均衡

    这篇文章主要为大家介绍了详解如何独立使用ribbon实现业务客户端负载均衡，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-06-06
  • Java Clone(类的复制)实例代码

    Java Clone(类的复制)实例代码

    Java Clone(类的复制)实例代码，需要的朋友可以参考一下
    2013-03-03
  • Java抢红包的红包生成算法

    Java抢红包的红包生成算法

    现在日常生活中抢红包已经成了日常游戏，本篇文章主要介绍了Java抢红包的红包生成算法，具有一定的参考价值，有需要的可以了解一下。
    2016-11-11
  • Spring Security实现两周内自动登录

    Spring Security实现两周内自动登录"记住我"功能

    登录过程中经常使用的“记住我”功能，也就是我们经常会在各种网站登陆时见到的"两周内免登录"，“三天内免登录”的功能。今天小编给大家分享基于Spring Security实现两周内自动登录"记住我"功能，感兴趣的朋友一起看看吧
    2019-11-11
  • 如何运行SpringBoot项目的方法

    如何运行SpringBoot项目的方法

    这篇文章主要介绍了如何运行SpringBoot项目的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-03-03

最新评论