SpringBoot项目中整合MinIO

在Spring Boot项目中整合MinIO,可以按照以下步骤进行操作:

1. 添加MinIO依赖

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

2. 配置MinIO连接

minio:endpoint: http://127.0.0.1:9000		#MinIO资源地址accessKey: minioadmin					#访问keysecretKey: minioadmin					#访问密钥bucketName: test						#存储桶名称

3. 创建MinIO配置类

@Data
@Configuration
public class MinioConfig  {@Value("${minio.endpoint}")private String endpoint;@Value("${minio.accessKey}")private String accessKey;@Value("${minio.secretKey}")private String secretKey;@Value("${minio.bucketName}")private String bucketName;@Beanpublic MinioClient minioClient() {return MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();}
}

4. 创建MinIO工具类


@Component
public class MinioUtil {@Autowiredprivate MinioClient minioClient;@Autowiredprivate MinioConfig minioConfig;/*** 创建存储bucket** @param bucketName 存储bucket名称* @return Boolean*/public boolean makeBucket(String bucketName) {try {minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());return true;} catch (Exception e) {e.printStackTrace();}return false;}/*** 删除存储bucket** @param bucketName 存储bucket名称* @return Boolean*/public boolean removeBucket(String bucketName) {try {minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());return true;} catch (Exception e) {e.printStackTrace();}return false;}/*** 查看存储bucket是否存在** @param bucketName* @return*/public boolean bucketExists(String bucketName) {try {return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());} catch (Exception e) {e.printStackTrace();}return false;}/*** 文件上传** @param objectName 对象名称* @param file       文件* @return*/public String uploadFile(String objectName, MultipartFile file) {try {InputStream stream = file.getInputStream();PutObjectArgs putObjectArgs = PutObjectArgs.builder().bucket(minioConfig.getBucketName()).object(objectName).contentType(file.getContentType()).stream(file.getInputStream(), file.getSize(), -1).build();minioClient.putObject(putObjectArgs);stream.close();return "%s/%s/%s".formatted(minioConfig.getEndpoint(), minioConfig.getBucketName(), objectName);} catch (Exception e) {e.printStackTrace();}return "";}/*** 获取对象url** @param objectName 对象名称* @return*/public String getObjectUrl(String objectName) {try {return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(minioConfig.getBucketName()).object(objectName).build());} catch (Exception e) {e.printStackTrace();}return null;}}

5. 控制器操作


@RestController
@RequestMapping("/api/file")
public class FileController {@Autowiredprivate MinioUtil minioUtil;/*** 创建存储bucket** @param bucketName* @return*/@PostMapping("makeBucket")public Object makeBucket(String bucketName) {var success = minioUtil.makeBucket(bucketName);Map<String, Object> map = new HashMap<>();map.put("success", success);return map;}/*** 删除存储bucket** @param bucketName* @return*/@PostMapping("removeBucket")public Object removeBucket(String bucketName) {var success = minioUtil.removeBucket(bucketName);Map<String, Object> map = new HashMap<>();map.put("success", success);return map;}/*** 查看存储bucket是否存在** @param bucketName* @return*/@GetMapping("bucketExists")public Object bucketExists(String bucketName) {var success = minioUtil.bucketExists(bucketName);Map<String, Object> map = new HashMap<>();map.put("success", success);return map;}/*** 文件上传** @param file* @return*/@PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)public Object uploadFile(@RequestParam("file") MultipartFile file) {String fileName = file.getOriginalFilename();var fileUrl = minioUtil.uploadFile(fileName, file);Map<String, Object> map = new HashMap<>();map.put("success", true);map.put("data", fileUrl);return map;}/*** 获取对象url** @param objectName* @return*/@GetMapping("getObjectUrl")public Object getObjectUrl(String objectName) {var fileUrl = minioUtil.getObjectUrl(objectName);Map<String, Object> map = new HashMap<>();map.put("success", true);map.put("data", fileUrl);return map;}
}

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

牛客 D 无限的韵律源点 (对顶堆+滑动窗口)

牛客 D 无限的韵律源点 &#xff08;对顶堆滑动窗口&#xff09; 题目链接 思路 本题的重点在于 recent best部分&#xff0c;即指定下标和指定长度的区间 k 最大值&#xff0c;这实际上是区间 k 最值的***版。因此可以选择主席树&#xff0c;划分树等数据结构直接维护。由于…

mybatis的使用技巧8——联合查询union和union all的区别和用法

在实际项目开发中&#xff0c;会经常联合查询结构相似的多张数据表&#xff0c;使用union关键字就只需要一次sql操作&#xff0c;而无需执行多次查询并通过代码逻辑合并处理&#xff0c;减少了大量繁琐的操作&#xff0c;最重要的是还能通过可选的all关键字筛选重复的数据。 1…

Python实现将文件夹下的所有pdf文件合并成一个pdf文件,并用文件夹名字命名

Python实现将文件夹下的所有pdf文件合并成一个pdf文件&#xff0c;并用文件夹名字命名 # -*- coding: utf-8 -*-import os import PyPDF2def merge_pdfs(folder_path):# 获取文件夹名称folder_name os.path.basename(folder_path)# 搜索文件夹内的所有PDF文件pdf_files [f fo…

chatgpt免费使用网站

在人工智能的浪潮中&#xff0c;OpenAI的ChatGPT作为一款前沿的语言处理工具&#xff0c;已经引起了广泛的关注和讨论。 ChatGPT以其卓越的语言理解和生成能力&#xff0c;为用户提供了多样化的应用场景&#xff0c;从日常对话、编程辅助到内容创作等。然而&#xff0c;对于许…

RAID10如何创建?RAID10做法详细说明

RAID10创建步骤主要有7步&#xff1a;1.硬件准备&#xff1b;2.配置RAID卡或存储设备&#xff1b;3.选择RAID级别&#xff1b;4.添加硬盘到RAID 10组&#xff1b;5.添加硬盘到RAID 10组&#xff1b;6.保存并退出配置&#xff1b;7. 初始化RAID 10阵列。 RAID 10&#xff0c;也…

鸿蒙OpenHarmony【搭建Ubuntu环境】

搭建Ubuntu环境 在嵌入式开发中&#xff0c;很多开发者习惯于使用Windows进行代码的编辑&#xff0c;比如使用Windows的Visual Studio Code进行OpenHarmony代码的开发。但当前阶段&#xff0c;大部分的开发板源码还不支持在Windows环境下进行编译&#xff0c;如Hi3861、Hi3516…

MySQL文件目录结构:表在文件系统中的表示

以下内容基于Linux系统&#xff0c;MySQL的 /var/lib/mysql/ 目录下的数据文件 &#x1f496; Innodb 引擎 MySQL 5.7 MySQL 8.0 &#x1f31f; 总结 Innodb 是聚簇索引&#xff0c;索引及数据&#xff0c;数据即索引&#xff0c;所以数据和索引是存储在同一个文件中的 MyS…

OpenHarmony网络协议通信—libevent [GN编译] - 事件通知库

libevent主要是用C语言实现了事件通知的功能 下载安装 直接在OpenHarmony-SIG仓中搜索libevent并下载。 使用说明 以OpenHarmony 3.1 Beta的rk3568版本为例 库代码存放路径&#xff1a;./third_party/libevent 修改添加依赖的编译脚本 在/developtools/bytrace_standard/…

C#面:.NET默认的委托类型有哪几种?

C# .NET默认的委托类型有以下几种&#xff1a; Action&#xff1a;Action 是一个泛型委托类型&#xff0c;它可以接受0到16个参数&#xff0c;并且没有返回值。例如&#xff0c;Action<int> 表示一个接受一个int类型参数的委托。Func&#xff1a;Func 也是一个泛型委托类…

el-table 表格从下往上滚动,触底自动请求新数据

关键点&#xff1a; 1、 el-table 需要设置高度 height&#xff1b; 2、el-table 外层盒子需要设置一个高度&#xff0c;并且设置 overflow&#xff1a;hidden&#xff1b; 3、获取 el-table 的 bodyWrapper&#xff1a;divData divData.scrollTop divData.clientHeight 1 &g…

C++_类型转换

文章目录 学习目标&#xff1a;1.static_cast2. reinterpret_cast3.const_cast4. dynamic_cast 学习过程1.static_cast2. reinterpret_cast3.const_cast在这里插入图片描述4. dynamic_cast 学习目标&#xff1a; 标准C为了加强类型转换的可视性&#xff0c;引入了四种命名的强…

mysql 查询实战3-解答

对mysql 查询实战3-题目&#xff0c;进行一个解答 11、查询每⽉产品交易与退款情况 目标&#xff1a;查询每⽉产品交易&#xff08;交易总额&#xff0c;交易数&#xff09;与退款情况&#xff08;退款总额&#xff0c;退款数&#xff09; 1&#xff0c;先把日期格式化 使用 E…

200.trie前缀树

Trie树常用于自动补全&#xff0c;拼写检查&#xff0c;单词搜索&#xff0c;高频统计等领域&#xff0c;一般都是这个模板再加个次数 介绍 题解

STM32直接存储器存取DMA

前提知识&#xff1a; 1、STM32F103内部存储器结构以及映射 STM32F103的程序存储器、数据存储器、寄存器和IO端口被组织在同一个4GB的线性地址空间内。数据字节以小端模式存放在存储器中。即低地址中存放的是字数据的低字节&#xff0c;高地址中存放的是字数据的高字节 可访问…

用Python在PDF文档中插入单图像水印和平铺图像水印

PDF文档因其跨平台兼容性和内容保真度成为信息交换的标准载体&#xff0c;为应对版权侵犯、内容篡改以及未经授权的传播等风险&#xff0c;向PDF中插入图片水印成为一种强化文档安全性、彰显所有权及实施访问控制的有效手段。图片水印不仅能以直观的方式标示文档来源、强化版权…

CH58X使用USB HID进行IAP注意事项——笔记

CH58X使用USB HID进行IAP注意事项——笔记 一、背景 基础 单片机使用CH582M&#xff0c;并使用USB HID进行IAP升级。方案 方案1&#xff1a;APPBOOT方案&#xff0c;可以只安装APP就可以运行&#xff0c;APP中后续安装BOOT程序和后面更新也方便。 方案2&#xff1a;经典IAP方…

Windows:web端UI自动化=python+selenium+pycharm框架

本篇写怎么写一个UI自动化代码。mac和Windows是一样的 都是这样写 不过&#xff0c;习惯用Windows了 如果python没有安装可以看我另一篇安装python的教程 先安装python先 下载完python 下载pip 1 安装pip $ curl https://bootstrap.pypa.io/get-pip.py -o get-pip.py # 下载…

【centso】sqlite3.7.17升级到更新的版本

下载 创建一个工作目录(非必须) mkdir sqlite3_upgrade cd sqlite3_upgrade下载源码包(官网&#xff1a; https://sqlite.org/download.html) wget https://www.sqlite.org/2020/sqlite-autoconf-3320300.tar.gz #或者 wget https://docs.iterdaily.com/sqlite-autoconf-332…

SpringBoot上传文件夹

SpringBoot上传文件夹 SpringBoot上传文件夹 SpringBoot上传文件夹前言前端后端FileControllerFilesUtil 前言 个人开发过程中的经验总结 前端 此处以vue3为例 <template><form submit.prevent"uploadFiles" ref"form"><inputtype"…

Sentinel + Nacos流控规则持久化配置

json参数对映sentinel 规则面板 [{"controlBehavior": 0,"count": 2,"grade": 1,"limitApp": "default","resource": "flow","strategy": 0} ] 第二步&#xff0c;告诉订单服务读取配置&…