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

😊 @ 作者： 一恍过去
💖 @ 主页： https://blog.csdn.net/zhuocailing3390
🎊 @ 社区： Java技术栈交流
🎉 @ 主题： SpringBoot整合Minio(支持公有及私有bucket)
⏱️ @ 创作时间： 2024年06月19日

目录

  • 1、Bucket、Object
  • 2、常用API
  • 3、整合SpringBoot
    • 3.1、yaml配置
    • 3.2、MinIo配置
    • 3.3、Bucket 操作
    • 3.4、Object操作
      • 1. 上传文件
      • 2、获取文件状态(是否存在)
      • 3、生成带签名公共访问连接
      • 4、下载文件流
      • 5、获取文件列表
      • 6、删除文件信息

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("删除文件失败");
        }
    }
}

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/724230.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

第6章 设备驱动程序（4）

第6章 设备驱动程序（4）

目录 6.5 块设备操作 6.5.5 请求结构 6.5.6 BIO 6.5.7 提交请求 6.5.8 I/O调度 6.5.9 ioctl实现 本专栏文章将有70篇左右&#xff0c;欢迎关注&#xff0c;查看后续文章。 6.5 块设备操作 6.5.5 请求结构 struct request { //放在请求队列上&#xff0…
阅读更多...
Go Gin框架

Go Gin框架

一、Gin介绍 Gin是一个用Go编写的HTTPweb框架。它是一个类似于martini但拥有更好性能的API框架, 优于httprouter&#xff0c;速度提高了近 40 倍。点击此处访问Gin官方中文文档。 二、安装 1、安装Gin go get -u github.com/gin-gonic/gin 2、代码中引入 import "githu…
阅读更多...
【Docker】——安装镜像和创建容器，详解镜像和Dockerfile

【Docker】——安装镜像和创建容器，详解镜像和Dockerfile

前言 在此记录一下docker的镜像和容器的相关注意事项 前提条件&#xff1a;已安装Docker、显卡驱动等基础配置 1. 安装镜像 网上有太多的教程&#xff0c;但是都没说如何下载官方的镜像&#xff0c;在这里记录一下&#xff0c;使用docker安装官方的镜像 Docker Hub的官方链…
阅读更多...
进阶篇05——存储过程、存储函数、触发器

进阶篇05——存储过程、存储函数、触发器

存储过程 简介 基本语法 创建和调用 -- 创建名为p1的存储过程&#xff0c;小括号里可以跟参数 -- 存储过程个人觉得就是SQL里的函数 create procedure p1() begin-- begin 和 end 之间是封装的SQL语句-- 可以是一条SQL也可以是多条SQLselect * from student; end;-- 调用存储…
阅读更多...
【FreeRTOS】估算栈的大小

【FreeRTOS】估算栈的大小

参考《FreeRTOS入门与工程实践(基于DshanMCU-103).pdf》 目录 估算栈的大小回顾简介计算说明估计函数用到的栈有多大合计 估算栈的大小 回顾 上一篇文章链接&#xff1a;http://t.csdnimg.cn/Cc8b4 传送门: 上一篇文章 上一篇文章创建的三个任务 /* 创建任务&#xff1a;声 *…
阅读更多...
vivado SITE

vivado SITE

描述 SITE是一个设备对象&#xff0c;表示许多不同类型的逻辑资源之一 可在目标Xilinx FPGA上获得。 SITE包括SLICE/CLB&#xff0c;它们是基本逻辑元件&#xff08;BEL&#xff09;的集合&#xff0c;如 查找表&#xff08;LUT&#xff09;、触发器、多路复用器&#xff0c;携…
阅读更多...
网页钓鱼-克隆修改--劫持口令下载后门

网页钓鱼-克隆修改--劫持口令下载后门

免责声明:本文仅做技术交流与学习... 目录 1-右键另存为 2-goblin项目(不推荐) 修改goblin.yaml文件 运行exe ​编辑 3-Setoolkit (kali自带) 网页克隆---> 1-右键另存为 --不行就再定位元素进行修改. 2-goblin项目(不推荐) GitHub - xiecat/goblin: 一款适用于红蓝…
阅读更多...
力扣每日一题 6/19 排序+动态规划

力扣每日一题 6/19 排序+动态规划

博客主页&#xff1a;誓则盟约系列专栏&#xff1a;IT竞赛 专栏关注博主&#xff0c;后期持续更新系列文章如果有错误感谢请大家批评指出&#xff0c;及时修改感谢大家点赞&#x1f44d;收藏⭐评论✍ 2713.矩阵中严格递增的单元格数【困难】 题目&#xff1a; 给你一个下标从…
阅读更多...
【2024最新华为OD-C/D卷试题汇总】[支持在线评测] 部门组队编程(200分) - 三语言AC题解(Python/Java/Cpp)

【2024最新华为OD-C/D卷试题汇总】[支持在线评测] 部门组队编程(200分) - 三语言AC题解(Python/Java/Cpp)

&#x1f36d; 大家好这里是清隆学长 &#xff0c;一枚热爱算法的程序员 ✨ 本系列打算持续跟新华为OD-C/D卷的三语言AC题解 &#x1f4bb; ACM银牌&#x1f948;| 多次AK大厂笔试 &#xff5c; 编程一对一辅导 &#x1f44f; 感谢大家的订阅➕ 和 喜欢&#x1f497; &#x1f…
阅读更多...
项目3：从0开始的RPC框架（扩展版）-3

项目3：从0开始的RPC框架（扩展版）-3

七. 负载均衡 1. 需求分析 目前我们的RPC框架仅允许消费者读取第一个服务提供者的服务节点&#xff0c;但在实际应用中&#xff0c;同一个服务会有多个服务提供者上传节点信息。如果消费者只读取第一个&#xff0c;势必会增大单个节点的压力&#xff0c;并且也浪费了其它节点…
阅读更多...
文件扫描工具都有哪些？职场大佬都在用的文本提取工具大盘点~

文件扫描工具都有哪些？职场大佬都在用的文本提取工具大盘点~

回想起刚毕业初入职场那阵子&#xff0c;领导让帮忙把纸质文件扫描提取为文本时&#xff0c;还只会傻乎乎地一点点操作&#xff0c;属实是费劲得很&#xff01; 好在后面受朋友安利&#xff0c;找到了4个能够快速实现文件扫描文字提取的方法&#xff0c;这才让我的办公效率蹭蹭…
阅读更多...
GD32如何设计晶振电路

GD32如何设计晶振电路

关于晶振电路真的简单吗&#xff1f;如何可靠的设计好GD32晶振电路&#xff0c;我们需要知道这些&#xff1a; 1、GD32可以选择哪些范围大小晶振&#xff1f; 以GD32F303为例&#xff0c;查询DATASHEET外部时钟电气特性小节可以看到晶振支持范围是4—32M范围均可选择 2、需不…
阅读更多...
JupyterLab使用指南(六):JupyterLab的 Widget 控件

JupyterLab使用指南(六):JupyterLab的 Widget 控件

1. 什么是 Widget 控件 JupyterLab 中的 Widget 控件是一种交互式的小部件&#xff0c;可以用于创建动态的、响应用户输入的界面。通过使用 ipywidgets 库&#xff0c;用户可以在 Jupyter notebook 中创建滑块、按钮、文本框、选择器等控件&#xff0c;从而实现数据的交互式展…
阅读更多...
51单片机STC89C52RC——3.1 数码管静态展示

51单片机STC89C52RC——3.1 数码管静态展示

目的 让数码管在指定位置显示指定数字 一&#xff0c;STC单片机模块 二&#xff0c;数码管 2.1 数码管位置 2.2 生活中用到的数目管 红绿灯 LED数码管在生活中随处可见&#xff0c;洗衣机、电饭煲、热水器、微波炉、冰箱、这些最基本的家用电器上基本都用到了这种7段LED数…
阅读更多...
js语法---理解反射Reflect对象和代理Proxy对象

js语法---理解反射Reflect对象和代理Proxy对象

Reflect 基本要点 反射&#xff1a;reflect是一个内置的全局对象&#xff0c;它的作用就是提供了一些对象实例的拦截方法&#xff0c;它的用法和Math对象相似&#xff0c;都只有静态方法和属性&#xff0c;同时reflect也没有构造器&#xff0c;无法通过new运算符构建实例对象&…
阅读更多...
WiFi/BLE芯片(1)：英飞凌

WiFi/BLE芯片(1)：英飞凌

英飞凌AIROC蓝牙芯片的应用场景：
阅读更多...
error: ‘LocalParameterization’ is not a member of ‘ceres

error: ‘LocalParameterization’ is not a member of ‘ceres

一、错误提示&#xff1a; 对于以下报错&#xff1a; error: ‘LocalParameterization’ is not a member of ‘ceres’ error: ‘quatParam’ was not declared in this scope error: expected type-specifier 二、背景&#xff1a; 我是在Ubuntu20.04下&#xff0c;运行…
阅读更多...
数据库 | 试卷五试卷六试卷七

数据库 | 试卷五试卷六试卷七

1. 主码不相同&#xff01;相同的话就不能唯一标识非主属性了 2.从关系规范化理论的角度讲&#xff0c;一个只满足 1NF 的关系可能存在的四方面问题 是&#xff1a; 数据冗余度大&#xff0c;插入异常&#xff0c;修改异常&#xff0c;删除异常 3.数据模型的三大要素是什么&…
阅读更多...
DDMA信号处理以及数据处理的流程---距离速度测量

DDMA信号处理以及数据处理的流程---距离速度测量

Hello，大家好，我是Xiaojie，好久不见，欢迎大家能够和Xiaojie一起学习毫米波雷达知识，Xiaojie准备连载一个系列的文章—DDMA信号处理以及数据处理的流程，本系列文章将从目标生成、信号仿真、测距、测速、cfar检测、测角、目标聚类、目标跟踪这几个模块逐步介绍，这个系列的…
阅读更多...
华为---OSPF单区域配置（一）

华为---OSPF单区域配置（一）

09、OSPF 9.1 OSPF单区域配置 9.1.1 原理概述 为了弥补距离矢量路由协议的不足&#xff0c;IETF组织开发了一种基于链路状态的内部网关协议——OSPF&#xff08;Open Shortest Path First&#xff0c;开放式最短路径优先&#xff09;。 OSPF作为基于链路状态的协议&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023