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

2024-09-07 08:44
文章标签 java 阿里 springboot 切换 spring 整合 oss 配置文件 minio 无缝

本文主要是介绍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();}}

这篇关于SpringBoot整合Minio及阿里云OSS（配置文件无缝切换）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1144605。

相关文章

Oracle数据库如何切换登录用户(system和sys)

Oracle数据库如何切换登录用户(system和sys)

《Oracle数据库如何切换登录用户(system和sys)》文章介绍了如何使用SQL*Plus工具登录Oracle数据库的system用户,包括打开登录入口、输入用户名和口令、以及切换到sys用户的... 目录打开登录入口登录system用户总结打开登录入口win+R打开运行对话框，输php入：sqlp
阅读更多...
深入解析Spring TransactionTemplate 高级用法(示例代码)

深入解析Spring TransactionTemplate 高级用法(示例代码)

《深入解析SpringTransactionTemplate高级用法(示例代码)》TransactionTemplate是Spring框架中一个强大的工具,它允许开发者以编程方式控制事务,通过... 目录1. TransactionTemplate 的核心概念2. 核心接口和类3. TransactionT
阅读更多...
Java实现Elasticsearch查询当前索引全部数据的完整代码

Java实现Elasticsearch查询当前索引全部数据的完整代码

《Java实现Elasticsearch查询当前索引全部数据的完整代码》：本文主要介绍如何在Java中实现查询Elasticsearch索引中指定条件下的全部数据,通过设置滚动查询参数（scrol... 目录需求背景通常情况Java 实现查询 Elasticsearch 全部数据写在最后需求背景通常情况下
阅读更多...
Spring Boot 整合 ShedLock 处理定时任务重复执行的问题小结

Spring Boot 整合 ShedLock 处理定时任务重复执行的问题小结

《SpringBoot整合ShedLock处理定时任务重复执行的问题小结》ShedLock是解决分布式系统中定时任务重复执行问题的Java库,通过在数据库中加锁,确保只有一个节点在指定时间执行... 目录前言什么是 ShedLock？ShedLock 的工作原理：定时任务重复执行China编程的问题使用 Shed
阅读更多...
一文详解Java Condition的await和signal等待通知机制

一文详解Java Condition的await和signal等待通知机制

《一文详解JavaCondition的await和signal等待通知机制》这篇文章主要为大家详细介绍了JavaCondition的await和signal等待通知机制的相关知识,文中的示例代码讲... 目录1. Condition的核心方法2. 使用场景与优势3. 使用流程与规范基本模板生产者-消费者示例
阅读更多...
Sentinel 断路器在Spring Cloud使用详解

Sentinel 断路器在Spring Cloud使用详解

《Sentinel断路器在SpringCloud使用详解》Sentinel是阿里巴巴开源的一款微服务流量控制组件,主要以流量为切入点,从流量路由、流量控制、流量整形、熔断降级、系统自适应过载保护、... 目录Sentinel 介绍同类对比Hystrix：Sentinel：微服务雪崩问题问题原因问题解决方案请
阅读更多...
Spring IOC的三种实现方式详解

Spring IOC的三种实现方式详解

《SpringIOC的三种实现方式详解》：本文主要介绍SpringIOC的三种实现方式,在Spring框架中,IOC通过依赖注入来实现,而依赖注入主要有三种实现方式,构造器注入、Setter注入... 目录1. 构造器注入（Cons编程tructor Injection）2. Setter注入（Setter
阅读更多...
Java function函数式接口的使用方法与实例

Java function函数式接口的使用方法与实例

《Javafunction函数式接口的使用方法与实例》：本文主要介绍Javafunction函数式接口的使用方法与实例,函数式接口如一支未完成的诗篇,用Lambda表达式作韵脚,将代码的机械美感... 目录引言-当代码遇见诗性一、函数式接口的生物学解构1.1 函数式接口的基因密码1.2 六大核心接口的形态学
阅读更多...
Spring IOC控制反转的实现解析

Spring IOC控制反转的实现解析

《SpringIOC控制反转的实现解析》：本文主要介绍SpringIOC控制反转的实现,IOC是Spring的核心思想之一,它通过将对象的创建、依赖注入和生命周期管理交给容器来实现解耦,使开发者... 目录1. IOC的基本概念1.1 什么是IOC1.2 IOC与DI的关系2. IOC的设计目标3. IOC
阅读更多...
Spring Boot统一异常拦截实践指南(最新推荐)

Spring Boot统一异常拦截实践指南(最新推荐)

《SpringBoot统一异常拦截实践指南(最新推荐)》本文介绍了SpringBoot中统一异常处理的重要性及实现方案,包括使用`@ControllerAdvice`和`@ExceptionHand... 目录Spring Boot统一异常拦截实践指南一、为什么需要统一异常处理二、核心实现方案1. 基础组件
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2