【Spring Cloud Alibaba】13.自建存储对象服务与集成(minio版)

2024-06-07 23:28
文章标签 java 服务 对象 spring cloud 存储 alibaba 集成 13 minio 自建

本文主要是介绍【Spring Cloud Alibaba】13.自建存储对象服务与集成(minio版)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 简介
    • 什么是云存储服务（OSS）
    • 为什么选择MiniIO
    • MiniIO相关地址
  • 搭建(docker)
    • 安装Docker
    • 部署MinIO
    • 创建存储桶
    • 配置存储桶
    • 设置存储桶可以直接在浏览器访问
  • 集成到Spring Cloud Alibaba项目
    • 创建子模块
    • 引入依赖包
    • 项目结构
    • 配置文件
    • 工具类
    • 接口类
    • 测试

简介

接下来对分布式项目实现存储对象服务器搭建与集成，本操作与前置步骤关系不大，大家可酌情查看前置步骤，详情请参照【Spring Cloud Alibaba】Spring Cloud Alibaba 搭建教程

什么是云存储服务（OSS）

OSS (Object Storage Service) 是一种云存储服务，用于存储和访问大量的非结构化数据，如图片、视频、文档等。它提供了高可靠性、高扩展性和低成本的存储解决方案，适用于各种云计算和大数据应用场景。

以下是一些常用的开源对象存储服务搭建技术：

  1. MinIO：专注于对象存储，具有高性能和易用性，适合用于存储大量的非结构化数据。
  2. Ceph：分布式存储系统，具有高可靠性和可扩展性，适合用于大规模存储和数据处理。
  3. Swift：OpenStack项目的一部分，提供对象存储服务，适合用于云存储和数据备份。
  4. HDFS：Apache Hadoop的分布式文件系统，适合用于大数据存储和处理。
  5. GlusterFS：分布式文件系统，具有高可用性和可扩展性，适合用于文件共享和存储。
  6. Ozone：Apache Hadoop的对象存储层，适合用于大规模对象存储和分析。

为什么选择MiniIO

对于云存储服务的集成大同小异，本文介绍的是MiniIO，至于为什么选择MiniIO，主要是因为搭建和集成方便，性能也不错，适合中小企业比较省心。

MiniIO相关地址

官网地址：https://min.io
官网文档：https://min.io/docs/minio/container/index.html

开源地址：

  • Github
  • Gitee

搭建(docker)

本问搭建方式选择的是docker，其他搭建方法参照官网搭建教程

安装Docker

已安装过的用户忽略此步骤，未安装的用户可以参照往期文章：
Centos安装docker
ubuntu安装docker
window安装docker

部署MinIO

创建文件持久化路径

mkdir -p ~/minio/data

创建并运行MinIO容器

docker run -d\--restart=always \-p 9876:9000 \-p 9878:9878 \--name minio \-v ~/minio/data:/data \-e "MINIO_ROOT_USER=moonce" \-e "MINIO_ROOT_PASSWORD=Mm123456" \quay.io/minio/minio server /data --console-address ":9878"

命令说明：

  • docker run：创建并启动容器；
  • --restart=always：跟随docker一起启动；
  • -p 9876:9000 和 -p 9878:9878 ：指定主机与容器端口映射，主机9876、 9878分别对应容器9000、9878端口；
  • --name minio ：指定容器名称为minio
  • -v ~/minio/data:/data：将主机路径 ~/minio/data与容器 /data映射，数据持久化存储；
  • -e "MINIO_ROOT_USER=moonce"和-e "MINIO_ROOT_PASSWORD=Mm123456"：设置默认用户名和密码；
  • quay.io/minio/minio:镜像地址,默认安装最新稳定版，需要指定版本加:版本；
  • server /data:容器中文件存储位置
  • --console-address ":9878"：指定UI控制台端口

创建完成后，打开服务器IP:9878
在这里插入图片描述
输入创建容器设置的账号密码，完成登录

创建存储桶

1.登录完成后，我们进入Buckets菜单，然后点击按钮Create Bucket
在这里插入图片描述
2.输入存储桶名称，无特殊要求的话，其他默认即可
在这里插入图片描述
配置说明

  • Versioning：允许在同一密钥下保留同一对象的多个版本。
  • Object Locking：可防止对象被删除。需要支持保留和合法保留。只能在创建存储桶时启用。
  • Quota ：限制桶中的数据量。
  • Retention：施加规则以防止在一段时间内删除对象。必须启用版本控制才能设置存储桶保留策略。

配置存储桶

1.创建完成后我们在Buckets菜单中可以看到已经创建名为moonce的存储桶
在这里插入图片描述
2.点击这个存储桶，打开存储桶详细配置信息
在这里插入图片描述
功能项说明

  • Events：MinIO 存储桶通知允许管理员就某些对象或存储桶事件向支持的外部服务发送通知。 MinIO 支持与 Amazon S3 事件通知类似的存储桶和对象级 S3 事件。
  • Replication：MinIO 支持源存储桶和目标存储桶之间的服务器端和客户端对象复制。
  • Lifecycle ：MinIO 对象生命周期管理允许为基于时间或日期的对象自动转换或到期创建规则。对于对象转换，MinIO 自动将对象移动到配置的远程存储层。
  • Access ：了解哪些政策和用户被授权接入这个桶。
  • Anonymous ：设置匿名策略允许客户端无需认证即可访问Bucket或前缀内容并执行符合指定策略的操作。

设置存储桶可以直接在浏览器访问

选择Anonymous,点击Add Access Rule
在这里插入图片描述
创建新的匿名规则，让改存储桶下所有文件可以匿名只读
在这里插入图片描述
这样我们就可以直接在浏览器访问服务器IP:9876/moonce/存储桶中文件名.jpg来直接访问到文件。

集成到Spring Cloud Alibaba项目

创建子模块

参照【Spring Cloud Alibaba】3.创建服务提供者，创建服务提供者模块，命名为moonce-minio-provider

引入依赖包

<dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.10</version>
</dependency>

如果允运行提示Unsupported OkHttp library found. Must use okhttp ＞= 4.12.0错误，则修改引用的okhttp版本

 <!-- minio oss --><dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.10</version><exclusions><exclusion><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId></exclusion></exclusions></dependency><dependency><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId><version>4.12.0</version></dependency>

项目结构

在这里插入图片描述

配置文件

MinioConfig.java

import io.minio.MinioClient;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Data
@Configuration
@ConfigurationProperties(prefix = "minio")
public class MinioConfig {private String endpoint;private String accessKey;private String secretKey;private String bucketName;@Beanpublic MinioClient minioClient() {return MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();}
}

参数配置（演示时没连nacos，正常应该将配置信息写到nacos中）
application.yml

server:port: 8081management:endpoints:web:exposure:include: "*"
minio:#Minio服务所在地址endpoint: http://127.0.0.1:9876#存储桶名称bucketName: moonce#访问的keyaccessKey: moonce#访问的秘钥secretKey: Mm123465

工具类

MinioUtil.java


import com.moonce.provider.config.MinioConfig;
import io.minio.*;
import io.minio.http.Method;
import io.minio.messages.Bucket;
import io.minio.messages.Item;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.FastByteArrayOutputStream;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;@Component
@Slf4j
public class MinioUtil {@Autowiredprivate MinioConfig prop;@Resourceprivate MinioClient minioClient;/*** 查看存储bucket是否存在* @return boolean*/public Boolean bucketExists(String bucketName) {Boolean found;try {found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());} catch (Exception e) {e.printStackTrace();return false;}return found;}/*** 创建存储bucket* @return Boolean*/public Boolean makeBucket(String bucketName) {try {minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());} catch (Exception e) {e.printStackTrace();return false;}return true;}/*** 删除存储bucket* @return Boolean*/public Boolean removeBucket(String bucketName) {try {minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());} catch (Exception e) {e.printStackTrace();return false;}return true;}/*** 获取全部bucket*/public List<Bucket> getAllBuckets() {try {List<Bucket> buckets = minioClient.listBuckets();return buckets;} catch (Exception e) {e.printStackTrace();}return null;}/*** 文件上传** @param file 文件* @return Boolean*/public String upload(MultipartFile file) {String originalFilename = file.getOriginalFilename();if (StringUtils.isBlank(originalFilename)){throw new RuntimeException();}String fileName = System.currentTimeMillis() + originalFilename.substring(originalFilename.lastIndexOf("."));SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM/dd");String formattedDate = sdf.format(new Date());String objectName = formattedDate + "/" + fileName;try {PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(prop.getBucketName()).object(objectName).stream(file.getInputStream(), file.getSize(), -1).contentType(file.getContentType()).build();//文件名称相同会覆盖minioClient.putObject(objectArgs);} catch (Exception e) {e.printStackTrace();return null;}return objectName;}/*** 预览图片* @param fileName* @return*/public String preview(String fileName){// 查看文件地址GetPresignedObjectUrlArgs build = new GetPresignedObjectUrlArgs().builder().bucket(prop.getBucketName()).object(fileName).method(Method.GET).build();try {String url = minioClient.getPresignedObjectUrl(build);return url;} catch (Exception e) {e.printStackTrace();}return null;}/*** 文件下载* @param fileName 文件名称* @param res response* @return Boolean*/public void download(String fileName, HttpServletResponse res) {GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(prop.getBucketName()).object(fileName).build();try {GetObjectResponse response = minioClient.getObject(objectArgs);byte[] buf = new byte[1024];int len;try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()){while ((len=response.read(buf))!=-1){os.write(buf,0,len);}os.flush();byte[] bytes = os.toByteArray();res.setCharacterEncoding("utf-8");// 设置强制下载不打开// res.setContentType("application/force-download");res.addHeader("Content-Disposition", "attachment;fileName=" + fileName);try (ServletOutputStream stream = res.getOutputStream()){stream.write(bytes);stream.flush();}}} catch (Exception e) {e.printStackTrace();}}/*** 查看文件对象* @return 存储bucket内文件对象信息*/public List<Item> listObjects() {Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(prop.getBucketName()).build());List<Item> items = new ArrayList<>();try {for (Result<Item> result : results) {items.add(result.get());}} catch (Exception e) {e.printStackTrace();return null;}return items;}/*** 删除* @param fileName* @return* @throws Exception*/public boolean remove(String fileName){try {minioClient.removeObject( RemoveObjectArgs.builder().bucket(prop.getBucketName()).object(fileName).build());}catch (Exception e){return false;}return true;}}

接口类

MinioController.java

import com.moonce.provider.config.MinioConfig;
import com.moonce.provider.util.MinioUtil;
import io.minio.messages.Bucket;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import javax.servlet.http.HttpServletResponse;
import java.util.List;@Slf4j
@RestController
@RequestMapping(value = "product/file")
public class MinioController {@Autowiredprivate MinioUtil minioUtil;@Autowiredprivate MinioConfig prop;/*** 查看存储bucket是否存在* @param bucketName* @return*/@GetMapping("/bucketExists")public Boolean bucketExists(@RequestParam("bucketName") String bucketName) {return minioUtil.bucketExists(bucketName);}/*** 创建存储bucket* @param bucketName* @return*/@GetMapping("/makeBucket")public Boolean makeBucket(String bucketName) {return minioUtil.makeBucket(bucketName);}/*** 删除存储bucket* @param bucketName* @return*/@GetMapping("/removeBucket")public Boolean removeBucket(String bucketName) {return minioUtil.removeBucket(bucketName);}/*** 获取全部bucket* @return*/@GetMapping("/getAllBuckets")public  List<Bucket> getAllBuckets() {List<Bucket> allBuckets = minioUtil.getAllBuckets();return allBuckets;}/*** 文件上传返回url* @param file* @return*/@PostMapping("/upload")public String upload(@RequestParam("file") MultipartFile file) {String objectName = minioUtil.upload(file);if (null != objectName) {return prop.getEndpoint() + "/" + prop.getBucketName() + "/" + objectName;}return "";}/*** 图片/视频预览* @param fileName* @return*/@GetMapping("/preview")public String preview(@RequestParam("fileName") String fileName) {return minioUtil.preview(fileName);}/*** 文件下载* @param fileName* @param res* @return*/@GetMapping("/download")public void download(@RequestParam("fileName") String fileName, HttpServletResponse res) {minioUtil.download(fileName,res);}/*** 删除文件* @param url* @return*/@PostMapping("/delete")public String remove(String url) {String objName = url.substring(url.lastIndexOf(prop.getBucketName()+"/") + prop.getBucketName().length()+1);minioUtil.remove(objName);return objName;}

测试

在这里插入图片描述
访问返回地址，可正确打开图片！
在这里插入图片描述
在我们的minio控制台可以查询到该文件，上传路径中的/会自动分割成文件夹的形式！

这篇关于【Spring Cloud Alibaba】13.自建存储对象服务与集成(minio版)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

Java 正则表达式URL 匹配与源码全解析

Java 正则表达式URL 匹配与源码全解析

《Java正则表达式URL匹配与源码全解析》在Web应用开发中,我们经常需要对URL进行格式验证,今天我们结合Java的Pattern和Matcher类,深入理解正则表达式在实际应用中... 目录1.正则表达式分解：2. 添加域名匹配 (2)3. 添加路径和查询参数匹配 (3) 4. 最终优化版本5.设计思
阅读更多...
Java使用ANTLR4对Lua脚本语法校验详解

Java使用ANTLR4对Lua脚本语法校验详解

《Java使用ANTLR4对Lua脚本语法校验详解》ANTLR是一个强大的解析器生成器,用于读取、处理、执行或翻译结构化文本或二进制文件,下面就跟随小编一起看看Java如何使用ANTLR4对Lua脚本... 目录什么是ANTLR？第一个例子ANTLR4 的工作流程Lua脚本语法校验准备一个Lua Gramm
阅读更多...
Java字符串操作技巧之语法、示例与应用场景分析

Java字符串操作技巧之语法、示例与应用场景分析

《Java字符串操作技巧之语法、示例与应用场景分析》在Java算法题和日常开发中,字符串处理是必备的核心技能,本文全面梳理Java中字符串的常用操作语法,结合代码示例、应用场景和避坑指南,可快速掌握字... 目录引言1. 基础操作1.1 创建字符串1.2 获取长度1.3 访问字符2. 字符串处理2.1 子字
阅读更多...
Java Optional的使用技巧与最佳实践

Java Optional的使用技巧与最佳实践

《JavaOptional的使用技巧与最佳实践》在Java中,Optional是用于优雅处理null的容器类,其核心目标是显式提醒开发者处理空值场景,避免NullPointerExce... 目录一、Optional 的核心用途二、使用技巧与最佳实践三、常见误区与反模式四、替代方案与扩展五、总结在 Java
阅读更多...
基于Java实现回调监听工具类

基于Java实现回调监听工具类

《基于Java实现回调监听工具类》这篇文章主要为大家详细介绍了如何基于Java实现一个回调监听工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录监听接口类 Listenable实际用法打印结果首先，会用到 函数式接口 Consumer, 通过这个可以解耦回调方法，下面先写一个
阅读更多...
使用Java将DOCX文档解析为Markdown文档的代码实现

使用Java将DOCX文档解析为Markdown文档的代码实现

《使用Java将DOCX文档解析为Markdown文档的代码实现》在现代文档处理中,Markdown（MD）因其简洁的语法和良好的可读性,逐渐成为开发者、技术写作者和内容创作者的首选格式,然而,许多文... 目录引言1. 工具和库介绍2. 安装依赖库3. 使用Apache POI解析DOCX文档4. 将解析
阅读更多...
Java字符串处理全解析(String、StringBuilder与StringBuffer)

Java字符串处理全解析(String、StringBuilder与StringBuffer)

《Java字符串处理全解析(String、StringBuilder与StringBuffer)》：本文主要介绍Java字符串处理全解析(String、StringBuilder与StringBu... 目录Java字符串处理全解析：String、StringBuilder与StringBuffer一、St
阅读更多...
springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

《springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法》：本文主要介绍springboot整合阿里云百炼DeepSeek实现sse流式打印,本文给大家介绍的非常详细,对大... 目录1.开通阿里云百炼,获取到key2.新建SpringBoot项目3.工具类4.启动类5.测试类6.测
阅读更多...
Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

《SpringBoot循环依赖原理、解决方案与最佳实践(全解析)》循环依赖指两个或多个Bean相互直接或间接引用,形成闭环依赖关系,：本文主要介绍SpringBoot循环依赖原理、解决方案与最... 目录一、循环依赖的本质与危害1.1 什么是循环依赖？1.2 核心危害二、Spring的三级缓存机制2.1 三
阅读更多...
Python中判断对象是否为空的方法

Python中判断对象是否为空的方法

《Python中判断对象是否为空的方法》在Python开发中,判断对象是否为“空”是高频操作,但看似简单的需求却暗藏玄机,从None到空容器,从零值到自定义对象的“假值”状态,不同场景下的“空”需要精... 目录一、python中的“空”值体系二、精准判定方法对比三、常见误区解析四、进阶处理技巧五、性能优化
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2