分布式文件系统--MinIO

devtools/2024/11/14 6:27:09/

1 MinIO安装(Docker)

        ●在root目录下新建docker_minio文件夹

        ●在docker_minio文件夹下新建config文件夹,data文件夹

        ●在root目录下新建docker_compose文件夹,在docker_compose文件夹中添加docker-compose.yaml

services:minio:image: quay.io/minio/miniocontainer_name: minio_containerports:- "9000:9000" #api接口(内部访问)- "9001:9001" #控制台端口(外部界面)environment:TZ: Asia/Shanghai #时区上海MINIO_ROOT_USER: abc #管理后台用户名MINIO_ROOT_PASSWORD: abc #管理后台密码(最少8个字符)MINIO_COMPRESS: "off" #开启压缩(on开启,off关闭)MINIO_COMPRESS_EXTENSIONS: "" #扩展名  .pdf  .doc为空,所有类型均压缩MINIO_COMPRESS_MIME_TYPES: "" #mine类型application/pdf为空,所有类型均压缩volumes:- "/root/docker_minio/data:/data" #映射当前目录下的打他目录至容器内/data目录- "/root/docker_minio/config:/root/.minio" #映射配置目录command: server --address ':9000' --console-address ':9001' /data #服务器地址是9000,服务器控制台地址是9001,数据储存在/data下privileged: truenetworks:- sunner_network

        ●通过docker compose up -d命令执行docker-compose.yaml文件(必须在docker_compose文件夹目录下执行),然后系统会自动拉取minio镜像,创建并启动minio容器

​​​​​​​        ●执行docker ps -a命令,出现下图,表示安装和启动minio成功

2 MinIO的使用

        访问MinIO有2个端口,分别是9000端口和9001端口

                9000端口是用于内部访问,比如用户通过SpringBoot接口间接访问MinIO

                9001端口是用于外部访问,即通过浏览器访问

2.1 桶

        MinIO所有的文件都保存在中,可以将桶理解为文件夹

2.1.1新建桶

2.1.2 上传文件

2.2 网页访问图片

2.2.1 复制访问链接

        ●将127.0.0.1修改为MinIO所在服务器地址

        ●去掉访问链接后半段(去掉.png之后的)

2.2.2 修改桶权限为public

2.2.3 访问图片

        在浏览器的地址栏输入"访问链接"

3 SpringBoot集成MinIO

3.1 引入依赖

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

3.2 application.yaml

minio:endpoint: http://123.123.123.123:9000  #minio所在服务器访问地址accessKey: abc  #用户名secretKey: abc  #密码

3.3 MinIO配置类

java">@Component
@ConfigurationProperties(prefix = "minio")
public class MinioProp {private String endpoint;private String accessKey;private String secretKey;public String getEndpoint() {return endpoint;}public void setEndpoint(String endpoint) {this.endpoint = endpoint;}public String getAccessKey() {return accessKey;}public void setAccessKey(String accessKey) {this.accessKey = accessKey;}public String getSecretKey() {return secretKey;}public void setSecretKey(String secretKey) {this.secretKey = secretKey;}
}

3.4 通过MinIO配置类创建MinioClient,并注册进SpringIOC容器

java">@Configuration  //"配置类"注解
@MapperScan({"xyz.aboluo.minio.dao"})  //dao接口包扫描
//@EnableConfigurationProperties({Teacher.class})
public class MinioAutoConfiguration {@Autowiredprivate MinioProp minioProp;@Beanpublic MinioClient getMinioClient() {return MinioClient.builder().endpoint(minioProp.getEndpoint()).credentials(minioProp.getAccessKey(), minioProp.getSecretKey()).build();}@Beanpublic CorsFilter corsFilter() {UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();CorsConfiguration corsConfiguration = new CorsConfiguration();corsConfiguration.addAllowedOrigin("*"); // 1 设置访问源地址(允许任何地址访问)corsConfiguration.addAllowedHeader("*"); // 2 设置访问源请求头(允许任何请求头访问)corsConfiguration.addAllowedMethod("*"); // 3 设置访问源请求方法(允许任何方法(GET,POST等等)方法)source.registerCorsConfiguration("/**", corsConfiguration); // 4 对接口配置跨域设置return new CorsFilter(source);}
}

3.5 Controller接口

java">@RestController
@RequestMapping("/minioFileHandle")
public class MinioController {private static final Logger LOGGER = LoggerFactory.getLogger(MinioController.class);@Autowiredprivate MinioClient minioClient;/*** 获取bucket列表** @return*/@RequestMapping("/bucketList.do")public Result bucketList() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {List<Map<String, String>> buckets = new ArrayList<>();for (Bucket bucket : minioClient.listBuckets()) {Map<String, String> returnBucket = new HashMap<>();returnBucket.put("bucketName", bucket.name());returnBucket.put("creationDateTime", bucket.creationDate().toString());buckets.add(returnBucket);}return Result.success(buckets);}/*** 查询bucket下的所有文件信息** @return*/@RequestMapping("/queryBucketFiles.do")public Result queryBucketFiles(@RequestParam String bucketName) throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {//检查桶是否存在if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {throw new SunnerRuntimeException(Result.ResultEnum.BUCKET_NOT_EXIST);}//遍历封装桶中的文件信息Iterator<io.minio.Result<Item>> iterator = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).build()).iterator();List<Object> items = new ArrayList<>();while (iterator.hasNext()) {Item item = iterator.next().get();items.add(JSON.parse(String.format("{'fileName':'%s','fileSize':'%s','lastModified':'%s'}", item.objectName(), item.size(), Date.from(item.lastModified().toInstant()))));}return Result.success(items);}/*** 文件下载** @return*/@RequestMapping("/download.do")public Result download(@RequestParam String bucketName, @RequestParam String fileName, HttpServletResponse response) throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {response.setHeader("picture-upload-date-time", URLEncoder.encode("abccc", StandardCharsets.UTF_8));response.getOutputStream().write(minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(fileName).build()).readAllBytes());return Result.returnVoid();}
}

http://www.ppmy.cn/devtools/16514.html

相关文章

SSH远程直连服务器docker容器的jupyter

SSH远程直连服务器docker容器的jupyter 动机&#xff1a;最近在公司服务器使用jupyter出现了点问题&#xff0c;也不知道怎么回事&#xff0c;jupyter lab打开都没问题&#xff0c;但是准备打开一个ipynb文件时就卡住了&#xff0c;啥反应没有&#xff0c;ctrlC 也不能关掉jupy…

抢单业务介绍

存在的问题 会出现多个人同时访问的问题 解决办法&#xff1a;在判断前加锁&#xff0c;使用户在抢单前先访问锁然后在执行之后的操作 常见的锁 1.基于数据库 2.基础缓存(Redis等) 3.基于Zookeeper

Ubuntu 20.04 安装搜狗输入法,无法输入中文问题

搜狗输入法linux-安装指导 无法输入中文&#xff0c;主要是下面的命令没有执行&#xff1a; sudo apt install libqt5qml5 libqt5quick5 libqt5quickwidgets5qml-module-qtquick2 sudo apt install libgsettings-qt1 我的新台式机第一次执行上述命令失败&#xff0c;应该是默…

Stable Diffusion模型介绍

在深度学习和人工智能领域&#xff0c;Stable Diffusion模型作为一项前沿技术&#xff0c;已经引起了广泛的关注。本文将深入探讨Stable Diffusion模型的种类、特点以及它们在不同场景下的应用。 1. CheckPoint模型 Checkpoint模型是Stable Diffusion系列中的主模型&#xff…

【Qt】Visual Studio中打开Qt工程中的.ui文件闪退

1. 问题 Visual Studio中双击打开Qt工程中的.ui文件闪退。 2. 解决方法 .ui文件鼠标右键打开方式添加msvc中designer.ext路径&#xff08;安装路径\Qt6\5.15.2\msvc2015_64\bin&#xff09;将新设置的打开方式设置为默认打开方式。

Mac安装telnet

一、安装Homebrew 1、打开官网&#xff1a;Homebrew — The Missing Package Manager for macOS (or Linux) 2、打开终端输入&#xff1a; /usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)" 二、安装Telnet bre…

如何在使用 ES Modules 的 Node.js 应用中创建和使用 __dirname 和 __filename 这两个全局变量

在 Node.js 的 ES Modules (ESM) 环境中&#xff0c;传统的 CommonJS 全局变量 __dirname 和 __filename 不再直接可用。这是因为 ES Modules 采用不同的模块解析策略&#xff0c;更加符合 ECMAScript 标准。因此&#xff0c;如果在使用 ES Modules 格式编写 Node.js 代码&…

Apache Flink 中作业图与执行图的深入解析

Apache Flink 是一个用于分布式流处理和批处理的开源框架&#xff0c;它的核心概念之一是使用一系列层次化的执行图来抽象和优化用户的流处理作业。以下是 Flink 中作业图和执行图的详细介绍&#xff1a; StreamGraph(逻辑流图) StreamGraph 是用户编写的应用程序代码转换成的第…