springboot(3.2.5)初步集成MinIO(8.5.9)开发记录

springboot初步集成MinIO开发记录

  • 说明
  • 一：引入maven依赖
  • 二：手动注入minioClient
  • 三：创建service类
  • 四：测试打印连接信息
  • 五：时区转化工具类
  • 六：常用操作演示

说明

  • 这里只是作者开发的记录，已备将来完善和复习！内容很简单，大佬请路过。

一：引入maven依赖

  • 在项目pom中添加minio maven依赖
<dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.9</version>
</dependency>

二：手动注入minioClient

  • 由于minio官方没有提供spring-boot-starter-minio的启动类，所以，这里选择手动注入！
  • 在项目根目录下创建config软件包，创建config类
    在这里插入图片描述
import io.minio.MinioClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class Config {//链式编程 构建MinioClient对象@Beanpublic MinioClient minioClient(){return MinioClient.builder()// .region("zh-east-8") 可选注意和minio的区域配置一致.endpoint("http://ip:9000").credentials("minioadmin","minioadmin") // 默认 用户和秘密.build();}
}

三：创建service类

在这里插入图片描述

import io.minio.MinioClient;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;@Service
public class MinioService {@Resourceprivate MinioClient minioClient;public void testMinioClient(){System.out.print(minioClient);}
}

四：测试打印连接信息

  • 在测试类中测试打印连接信息
@SpringBootTest
class MinioApplicationTests {@Resourceprivate MinioService minioService;@Resourceprivate MinioClient minioClient;@Testvoid test() {minioService.testMinioClient();}
}
  • 测试结果
io.minio.MinioClient@7302ff13

五：时区转化工具类

  • 如果你困惑于文件最后修改时间和代码程序查询结果不一致，参看Minio(官方docker版)容器部署时区问题研究记录
    在这里插入图片描述
package com.yang.miniostudy01.utils;import java.lang.annotation.Retention;
import java.time.Instant;
import java.time.ZoneId;
import java.time.ZonedDateTime;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeFormatterBuilder;public class TimeConverter {// 使用自定义格式化模式private static final DateTimeFormatter isoFormatter = new DateTimeFormatterBuilder().append(DateTimeFormatter.ISO_LOCAL_DATE).appendLiteral('T').append(DateTimeFormatter.ISO_LOCAL_TIME).optionalStart().appendOffsetId().optionalEnd().toFormatter();private static final DateTimeFormatter customFormatter = new DateTimeFormatterBuilder().append(DateTimeFormatter.ISO_LOCAL_DATE).appendLiteral('T').append(DateTimeFormatter.ISO_LOCAL_TIME).appendLiteral('Z') // 添加字面值 'Z' 表示时区偏移量.toFormatter();/*** 将UTC时间转换为指定时区的时间，格式保持ISO-8601 默认时区为东八区* @param utcTimeString UTC时间字符串（ISO-8601格式）* @return 指定时区的时间字符串（ISO-8601格式）*/public static String convertUtcToLocal(String utcTimeString) {String zoneIdString="Asia/Shanghai";return convertUtcToLocal(utcTimeString,zoneIdString);}/*** 将UTC时间转换为指定时区的时间，格式保持ISO-8601* @param utcTimeString UTC时间字符串（ISO-8601格式）* @param zoneIdString 时区ID，如"Asia/Shanghai"* @return 指定时区的时间字符串（ISO-8601格式）*/public static String convertUtcToLocal(String utcTimeString, String zoneIdString) {Instant utcTime = Instant.parse(utcTimeString);ZonedDateTime localTime = utcTime.atZone(ZoneId.of(zoneIdString));DateTimeFormatter formatter = customFormatter.withZone(ZoneId.of(zoneIdString));return formatter.format(localTime);}/*** 将本地时间转换为UTC时间* @param localTimeString 本地时间字符串（ISO-8601格式）* @param zoneIdString 时区ID，如"Asia/Shanghai"* @return UTC时间字符串（ISO-8601格式）*/public static String convertLocalToUtc(String localTimeString) {String zoneIdString="Asia/Shanghai";return convertLocalToUtc(localTimeString,zoneIdString);}/*** 将本地时间转换为UTC时间* @param localTimeString 本地时间字符串（ISO-8601格式）* @param zoneIdString 时区ID，如"Asia/Shanghai"* @return UTC时间字符串（ISO-8601格式）*/public static String convertLocalToUtc(String localTimeString, String zoneIdString) {ZonedDateTime localTime = ZonedDateTime.parse(localTimeString, customFormatter.withZone(ZoneId.of(zoneIdString)));Instant utcTime = localTime.toInstant();return isoFormatter.format(utcTime.atZone(ZoneId.of("UTC")));}
}

六：常用操作演示

package com.yang.miniostudy01;import com.yang.miniostudy01.service.MinioService;
import com.yang.miniostudy01.utils.TimeConverter;
import io.minio.*;
import io.minio.errors.*;
import io.minio.http.Method;
import io.minio.messages.Bucket;
import io.minio.messages.Item;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.lang.reflect.Field;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.time.ZonedDateTime;
import java.util.List;
import java.util.concurrent.TimeUnit;@SpringBootTest
class MinioApplicationTests {@Resourceprivate MinioService minioService;@Resourceprivate MinioClient minioClient;/*** 判断桶是否存在*/@Testvoid testBucketExists(){try {boolean exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket("test1").build());System.out.println("桶存在:"+exists);} catch (ErrorResponseException | XmlParserException | InsufficientDataException | InternalException |ServerException | InvalidKeyException | InvalidResponseException | IOException |NoSuchAlgorithmException e) {throw new RuntimeException(e);}}/*** 创建桶*/@Testvoid testBucketCreate() throws Exception {boolean exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket("test02").build());if (!exists){minioClient.makeBucket(MakeBucketArgs.builder().bucket("test02").build());}System.out.println("bucket已存在，无需创建");}/*** 获取桶列表*/@Testvoid testBucketList() throws Exception {List<Bucket> buckets = minioClient.listBuckets();buckets.forEach(bucket-> System.out.println(bucket.name()+"--"+bucket.creationDate()));}/*** 删除桶*/@Testvoid testBucketRemove() throws Exception {minioClient.removeBucket(RemoveBucketArgs.builder().bucket("test02").build());}/*** 上传文件*/@Testvoid testObjectPut() throws Exception{File file = new File("src/main/resources/picture/image.jpg");ObjectWriteResponse response = minioClient.putObject(PutObjectArgs.builder().bucket("test02").object("image.jpg").stream(new FileInputStream(file),file.length(),-1).build());System.out.print(response);}/*** 简单上传文件*/@Testvoid testObjectUpload() throws Exception {ObjectWriteResponse response = minioClient.uploadObject(UploadObjectArgs.builder().bucket("test02").object("image3.jpg").filename("src/main/resources/picture/image.jpg").build());System.out.println(response);}/*** 判断文件是否存在*/@Testvoid testObjectExists() throws Exception {StatObjectResponse response = minioClient.statObject(StatObjectArgs.builder().bucket("test02").object("image.jpg").build());System.out.println("修改前文件信息："+response);String localLastModifiedTime = TimeConverter.convertUtcToLocal(response.lastModified().toString());ZonedDateTime localLastModified = ZonedDateTime.parse(localLastModifiedTime);//通过反射 修改文件信息 不影响minio存储的文件信息try {Field lastModifiedField = response.getClass().getDeclaredField("lastModified");lastModifiedField.setAccessible(true);lastModifiedField.set(response, localLastModified);} catch (NoSuchFieldException | IllegalAccessException e) {e.printStackTrace();}System.out.println("修改后文件信息："+response);}/*** 获取文件访问路径*/@Testvoid testObjectUrl() throws Exception {String objectUrl = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().bucket("test02").object("image.jpg").method(Method.GET).expiry(5, TimeUnit.MINUTES).build());System.out.println(objectUrl);}/*** 配置桶自定义权限*/@Testvoid testBucketCreateWithPrivilege() throws Exception {String bucketName="test02";boolean exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());if (!exists){minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}else{System.out.println("bucket已存在，无需创建");}// 定义存储桶的访问策略为公开// 定义公共访问策略String policyJson = "{\n" +"    \"Version\": \"2012-10-17\",\n" +"    \"Statement\": [\n" +"        {\n" +"            \"Sid\": \"PublicRead\",\n" +"            \"Effect\": \"Allow\",\n" +"            \"Principal\": \"*\",\n" +"            \"Action\": \"s3:GetObject\",\n" +"            \"Resource\": \"arn:aws:s3:::" + bucketName + "/*\"\n" +"        }\n" +"    ]\n" +"}";minioClient.setBucketPolicy(SetBucketPolicyArgs.builder().bucket(bucketName).config(policyJson).build());}/*** 文件下载*/@Testpublic void testObjectDownload() throws Exception {GetObjectResponse objectFile = minioClient.getObject(GetObjectArgs.builder().bucket("test02").object("image.jpg").build());System.out.println(objectFile.transferTo(new FileOutputStream("src/main/resources/picture/test.jpg")));}/*** 获取桶内文件信息*/@Testpublic void testObjectList(){Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket("test02").build());results.forEach((itemResult)->{try {Item item = itemResult.get();System.out.println(item.objectName()+" \t"+item.lastModified()+"\t"+item.size());} catch (ErrorResponseException | XmlParserException | ServerException | NoSuchAlgorithmException |InvalidResponseException | InsufficientDataException | InvalidKeyException | IOException |InternalException e) {throw new RuntimeException(e);}});}/*** 删除文件*/@Testpublic void testRemoveObject() throws Exception {minioClient.removeObject(RemoveObjectArgs.builder().bucket("test02").object("5g3pl8.jpg").build());}
}

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

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

相关文章

UDP通讯的demo

UDP通讯的demo

udp通讯的demo&#xff0c;这个只是简单的实现。 后面我还会加入udp组播功能。 因为懒&#xff0c;所以我自己发&#xff0c;自己接收了。 经过测试&#xff0c;可以看到&#xff0c;发送消息和接收消息功能都没问题。 广播&#xff1a; 这个是点对点的通过对方的ip和端口发…
阅读更多...
通过方法引用获取属性名的底层逻辑是什么？

通过方法引用获取属性名的底层逻辑是什么？

很多小伙伴可能都用过 MyBatis-Plus&#xff0c;这里边我们构造 where 条件的时候&#xff0c;可以直接通过方法引用的方式去指定属性名&#xff1a; LambdaQueryWrapper<Book> qw new LambdaQueryWrapper<>(); qw.eq(Book::getId, 2); List<Book> list bo…
阅读更多...
47.Redis学习笔记

47.Redis学习笔记

小林coding -> 图解redis的学习笔记 文章目录 Rediswindwos安装docker安装redis启动redis使用RDM访问虚拟机中的redispython连接redis缓存穿透、击穿、雪崩基本数据类型高级数据类型高并发指标布隆过滤器分布式锁Redis 的有序集合底层为什么要用跳表&#xff0c;而不用平衡…
阅读更多...
【数据结构】闲谈A股实时交易的数据结构-队列

【数据结构】闲谈A股实时交易的数据结构-队列

今天有点忙&#xff0c;特意早起&#xff0c;要不先写点什么。看到个股的红红绿绿&#xff0c; 突然兴起&#xff0c;要不写篇文章分析下A股交易的简易版数据结构。 在A股实时股票交易系统中&#xff0c;按照个人理解&#xff0c;大致会用队列来完成整个交易。队列&#xff08;…
阅读更多...
2024高校网络安全管理运维赛wp

2024高校网络安全管理运维赛wp

文章目录 misc签到钓鱼邮件识别easyshellSecretDBGatewayzipApachef for r webphpsqlMessy Mongo misc 签到 钓鱼邮件识别 两部分解base64&#xff0c;各一个flag 后面没有什么地方有有用信息了&#xff0c;根据题目钓鱼邮件&#xff0c;可能第三段flag就跟DMARC、DKIM 和 SP…
阅读更多...
c#实现音乐的“vip播放功能”

c#实现音乐的“vip播放功能”

文章目录 前言1. c#窗体2. 功能3. 具体实现3.1 添加文件3.2 音乐播放3.3 其他功能 4. 整体代码和窗口5. 依赖的第三方库 前言 最近在QQ音乐里重温周杰伦的歌&#xff0c;觉得好听到耳朵怀孕&#xff0c;兴起想要下载下来反复听&#xff0c;发现QQ音乐VIP歌曲下载下来的格式居然…
阅读更多...
基于SSM的“游戏交易网站”的设计与实现（源码+数据库+文档+PPT)

基于SSM的“游戏交易网站”的设计与实现（源码+数据库+文档+PPT)

基于SSM的“游戏交易网站”的设计与实现&#xff08;源码数据库文档PPT) 开发语言&#xff1a;Java 数据库&#xff1a;MySQL 技术&#xff1a;SSM 工具&#xff1a;IDEA/Ecilpse、Navicat、Maven 系统展示 游戏交易网站功能结构图 游戏交易网站首页 游戏交易网站用户注册…
阅读更多...
Android iw 工具

Android iw 工具

代码位置：Android/external/iw 查看支持的命令： console:/ # iw help Usage: iw [options] command Options:--debug enable netlink debugging--version show version (4.1) Commands:help [command]Print usage for all or a specific command, e.g."…
阅读更多...
axios参数汇总

axios参数汇总

axios参数汇总 url: 用于请求的服务器 URL。 method: 创建请求时使用的方法&#xff0c;默认为 get baseURL: 自动加在 url 前面&#xff0c;除非 url 是绝对 URL transformRequest: 在发送请求前修改请求数据的函数&#xff0c;仅适用于 PUT, POST 和 PATCH 请求方法 它只能…
阅读更多...
人工智能|机器学习——强大的 Scikit-learn 可视化让模型说话

人工智能|机器学习——强大的 Scikit-learn 可视化让模型说话

一、显示 API 简介 使用 utils.discovery.all_displays 查找可用的 API。 Sklearn 的utils.discovery.all_displays可以让你看到哪些类可以使用。 from sklearn.utils.discovery import all_displays displays all_displays() displays Scikit-learn (sklearn) 总是会在新版本…
阅读更多...
无人零售，重塑购物新纪元

无人零售，重塑购物新纪元

在这个快节奏的时代&#xff0c;科技的每一次跃进都在悄无声息地改变着我们的生活方式。而今&#xff0c;无人零售正以雷霆之势&#xff0c;颠覆传统购物模式&#xff0c;为我们带来前所未有的便捷与智能体验。想知道无人零售如何彻底改变我们的购物方式吗&#xff1f;跟随我&a…
阅读更多...
市场营销的酒店营销策略研究意义

市场营销的酒店营销策略研究意义

在市场经济条件下&#xff0c;市场营销策略已成为企业经营管理中最重要的组成部分&#xff0c;其在企业管理中的地位日益显现出来。 然而&#xff0c;由于酒店营销环境的特殊性&#xff0c;酒店营销策略研究一直是咱们从业者研究的热点之一。 对于酒店营销策略的研究&#xf…
阅读更多...
python from import 有这个文件但找不到路径

python from import 有这个文件但找不到路径

可能的问题&#xff1a; 模块文件路径不在Python解释器的搜索路径中 解决办法&#xff1a; 如果模块文件路径/path/abc.py不在Python解释器的搜索路径中&#xff0c;Python解释器会报错ModuleNotFoundError: No module named ‘abc’。这时候我们需要将模块文件路径添加到Pyth…
阅读更多...
基于多目标灰狼算法的冷热电联供型微网低碳经济调度

基于多目标灰狼算法的冷热电联供型微网低碳经济调度

针对冷热电联供型微电网运行调度的优化问题，为实现节能减排的目标，以微电网运行费用和环境污 染成本为优化目标，建立了包含风机、微型燃气轮机、余热锅炉、溴化锂吸收式制冷机等微源的微电网优化 模型。模型的优化求解使用改进的多目标灰狼优化算法，得到多目标问题的 Paret…
阅读更多...
uts插件开发-继uniapp原生插件nativeplugins,uts插件开发可直接操作原生安卓sdk等，支持uniappx，支持源码授权价格等等

uts插件开发-继uniapp原生插件nativeplugins,uts插件开发可直接操作原生安卓sdk等，支持uniappx，支持源码授权价格等等

1.创建uts项目 2.创建uts插件cf-takepic 3.在index.uts中编写原生安卓代码&#xff0c;首先定义一个函数方法&#xff0c;在页面中看是否可引用成功 uts函数代码 /*** 拍照函数*/ export const takepicfunction():void{console.log("11111111") } index.vue代码 …
阅读更多...
「PHP系列」PHP MySQL Order By/Update/Delete

「PHP系列」PHP MySQL Order By/Update/Delete

文章目录 一、PHP MySQL Order By二、PHP MySQL Update三、PHP MySQL Delete四、相关链接 一、PHP MySQL Order By 在 PHP 中使用 MySQL 时&#xff0c;如果你想要按照某个字段&#xff08;或字段的组合&#xff09;对查询结果进行排序&#xff0c;你可以使用 ORDER BY 子句。…
阅读更多...
大数据Scala教程从入门到精通第二篇：Scala入门

大数据Scala教程从入门到精通第二篇：Scala入门

一&#xff1a;Scala入门 1&#xff1a;为什么学习Scala Spark新一代内存级大数据计算框架&#xff0c;是大数据的重要内容 Spark就是使用Scala编写的。因此为了更好的学习Spark,需要掌握Scala这门语言 Spark的兴起&#xff0c;带动Scala语言的发展! 2&#xff1a;Scala的发展…
阅读更多...
详细分析Mybatis与MybatisPlus中分页查询的差异（附Demo）

详细分析Mybatis与MybatisPlus中分页查询的差异（附Demo）

目录 前言1. Mybatis2. MybatisPlus3. 实战 前言 更多的知识点推荐阅读&#xff1a; 【Java项目】实战CRUD的功能整理&#xff08;持续更新&#xff09;java框架 零基础从入门到精通的学习路线 附开源项目面经等&#xff08;超全&#xff09; 本章节主要以Demo为例&#xff…
阅读更多...
【JavaScript】执行栈和执行上下文

【JavaScript】执行栈和执行上下文

1. 执行上下文&#xff08;Execution Context&#xff09; 执行上下文是 JavaScript 中代码执行的环境的抽象概念&#xff0c;它包含了代码运行时所需的所有信息&#xff0c;比如变量的值、函数的引用等。 每当 JavaScript 代码执行前&#xff0c;都会创建一个执行上下文&…
阅读更多...
简单聊下 Vue 3.0 和 React 18 框架有什么区别

简单聊下 Vue 3.0 和 React 18 框架有什么区别

Vue3 vs React 18&#xff1a;前端框架比较 随着Vue3和React 18的相继发布&#xff0c;前端开发领域再次迎来了技术革新的热潮。这两款框架各自迭代升级&#xff0c;不仅优化了原有特性&#xff0c;还引入了许多新概念&#xff0c;使得开发者在构建现代Web应用时拥有更多选择。…
阅读更多...
最新文章

Copyright @ 2022~2023