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和端口发…
阅读更多...
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."…
阅读更多...
人工智能|机器学习——强大的 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…
阅读更多...
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代码 …
阅读更多...
详细分析Mybatis与MybatisPlus中分页查询的差异（附Demo）

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

目录 前言1. Mybatis2. MybatisPlus3. 实战 前言 更多的知识点推荐阅读&#xff1a; 【Java项目】实战CRUD的功能整理&#xff08;持续更新&#xff09;java框架 零基础从入门到精通的学习路线 附开源项目面经等&#xff08;超全&#xff09; 本章节主要以Demo为例&#xff…
阅读更多...
C# winform 连接mysql数据库（navicat）

C# winform 连接mysql数据库（navicat）

1.解决方案资源管理器->右键->管理NuGet程序包->搜索&#xff0c; 安装Mysql.Data 2.解决方案资源管理器->右键->添加->引用->浏览-> C:\Program Files (x86)\MySQL\MySQL Installer for Windows ->选择->MySql.Data.dll 3.解决方案资源管理器…
阅读更多...
深入剖析Tomcat(七) 日志记录器

深入剖析Tomcat(七) 日志记录器

在看原书第六章之前&#xff0c;一直觉得Tomcat记日志的架构可能是个“有点东西”的东西。在看了第六章之后呢&#xff0c;额… 就这&#xff1f;不甘心的我又翻了翻logback与新版tomcat的源码&#xff0c;额…&#xff0c;日志架构原来也没那么神秘。本篇文章先过一遍原书内容…
阅读更多...
Github 2024-05-07 开源项目日报 Tp10

Github 2024-05-07 开源项目日报 Tp10

根据Github Trendings的统计，今日(2024-05-07统计)共有10个项目上榜。根据开发语言中项目的数量，汇总情况如下： 开发语言项目数量TypeScript项目4Jupyter Notebook项目2Python项目1Batchfile项目1非开发语言项目1Java项目1HTML项目1C#项目1从零开始构建你喜爱的技术 创建周期…
阅读更多...
k8s 资源文件参数介绍

k8s 资源文件参数介绍

Kubernetes资源文件yaml参数介绍 yaml 介绍 yaml 是一个类似 XML、JSON 的标记性语言。它强调以数据为中心&#xff0c;并不是以标识语言为重点例如 SpringBoot 的配置文件 application.yml 也是一个 yaml 格式的文件 语法格式 通过缩进表示层级关系不能使用tab进行缩进&am…
阅读更多...
金三银四面试题（二十五）：策略模式知多少？

金三银四面试题（二十五）：策略模式知多少？

什么是策略模式 策略模式&#xff08;Strategy Pattern&#xff09;是一种行为型设计模式&#xff0c;旨在定义一系列算法&#xff0c;将每个算法封装到一个独立的类中&#xff0c;使它们可以互换。策略模式让算法的变化独立于使用它们的客户端&#xff0c;使得客户端可以根据…
阅读更多...
二叉搜索树相关

二叉搜索树相关

二叉搜索树 定义&#xff1a;对二叉搜索树的一些操作基本结构Insert操作Find操作Erase操作 InOrder遍历二叉树操作模拟字典模拟统计次数 定义&#xff1a; 二叉搜索树又称二叉排序树&#xff0c;它或者是一棵空树&#xff0c;或者是具有以下性质的二叉树:若它的左子树不为空&a…
阅读更多...
MacOS快速安装FFmpeg，并使用FFmpeg转换视频

MacOS快速安装FFmpeg，并使用FFmpeg转换视频

前言&#xff1a;目前正在接入flv视频流&#xff0c;但是没有一个合适的flv视频流地址。网上提供的flv也都不是H264AAC&#xff08;一种视频和音频编解码器组合&#xff09;&#xff0c;所以想通过fmpeg来将flv文件转换为H264AAC。 一、MacOS环境 博主的MacOS环境&#xff08;…
阅读更多...
初始C++（一）

初始C++（一）

目录 前言&#xff1a; 命名空间&#xff1a; 总结&#xff1a; 前言&#xff1a; C语言学好了&#xff0c;现在当然要进阶了&#xff0c;那么就是从C开始。 C兼容C&#xff0c;支持其中90%的语法。可能有很多同学听说过C#&#xff0c;C#和C没有关系&#xff0c;是微软研究出…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023