SpringBoot整合Minio及阿里云OSS（配置文件无缝切换）

SpringBoot整合Minio及阿里云OSS

文章目录

  • SpringBoot整合Minio及阿里云OSS
    • 1.Minio安装测试
      • 1.Docker安装
        • 启动容器
      • 2.创建bucket
      • 3.上传文件
        • 修改权限
    • 2.SpringBoot整合Minio及阿里云OSS
      • 1.公共部分抽取
      • 2.Minio配置整合
        • 1.添加pom依赖
        • 2.添加配置文件
        • 3.操作接口实现
      • 3.阿里云OSS配置整合
        • 1.pom依赖
        • 2.添加配置文件
        • 3.操作接口实现
      • 4.测试

1.Minio安装测试

MinIO是一个对象存储解决方案，它提供了与Amazon Web Services S3兼容的API，并支持所有核心S3功能。 MinIO有能力在任何地方部署 - 公有云或私有云，裸金属基础设施，编排环境，以及边缘基础设施。

文档地址：https://www.minio.org.cn/docs/minio/linux/developers/java/API.html#

1.Docker安装

拉取对应的镜像

docker pull minio/minio

创建挂载目录

mkdir -p /dockerData/minio/data
mkdir -p /dockerData/minio/config
启动容器

然后我们启动我们的容器，后面有个目录，就是我们需要挂载的硬盘目录

docker run --privileged -it -p 9000:9000 --name minio \
-e "MINIO_ACCESS_KEY=moshangshang2024" \
--privileged=true \
-e "MINIO_SECRET_KEY=moshangshang2024" \
-v /dockerData/minio/data:/data \
-v /dockerData/minio/config:/root/.minio \
minio/minio server /data

最新版本的minio启动使用这条语句

其中修改了MINIO_ROOT_USER和MINIO_ROOT_PASSWORD名称,增加了web控制台端口，密码长度需大于8位

docker run  --privileged -it \
--name minio \
-p 9000:9000  \
-p 9090:9090  \
-d --restart=always \
-e "MINIO_ROOT_USER=moshangshang2024" \
-e "MINIO_ROOT_PASSWORD=xxxxxxxx" \
-v /dockerData/minio/data:/data \
-v /dockerData/minio/config:/root/.minio \
minio/minio server  /data --console-address ":9090" --address ":9000"

我们只需要访问上面提到的ip地址

http://192.168.1.101:9000

输入刚刚配置的账号moshangshang2024和密码 即可进入
在这里插入图片描述

2.创建bucket

我们首先需要创建一个桶，可以当成是一个目录，选择 create bucket进行创建

在这里插入图片描述

3.上传文件

然后我们选中我们的桶，选择 upload 进行文件上传

在这里插入图片描述

在这里插入图片描述

修改权限

如果要使用SDK，比如Java客户端来操作我们的minio的话，那么我们还需要修改一下我们的bucket权限

在这里插入图片描述
在这里插入图片描述

然后就可以通过http://ip:9000/存储桶名/文件名访问文件

2.SpringBoot整合Minio及阿里云OSS

1.公共部分抽取

1.添加自定义yml配置

#对象存储
oss:#对象存储切换配置type: miniominio:endpoint: http://192.168.1.102:9000accessKey: rootsecretKey: rootbucketImageName: test#阿里云对象存储的配置信息aliyun:accessKey: xxxxxaccessSecret: xxxxxendpoint: oss-cn-hangzhou.aliyuncs.combucketImageName: test

2.公共操作方法接口

package com.li.test.minio;import org.springframework.web.multipart.MultipartFile;import javax.servlet.http.HttpServletResponse;
import java.util.List;public interface OSSOperation {/*** 获取默认bucketName** @return 返回 名称*/public String getBucketName();/*** 校验bucket是否存在** @param bucketName 桶名称* @return 返回 boolean - 如果存储桶存在，则为 True。*/public boolean checkBucketExist(String bucketName);/*** 列出所有存储桶的存储桶信息*/public List<String> listBuckets();/*** 创建一个存储桶** @param bucketName 桶名称* @return 返回 boolean - 如果执行成功，则为 True。*/public boolean makeBucket(String bucketName);/*** 删除一个空的存储桶** @param bucketName 桶名称* @return 返回 boolean - 如果执行成功，则为 True。*/public boolean removeBucket(String bucketName);/*** 文件上传** @param data       文件数据* @param bucketName 上传的桶名称*/public boolean uploadFile(MultipartFile data, String bucketName);/*** 文件上传** @param fileName   文件名* @param bucketName 上传的桶名称*/public void downloadFile( String fileName, String bucketName, HttpServletResponse response);/*** 文件删除** @param fileName   文件名* @param bucketName 上传的桶名称*/public boolean removeFile(String fileName, String bucketName);
}

2.Minio配置整合

1.添加pom依赖
      <dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.10</version></dependency>
2.添加配置文件

然后我们需要编写配置文件，用于初始化配置 MinioClient装载到spring容器中

@Data
@ConfigurationProperties(prefix = "oss.minio")
public class MinioOSSProperties {private String endpoint;private String accessKey;private String secretKey;private String bucketImageName;}
/*** Minio配置类** @author moshangshang*/
@Configuration
@EnableConfigurationProperties(MinioOSSProperties.class)
@ConditionalOnProperty(prefix = "oss", name = "type",havingValue = "minio", matchIfMissing = true)
public class MinioOSSConfiguration {@Resourceprivate MinioOSSProperties ossProperties;@Bean@SneakyThrowspublic MinioClient minioClient() {return MinioClient.builder().endpoint(ossProperties.getEndpoint()).credentials(ossProperties.getAccessKey(), ossProperties.getSecretKey()).build();}}
3.操作接口实现
/*** minio操作工具类* @author moshangshang*/
@Slf4j
@Data
@Component
public class MinioUtils {@Resourceprivate MinioClient minioClient;@Resourceprivate OssMinioProperties minioProperties;/*** 校验bucket是否存在** @param bucketName 桶名称* @return 返回 boolean - 如果存储桶存在，则为 True。*/public boolean checkBucketExist(String bucketName) {boolean found = false;try {found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());if (found) {log.info("{} exists", bucketName);} else {log.info("{} not exist", bucketName);}} catch (Exception e) {log.info("{} checkBucketExist exception", bucketName,e);}return found;}/*** 列出所有存储桶的存储桶信息*/public List<Bucket> listBuckets() {List<Bucket> buckets = new ArrayList<>();try {buckets = minioClient.listBuckets();} catch (Exception e) {log.info("listBuckets exception......",e);}return buckets;}/*** 创建一个存储桶** @param bucketName 桶名称* @return 返回 boolean - 如果执行成功，则为 True。*/public boolean makeBucket(String bucketName) {boolean found = false;try {minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());found = true;} catch (Exception e) {log.info("{} makeBucket exception {}", bucketName,e.getMessage(),e);}return found;}/*** 删除一个空的存储桶** @param bucketName 桶名称* @return 返回 boolean - 如果执行成功，则为 True。*/public boolean removeBucket(String bucketName) {boolean found = false;try {minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());found = true;} catch (Exception e) {log.info("{} removeBucket exception", bucketName);}return found;}/*** 文件上传** @param data       文件数据* @param bucketName 上传的桶名称*/public boolean uploadFile(MultipartFile data, String bucketName) {boolean flag = checkBucketExist(bucketName);if (!flag){return false;}String fileName = data.getOriginalFilename();InputStream is = null;try {is = data.getInputStream();minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(fileName).stream(is, data.getSize(), -1).contentType(data.getContentType()).build());return true;} catch (Exception e) {log.info("{} upload exception", bucketName,e);}return false;}/*** 文件上传** @param fileName   文件名* @param bucketName 上传的桶名称*/public void downloadFile( String fileName, String bucketName, HttpServletResponse response) {GetObjectResponse is = null;try {GetObjectArgs getObjectArgs = GetObjectArgs.builder().bucket(bucketName).object(fileName).build();is = minioClient.getObject(getObjectArgs);response.setContentType("application/octet-stream");response.setCharacterEncoding("utf-8");response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(fileName, "utf-8"));IoUtil.copy(is, response.getOutputStream());log.info("minio downloadFile success, filePath:{}", fileName);} catch (Exception e) {log.error("minio downloadFile Exception:{}", e.getMessage(), e);} finally {IoUtil.close(is);}}/*** 文件删除** @param fileName   文件名* @param bucketName 上传的桶名称*/public boolean removeFile(String fileName, String bucketName) {boolean flag = checkBucketExist(bucketName);if (!flag){return false;}try {minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build());return true;} catch (Exception e) {log.error("minio removeFile Exception:{}", e.getMessage(), e);}return false;}
}

3.阿里云OSS配置整合

1.pom依赖
     <dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>3.10.2</version></dependency>
2.添加配置文件
@Data
@ConfigurationProperties(prefix = "oss.aliyun")
public class AliYunOSSProperties {private String accessKey;private String accessSecret;private String endpoint;private String bucketImageName;}

/*** 阿里云oss配置类** @author moshangshang*/
@Configuration
@EnableConfigurationProperties(AliYunOSSProperties.class)
@ConditionalOnProperty(prefix = "oss", name = "type",havingValue = "aliyun", matchIfMissing = true)
public class AliYunOSSConfiguration {@Resourceprivate AliYunOSSProperties ossProperties;@Bean@SneakyThrowspublic OSS ossClient() {return new OSSClientBuilder().build(ossProperties.getEndpoint(),ossProperties.getAccessKey(),ossProperties.getAccessSecret());}}
3.操作接口实现
/*** 阿里云oss操作工具类* @author moshangshang*/
@Slf4j
@Data
@Component
@ConditionalOnProperty(prefix = "oss", name = "type",havingValue = "aliyun", matchIfMissing = true)
public class AliYunOSSOperation implements OSSOperation {@Resourceprivate OSS ossClient;@Resourceprivate AliYunOSSProperties aliYunOSSProperties;@Overridepublic String getBucketName() {return aliYunOSSProperties.getBucketImageName();}/*** 校验bucket是否存在** @param bucketName 桶名称* @return 返回 boolean - 如果存储桶存在，则为 True。*/public boolean checkBucketExist(String bucketName) {boolean found = false;try {found = ossClient.doesBucketExist(bucketName);if (found) {log.info("{} exists", bucketName);} else {log.info("{} not exist", bucketName);}} catch (Exception e) {log.info("{} checkBucketExist exception", bucketName,e);}return found;}/*** 列出所有存储桶的存储桶信息*/public List<String> listBuckets() {List<String> result = new ArrayList<>();try {List<Bucket> buckets = ossClient.listBuckets();result = buckets.stream().map(Bucket::getName).collect(Collectors.toList());} catch (Exception e) {log.info("listBuckets exception......",e);}return result;}/*** 创建一个存储桶** @param bucketName 桶名称* @return 返回 boolean - 如果执行成功，则为 True。*/public boolean makeBucket(String bucketName) {boolean found = false;try {ossClient.createBucket(bucketName);found = true;} catch (Exception e) {log.info("{} makeBucket exception {}", bucketName,e.getMessage(),e);}return found;}/*** 删除一个空的存储桶** @param bucketName 桶名称* @return 返回 boolean - 如果执行成功，则为 True。*/public boolean removeBucket(String bucketName) {boolean found = false;try {ossClient.deleteBucket(bucketName);found = true;} catch (Exception e) {log.info("{} removeBucket exception", bucketName);}return found;}/*** 文件上传** @param data       文件数据* @param bucketName 上传的桶名称*/public boolean uploadFile(MultipartFile data, String bucketName) {String fileName = data.getOriginalFilename();InputStream is = null;try {is = data.getInputStream();ossClient.putObject(bucketName,fileName,data.getInputStream());return true;} catch (Exception e) {log.info("{} upload exception", bucketName,e);}return false;}/*** 文件下载** @param fileName   文件名* @param bucketName 上传的桶名称*/public void downloadFile( String fileName, String bucketName, HttpServletResponse response) {InputStream is = null;try {is = ossClient.getObject(bucketName,fileName).getObjectContent();response.setContentType("application/octet-stream");response.setCharacterEncoding("utf-8");response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(fileName, "utf-8"));IoUtil.copy(is, response.getOutputStream());log.info("minio downloadFile success, filePath:{}", fileName);} catch (Exception e) {log.error("minio downloadFile Exception:{}", e.getMessage(), e);} finally {IoUtil.close(is);}}/*** 文件删除** @param fileName   文件名* @param bucketName 上传的桶名称*/public boolean removeFile(String fileName, String bucketName) {boolean flag = checkBucketExist(bucketName);if (!flag){return false;}try {ossClient.deleteObject(bucketName,fileName);return true;} catch (Exception e) {log.error("minio removeFile Exception:{}", e.getMessage(), e);}return false;}
}

4.测试

/*** minio测试* @author moshangshang*/
@Slf4j
@RestController
public class OSSController {@Resourceprivate OSSOperation ossOperation;@PostMapping("/check")public boolean checkBucketExist(@RequestParam("bucketName")String bucketName) {return ossOperation.checkBucketExist(bucketName);}@PostMapping("/upload")public boolean upload(@RequestParam("data") MultipartFile data) {return ossOperation.uploadFile(data, ossOperation.getBucketName());}@PostMapping("/download")public void download(@RequestParam("fileName")String fileName, HttpServletResponse response) {ossOperation.downloadFile(fileName, ossOperation.getBucketName(), response);}@PostMapping("/remove/file")public boolean removeFile(@RequestParam("fileName")String fileName) {return ossOperation.removeFile(fileName, ossOperation.getBucketName());}@PostMapping("/remove/bucket")public boolean removeBucket(@RequestParam("bucketName")String bucketName) {return ossOperation.removeBucket(bucketName);}@PostMapping("/add/bucket")public boolean makeBucket(@RequestParam("bucketName")String bucketName) {return ossOperation.makeBucket(bucketName);}@PostMapping("/bucket/list")public List<String> listBuckets() {return ossOperation.listBuckets();}}

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

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

相关文章

家政上门小程序系统设计解析

家政上门小程序系统设计解析

一、系统概述 上门家政系统是一种基于互联网技术的综合性服务平台&#xff0c;该系统利用大数据分析和人工智能算法&#xff0c;实现家政服务资源的有效整合与优化配置&#xff0c;进而达到用户与家政服务提供者之间的精准匹配。编辑&#xff1a;qawsed2466 二、系统功能模块 …
阅读更多...
RabbitMQ简介

RabbitMQ简介

RabbitMQ简介 MQ 百度百科-MQ MQ&#xff1a;Message Queue 消息队列 # 何为消息队列&#xff1f; 消息&#xff1a;字符串&#xff0c;数字&#xff0c;对象&#xff0c;文件...... 业务中需要用到的数据都可以称为消息 队列&#xff1a;先进先出的数据结构常用来解耦&…
阅读更多...
【Python知识宝库】迭代器与生成器：高效处理大数据集

【Python知识宝库】迭代器与生成器：高效处理大数据集

&#x1f3ac; 鸽芷咕&#xff1a;个人主页 &#x1f525; 个人专栏: 《C干货基地》《粉丝福利》 ⛺️生活的理想&#xff0c;就是为了理想的生活! 文章目录 前言一、迭代器&#xff1a;逐个访问数据的艺术1. 迭代器的定义2. 自定义迭代器3. 迭代器的优势 二、生成器&#xff…
阅读更多...
分布式风电电池储能系统

分布式风电电池储能系统

风能作为一种清洁的可再生能源,越来越受到世界各国的*视。但风能随机波动的特点,造成风电出力的频繁波动,使电网的调频、调峰压力加大,成为长期困扰风电并网的主要难题。 我国的弃风限电*次出现于2010年,此后弃风从零星现象快速扩散,2012年的情况*为严*,弃风率达17%。之后随着…
阅读更多...
VueSax-解决Vue3报错问题，并支持typescript

VueSax-解决Vue3报错问题，并支持typescript

以下为坑点 根据官方提示&#xff0c;本人在vue3typescript的项目中添加了vuesax的组件依赖 根据正常的导入依赖思路编写代码&#xff0c;发现typescript一直报 查询vuesax的目录文件发现存在ts文件&#xff0c;于是乎觉得是自己的问题&#xff0c;就查阅gpt与网上资料&#x…
阅读更多...
【学习笔记】SSL证书安全机制之证书撤销

【学习笔记】SSL证书安全机制之证书撤销

前言&#xff1a;以往提到过&#xff0c;钓鱼网站会仿冒我们&#xff0c;如果我们的私钥泄露了&#xff0c;如果被不法分子得到了私钥&#xff0c;他们就能假装是我们网站。那现在&#xff0c;我们要做的是生成新私钥并申请新证书。问题来了&#xff0c;旧的证书亦然存在且有效…
阅读更多...
sql-labs51-55通关攻略

sql-labs51-55通关攻略

第51关 一.查询数据库 1and updatexml(1,concat(0x7e,(select database()),0x7e),1)-- 二.查表 and updatexml(1,concat(0x7e,(select group_concat(table_name) from information_schema.tables where table_schemadatabase() ),0x7e),1) -- 三.查列 and updatexml(1,concat…
阅读更多...
如何利用mHand Pro动捕数据手套连接虚拟与现实？

如何利用mHand Pro动捕数据手套连接虚拟与现实？

数据手套作为虚拟现实中的一种交互动捕设备&#xff0c;能够模拟真人手部的动作和感知反馈&#xff0c;实现人机交互的效果。随着虚拟现实技术的不断发展&#xff0c;数据手套也在不断地改进和升级。 mHand Pro是一款由拥有多年经验的惯性动作捕捉技术团队广州虚拟动力研发的数…
阅读更多...
Java并发编程实战 04 | 使用WaitNotify时要注意什么？

Java并发编程实战 04 | 使用WaitNotify时要注意什么？

在 Java 中&#xff0c;wait()、notify() 和 notifyAll() 方法在多线程编程中主要用于线程间的协作和同步。理解这些方法的使用特点对于编写稳定的多线程程序至关重要。我们将从以下三个问题入手深入探讨它们的使用&#xff1a; 为什么必须在 synchronized 代码块中使用 wait(…
阅读更多...
gazebo可能打不开的问题

gazebo可能打不开的问题

如果经常遇到gazebo只能断网才能运行的时候&#xff0c;主要就是因为无法联网访问gazebo的在线模型库&#xff0c;此时我们一般无法在联网的情况下打开gazebo。 这个时候就直接将下载好的模型先放到~/.gazebo/models/文件夹下面即可&#xff1a; https://github.com/osrf/gazeb…
阅读更多...
大语言模型(LLM)如何更好地继续预训练（Continue PreTraining）

大语言模型(LLM)如何更好地继续预训练（Continue PreTraining）

预训练&#xff08;Pretraining&#xff09;是一个非常消耗资源的工作&#xff0c;尤其在 LLM 时代。随着LLama2的开源&#xff0c;越来越多人都开始尝试在这个强大的英文基座模型上进行中文增强。但&#xff0c;我们如何才能保证模型在既学到「中文知识」的情况下&#xff0c;…
阅读更多...
简单的EasyCaptcha图片验证码学习

简单的EasyCaptcha图片验证码学习

简单的EasyCaptcha图片验证码学习 1. 需求 图片验证码是一种常见的验证形式&#xff0c;它通过生成一串随机数字或符号&#xff0c;并加入一些干扰像素&#xff0c;最终生成用于验证的图片。这种验证码的设计旨在增加破解难度&#xff0c;主要通过加大干扰强度来提高安全性。…
阅读更多...
vue3 element-plus form 表单 循环校验

vue3 element-plus form 表单 循环校验

需求&#xff1a; 表单是循环出来的&#xff0c;3个一组&#xff0c;每组对于前端来说是一样的&#xff0c; 需要校验输入框是否必填是否为小数或者整数 效果&#xff1a; 未输入--显示&#xff1a;请输入 输入不是小数或整数--显示&#xff1a;请输入整数或小数 输入正确…
阅读更多...
Vue - 关于Router路由跳转时显示的animate.css动画

Vue - 关于Router路由跳转时显示的animate.css动画

Vue - 关于Router路由跳转时显示的animate.css动画 在Vue中&#xff0c;操作路由跳转时页面是闪白的&#xff0c;没有动画效果&#xff0c;我们可以通过在router-view中设置transition&#xff0c;并搭配animate丰富的动画效果来美化路由跳转时的显示效果. 1.安装animate np…
阅读更多...
Java使用类加载器解决类冲突，多版本jar共存

Java使用类加载器解决类冲突，多版本jar共存

Java使用类加载器解决类冲突 1、案例说明2、打包新版本POI并将要调用的方法封装2.1、POM文件2.2、封装的方法 3、要使用多个POI版本的项目3.1、打包前面的项目生成一个jar包3.1、POM文件3.2、类加载器代码3.3、Jar加载工具3.4、最终调用 1、案例说明 项目中已经有了一个旧版本…
阅读更多...
奖项再+1！通义灵码智能编码助手通过可信 AI 智能编码工具评估，获当前最高等级

奖项再+1！通义灵码智能编码助手通过可信 AI 智能编码工具评估，获当前最高等级

阿里云的通义灵码智能编码助手参与中国信通院组织的可信AI智能编码工具首轮评估&#xff0c;最终获得 4 级评级&#xff0c;成为国内首批通过该项评估并获得当前最高评级的企业之一。 此次评估以《智能化软件工程技术和应用要求 第 2 部分&#xff1a;智能开发能力》为依据&…
阅读更多...
别给智能猫砂盆花冤枉钱了！这三款好用智能猫砂盆哪个更好用？

别给智能猫砂盆花冤枉钱了！这三款好用智能猫砂盆哪个更好用？

节假日回老家&#xff0c;不方便带猫咪怎么办&#xff1f;而且猫咪这么能拉&#xff0c;猫砂盆里拉满了又怎么办&#xff1f;猫砂盆一满&#xff0c;就会变脏&#xff0c;变脏了小猫就会抗拒上厕所&#xff0c;从而在家里找其他干净的地方排泄&#xff0c;那我们要怎么保证不在…
阅读更多...
python中 if __name__ == “__main__“的代码没被执行

python中 if __name__ == “__main__“的代码没被执行

运行pytest 和unittest时&#xff0c;if name “main”: 下的代码没有被执行&#xff0c;发现__name__等于模块名 一、“name” 的作用 1、 __name__是python的一个内置类属性&#xff0c;它天生就存在于一个 python 程序中。 2、直接运行python程序时&#xff0c;__name__的…
阅读更多...
报错:Reached the max session limit(DM8 达梦数据库)

报错:Reached the max session limit(DM8 达梦数据库)

报错:Reached the max session limit - - DM8 达梦数据库 1 环境介绍2 数据库启动SYSTEM IS READY后面日志3 数据库刚启动日志4 达梦数据库学习使用列表 1 环境介绍 某项目无法连接数据库,报错:超过最大会话数限制 , 检查 dmdba ulimit -a openfiles 已改检查 dm.ini 其中 MAX…
阅读更多...
提升效率！ArcGIS中创建脚本工具

提升效率！ArcGIS中创建脚本工具

在我们日常使用的ArcGIS中已经自带了很多功能强大的工具&#xff0c;但有时候遇到个人的特殊情况还是无法满足&#xff0c;这时就可以试着创建自定义脚本工具。 一、编写代码 此处的代码就是一个很简单的给图层更改别名的代码。 1. import arcpy 2. input_fc arcpy.GetParam…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023