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。

相关文章

python版本切换工具pyenv的安装及用法

python版本切换工具pyenv的安装及用法

《python版本切换工具pyenv的安装及用法》Pyenv是管理Python版本的最佳工具之一,特别适合开发者和需要切换多个Python版本的用户,：本文主要介绍python版本切换工具pyen... 目录Pyenv 是什么？安装 Pyenv（MACOS）使用 Homebrew：配置 shell（zsh
阅读更多...
Java利用Spire.XLS for Java自动化设置Excel的文档属性

Java利用Spire.XLS for Java自动化设置Excel的文档属性

《Java利用Spire.XLSforJava自动化设置Excel的文档属性》一个专业的Excel文件,其文档属性往往能大大提升文件的可管理性和可检索性,下面我们就来看看Java如何使用Spire... 目录Spire.XLS for Java 库介绍与安装Java 设置内置的 Excel 文档属性Java
阅读更多...
Java中的CompletableFuture核心用法和常见场景

Java中的CompletableFuture核心用法和常见场景

《Java中的CompletableFuture核心用法和常见场景》CompletableFuture是Java8引入的强大的异步编程工具,支持链式异步编程、组合、异常处理和回调,介绍其核心用法,通过... 目录1、引言2. 基本概念3. 创建 CompletableFuture3.1. 手动创建3.2.
阅读更多...
java中4种API参数传递方式统一说明

java中4种API参数传递方式统一说明

《java中4种API参数传递方式统一说明》在Java中,我们可以使用不同的方式来传递参数给方法或函数,：本文主要介绍java中4种API参数传递方式的相关资料,文中通过代码介绍的非常详细,需要的... 目录1. 概述2. 参数传递方式分类2.1 Query Parameters（查询参数）2.2 Path
阅读更多...
SpringBoot整合 Quartz实现定时推送实战指南

SpringBoot整合 Quartz实现定时推送实战指南

《SpringBoot整合Quartz实现定时推送实战指南》文章介绍了SpringBoot中使用Quartz动态定时任务和任务持久化实现多条不确定结束时间并提前N分钟推送的方案,本文结合实例代码给大... 目录前言一、Quartz 是什么？1、核心定位：解决什么问题？2、Quartz 核心组件二、使用步骤1
阅读更多...
Java线程池核心参数原理及使用指南

Java线程池核心参数原理及使用指南

《Java线程池核心参数原理及使用指南》本文详细介绍了Java线程池的基本概念、核心类、核心参数、工作原理、常见类型以及最佳实践,通过理解每个参数的含义和工作原理,可以更好地配置线程池,提高系统性能,... 目录一、线程池概述1.1 什么是线程池1.2 线程池的优势二、线程池核心类三、ThreadPoolE
阅读更多...
Springboot请求和响应相关注解及使用场景分析

Springboot请求和响应相关注解及使用场景分析

《Springboot请求和响应相关注解及使用场景分析》本文介绍了SpringBoot中用于处理HTTP请求和构建HTTP响应的常用注解,包括@RequestMapping、@RequestParam... 目录1. 请求处理注解@RequestMapping@GetMapping, @PostMappin
阅读更多...
Java调用DeepSeek API的8个高频坑与解决方法

Java调用DeepSeek API的8个高频坑与解决方法

《Java调用DeepSeekAPI的8个高频坑与解决方法》现在大模型开发特别火,DeepSeek因为中文理解好、反应快、还便宜,不少Java开发者都用它,本文整理了最常踩的8个坑,希望对... 目录引言一、坑 1：Token 过期未处理，鉴权异常引发服务中断问题本质典型错误代码解决方案：实现 Token
阅读更多...
SpringBoot整合AOP及使用案例实战

SpringBoot整合AOP及使用案例实战

《SpringBoot整合AOP及使用案例实战》本文详细介绍了SpringAOP中的切入点表达式,重点讲解了execution表达式的语法和用法,通过案例实战,展示了AOP的基本使用、结合自定义注解以... 目录一、 引入依赖二、切入点表达式详解三、案例实战1. AOP基本使用2. AOP结合自定义注解3.
阅读更多...
Java实现字符串大小写转换的常用方法

Java实现字符串大小写转换的常用方法

《Java实现字符串大小写转换的常用方法》在Java中,字符串大小写转换是文本处理的核心操作之一,Java提供了多种灵活的方式来实现大小写转换,适用于不同场景和需求,本文将全面解析大小写转换的各种方法... 目录前言核心转换方法1.String类的基础方法2. 考虑区域设置的转换3. 字符级别的转换高级转换
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2