MinIO是什么？如何使用

news2024/7/6 18:40:12

哈喽！大家好，我是旷世奇才李先生
文章持续更新，可以微信搜索【小奇JAVA面试】第一时间阅读，回复【资料】更有我为大家准备的福利哟，回复【项目】获取我为大家准备的项目

文章目录

  • 一、MinIO介绍
    • 1、简介
    • 2、优缺点
  • 二、MinIO 使用
    • 1、使用docker进行环境部署和启动
    • 2、minio中建立一个存储的桶
    • 3、java代码整合minio使用
    • 4、封装MinIO为starter
  • 三、总结

相关阅读

  • 面试官：Zookeeper是什么，它有什么特性与使用场景？
  • 面试官：Redis如何实现持久化的、主从哨兵又是什么？

一、MinIO介绍

1、简介

MinIO基于Apache License v2.0开源协议的对象存储服务，可以做为云存储的解决方案用来保存海量的图片，视频，文档。由于采用Golang实现，服务端可以工作在Windows,Linux, OS X和FreeBSD上。配置简单，基本是复制可执行程序，单行命令可以运行起来。

MinIO兼容亚马逊S3云存储服务接口，非常适合于存储大容量非结构化的数据，例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等，而一个对象文件可以是任意大小，从几kb到最大5T不等。

2、优缺点

在这里插入图片描述

二、MinIO 使用

1、使用docker进行环境部署和启动

启动docker容器

docker run -p 9000:9000 --name minio -d --restart=always -e "MINIO_ACCESS_KEY=minio" -e "MINIO_SECRET_KEY=minio123" -v /home/data:/data -v /home/config:/root/.minio minio/minio server /data

访问登录地址 http://192.168.200.130:9000

登录页面如下

在这里插入图片描述

用户名为：minio 密码为：minio123

2、minio中建立一个存储的桶

在这里插入图片描述
点击这个create bucket按钮创建一个桶的名字

3、java代码整合minio使用

import io.minio.MinioClient;
import io.minio.PutObjectArgs;

import java.io.FileInputStream;

public class MinIOApplication {

    /**
     * @Author: KSQC
     * @Description: 把list.html文件上传到minio中，并且可以在浏览器中访问
     * @Date: 2023/9/9 18:35
     */
    public static void main(String[] args) {

        try {
            FileInputStream fileInputStream = new FileInputStream("D:\\list.html");

            //1，过去minio的链接信息，创建一个minio的客户端
            MinioClient minioClient = MinioClient.builder().credentials("minio","minio123").endpoint("http://192.168.200.130:9000").build();

            //2.上传
            PutObjectArgs putObjectArgs = PutObjectArgs.builder()
                    .object("list.html") //文件名词
                    .contentType("text/html") //文件类型
                    .bucket("leadnews") //桶名称 与minio管理界面创建的桶一致即可
                    .stream(fileInputStream,fileInputStream.available(),-1).build();
            minioClient.putObject(putObjectArgs);

            //访问路径
            System.out.println("http://192.168.200.130:9000/leadnews/list.html");
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}

上传成功后我们访问连接地址可以成功看到结果信息。

在这里插入图片描述

4、封装MinIO为starter

在微服务项目当中我们需要将文件上传单独抽出一个服务来集中管理，所以这个时候我们创建一个新的模块，然后导入我们的封装好的一些工具类，这样使用的时候更加方便。

首先使MinIOConfig类

package com.heima.file.config;

import com.heima.file.service.FileStorageService;
import io.minio.MinioClient;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Data
@Configuration
@EnableConfigurationProperties({MinIOConfigProperties.class})
//当引入FileStorageService接口时
@ConditionalOnClass(FileStorageService.class)
public class MinIOConfig {

    @Autowired
    private MinIOConfigProperties minIOConfigProperties;

    @Bean
    public MinioClient buildMinioClient() {
        return MinioClient
                .builder()
                .credentials(minIOConfigProperties.getAccessKey(), minIOConfigProperties.getSecretKey())
                .endpoint(minIOConfigProperties.getEndpoint())
                .build();
    }
}

然后是MinIOConfigProperties类

package com.heima.file.config;


import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

import java.io.Serializable;

@Data
@ConfigurationProperties(prefix = "minio")  // 文件上传 配置前缀file.oss
public class MinIOConfigProperties implements Serializable {

    private String accessKey;
    private String secretKey;
    private String bucket;
    private String endpoint;
    private String readPath;
}

然后是FileStorageService接口

package com.heima.file.service;

import java.io.InputStream;

/**
 * @author itheima
 */
public interface FileStorageService {


    /**
     *  上传图片文件
     * @param prefix  文件前缀
     * @param filename  文件名
     * @param inputStream 文件流
     * @return  文件全路径
     */
    public String uploadImgFile(String prefix, String filename,InputStream inputStream);

    /**
     *  上传html文件
     * @param prefix  文件前缀
     * @param filename   文件名
     * @param inputStream  文件流
     * @return  文件全路径
     */
    public String uploadHtmlFile(String prefix, String filename,InputStream inputStream);

    /**
     * 删除文件
     * @param pathUrl  文件全路径
     */
    public void delete(String pathUrl);

    /**
     * 下载文件
     * @param pathUrl  文件全路径
     * @return
     *
     */
    public byte[]  downLoadFile(String pathUrl);

}

然后是MinIOFileStorageService类

package com.heima.file.service.impl;


import com.heima.file.config.MinIOConfig;
import com.heima.file.config.MinIOConfigProperties;
import com.heima.file.service.FileStorageService;
import io.minio.GetObjectArgs;
import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import io.minio.RemoveObjectArgs;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Import;
import org.springframework.util.StringUtils;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.Date;

@Slf4j
@EnableConfigurationProperties(MinIOConfigProperties.class)
@Import(MinIOConfig.class)
public class MinIOFileStorageService implements FileStorageService {

    @Autowired
    private MinioClient minioClient;

    @Autowired
    private MinIOConfigProperties minIOConfigProperties;

    private final static String separator = "/";

    /**
     * @param dirPath
     * @param filename  yyyy/mm/dd/file.jpg
     * @return
     */
    public String builderFilePath(String dirPath,String filename) {
        StringBuilder stringBuilder = new StringBuilder(50);
        if(!StringUtils.isEmpty(dirPath)){
            stringBuilder.append(dirPath).append(separator);
        }
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd");
        String todayStr = sdf.format(new Date());
        stringBuilder.append(todayStr).append(separator);
        stringBuilder.append(filename);
        return stringBuilder.toString();
    }

    /**
     *  上传图片文件
     * @param prefix  文件前缀
     * @param filename  文件名
     * @param inputStream 文件流
     * @return  文件全路径
     */
    @Override
    public String uploadImgFile(String prefix, String filename,InputStream inputStream) {
        String filePath = builderFilePath(prefix, filename);
        try {
            PutObjectArgs putObjectArgs = PutObjectArgs.builder()
                    .object(filePath)
                    .contentType("image/jpg")
                    .bucket(minIOConfigProperties.getBucket()).stream(inputStream,inputStream.available(),-1)
                    .build();
            minioClient.putObject(putObjectArgs);
            StringBuilder urlPath = new StringBuilder(minIOConfigProperties.getReadPath());
            urlPath.append(separator+minIOConfigProperties.getBucket());
            urlPath.append(separator);
            urlPath.append(filePath);
            return urlPath.toString();
        }catch (Exception ex){
            log.error("minio put file error.",ex);
            throw new RuntimeException("上传文件失败");
        }
    }

    /**
     *  上传html文件
     * @param prefix  文件前缀
     * @param filename   文件名
     * @param inputStream  文件流
     * @return  文件全路径
     */
    @Override
    public String uploadHtmlFile(String prefix, String filename,InputStream inputStream) {
        String filePath = builderFilePath(prefix, filename);
        try {
            PutObjectArgs putObjectArgs = PutObjectArgs.builder()
                    .object(filePath)
                    .contentType("text/html")
                    .bucket(minIOConfigProperties.getBucket()).stream(inputStream,inputStream.available(),-1)
                    .build();
            minioClient.putObject(putObjectArgs);
            StringBuilder urlPath = new StringBuilder(minIOConfigProperties.getReadPath());
            urlPath.append(separator+minIOConfigProperties.getBucket());
            urlPath.append(separator);
            urlPath.append(filePath);
            return urlPath.toString();
        }catch (Exception ex){
            log.error("minio put file error.",ex);
            ex.printStackTrace();
            throw new RuntimeException("上传文件失败");
        }
    }

    /**
     * 删除文件
     * @param pathUrl  文件全路径
     */
    @Override
    public void delete(String pathUrl) {
        String key = pathUrl.replace(minIOConfigProperties.getEndpoint()+"/","");
        int index = key.indexOf(separator);
        String bucket = key.substring(0,index);
        String filePath = key.substring(index+1);
        // 删除Objects
        RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder().bucket(bucket).object(filePath).build();
        try {
            minioClient.removeObject(removeObjectArgs);
        } catch (Exception e) {
            log.error("minio remove file error.  pathUrl:{}",pathUrl);
            e.printStackTrace();
        }
    }


    /**
     * 下载文件
     * @param pathUrl  文件全路径
     * @return  文件流
     *
     */
    @Override
    public byte[] downLoadFile(String pathUrl)  {
        String key = pathUrl.replace(minIOConfigProperties.getEndpoint()+"/","");
        int index = key.indexOf(separator);
        String bucket = key.substring(0,index);
        String filePath = key.substring(index+1);
        InputStream inputStream = null;
        try {
            inputStream = minioClient.getObject(GetObjectArgs.builder().bucket(minIOConfigProperties.getBucket()).object(filePath).build());
        } catch (Exception e) {
            log.error("minio down file error.  pathUrl:{}",pathUrl);
            e.printStackTrace();
        }

        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
        byte[] buff = new byte[100];
        int rc = 0;
        while (true) {
            try {
                if (!((rc = inputStream.read(buff, 0, 100)) > 0)) break;
            } catch (IOException e) {
                e.printStackTrace();
            }
            byteArrayOutputStream.write(buff, 0, rc);
        }
        return byteArrayOutputStream.toByteArray();
    }
}

最后我们写一个Test测试类来测试一下

@SpringBootTest(classes = MinIOApplication.class)
@RunWith(SpringRunner.class)
public class MinIOTest {

    @Autowired
    private FileStorageService fileStorageService;

    //把list.html文件上传到minio中，并且可以在浏览器中访问

    @Test
    public void test() throws FileNotFoundException {
        FileInputStream fileInputStream = new FileInputStream("D:\\list.html");
        String path = fileStorageService.uploadHtmlFile("", "list.html", fileInputStream);
        System.out.println(path);
    }
    }

上传成功后我们可以看到我们按照日期进行了一个存储目录的区分，以后我们每天上传的文件都在一个文件夹下
在这里插入图片描述

在看一下我们minio页面创建了时间的目录

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

真正我们在开发中是需要进行时间的一个分目录操作，因为如果后续排查问题的时候我们可以根据哪一天上传附件有问题然后只看某一天的目录下有没有成功上传这个附件即可。

三、总结

项目涉及的功能还是比较全面的，建议大家跟着视频做一遍。可以关注公众号回复【项目】领取项目，如果有用就点赞支持一下吧。

文章持续更新，可以微信搜索【小奇JAVA面试】第一时间阅读，回复【项目】获取我为大家准备的项目

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

类和对象（1）

类和对象（1）

文章目录 1.面向过程和面向对象初步认识2.类的引入3.类的定义4.类的访问限定符和封装4.1访问限定符4.2封装 5.类的作用域6.类的实例化6.2结构体内存对齐规则 7.this指针7.2this指针的特性 封装（补充） 1.面向过程和面向对象初步认识 C面向对象但不纯面向…
阅读更多...
推荐几款实用的Google浏览器插件

推荐几款实用的Google浏览器插件

推荐几款实用的Google浏览器插件 1. 阅读翻译插件1.1 Google 翻译1.2 DeepL翻译（适合大段落） 2. 视频字幕翻译插件2.1 YouTube™ 双字幕2.2 Dualsub——实现双字幕 3. 评论翻译插件3.1 油管评论翻译机 4. Infinity 新标签页 (Pro)5. 附加其他5.1 Octotre…
阅读更多...
JDK20 + SpringBoot 3.1.0 + JdbcTemplate 使用

JDK20 + SpringBoot 3.1.0 + JdbcTemplate 使用

JDK20 SpringBoot 3.1.0 JdbcTemplate 使用 一.测试数据库 Postgres二.SpringBoot项目1.Pom 依赖2.配置文件3.启动类4.数据源配置类5.实体对象类包装类6.测试用实体对象1.基类2.扩展类 7.测试类 通过 JdbcTemplate 直接执行 SQL 语句，结合源码动态编译即可方便实现…
阅读更多...
复现SCI文章系列教程 | 文章复现一(IF 7.3)：文章讨论与文章分析套路讲解

复现SCI文章系列教程 | 文章复现一(IF 7.3)：文章讨论与文章分析套路讲解

一、本期复现文章 本系列教程从今天开始，前面想做，但是又没时间。作为佛系博主的我来说，这个系列教程算是一个长久的计划。会涉及医学和植物两大类。本系列教程详细情况可以看《复现SCI文章系列教程》. 我们第一篇复现的文章寻找的是的来自…
阅读更多...
Spring MVC：请求转发与请求重定向

Spring MVC：请求转发与请求重定向

Spring MVC 请求转发请求重定向附 请求转发 转发（ forward ），指服务器接收请求后，从一个资源跳转到另一个资源中。请求转发是一次请求，不会改变浏览器的请求地址。 简单示例： 1.通过 String 类型的返回值…
阅读更多...
开学季买哪个牌子的电容笔好？ipad触控笔推荐平价

开学季买哪个牌子的电容笔好？ipad触控笔推荐平价

我想很多学生们在新学期开始之前就开始买iPad了，如今，作为iPad主要配件之一的电容笔，功能越来越强，使用的人也越来越多。所以，怎样选择一支质量好，价格便宜的电容笔就成了人们最为关注的问题。所以&#xf…
阅读更多...
软件测试需求分析

软件测试需求分析

1.1 需求的重要性 1.1.1 软件缺陷的8020原则 1) 在软件测试过程中，从需求分析开始到集成测试阶段引入测试手段，能发现所有缺陷的80%；系统测试阶段引入测试手段，能发现剩余缺陷中80%的缺陷；在运行维护阶段经过长…
阅读更多...
云服务器与http服务器

云服务器与http服务器

如何与http服务器建立连接（客户端）？ http请求设计格式： 例子： 发送http请求 http数据响应格式： 接收http服务器返回的数据需要进一步进行字符串处理操作，提取有用的数据。
阅读更多...
21天学会C++：Day8----范围for与nullptr

21天学会C++：Day8----范围for与nullptr

目录 ​编辑 1. 范围for 2. nullptr 1. 范围for 我们在写C语言循环遍历代码的时候，无论是用 for循环，while循环都需要考虑循环的起始条件，循环变量的递增逻辑，循环的结束条件。麻烦不说还可能会出错。 int main() {int arr[]…
阅读更多...
2023-09-11 LeetCode每日一题（课程表 III）

2023-09-11 LeetCode每日一题（课程表 III）

2023-09-11每日一题 一、题目编号 630. 课程表 III二、题目链接 点击跳转到题目位置 三、题目描述 这里有 n 门不同的在线课程，按从 1 到 n 编号。给你一个数组 courses ，其中 courses[i] [durationi, lastDayi] 表示第 i 门课将会 持续 上 durati…
阅读更多...
MySQL版数据库原理与应用期末复习重点（1）---关系代数（除运算和自连接查询、手写例题）

MySQL版数据库原理与应用期末复习重点（1）---关系代数（除运算和自连接查询、手写例题）

文章目录 一、除运算题目二、自连接查询 一、除运算题目 注：在除运算中就包含了选择和投影运算。 二、自连接查询 注：自连接查询一般很少用到。
阅读更多...
引爆效率！新一代搜索引擎软件助您快速获取关键数据

引爆效率！新一代搜索引擎软件助您快速获取关键数据

一款突破性的搜索引擎软件，助您轻松检索相关数据 →→MsrayPlus官方网址 您是否曾为从海量信息中筛选出关键数据而烦恼？现在，我们为您推出一款全新的搜索引擎软件，让您从繁杂的搜索结果中快速捕捉所需信息。这款软件拥有三大功…
阅读更多...
电脑网络不能用？解决99%的网络连接问题...

电脑网络不能用？解决99%的网络连接问题...

公文：网络又不能用了？ 检查设备连接 首先，我们需要确保所有的网络设备都正确连接。检查以下几点： 路由器状态：确保路由器的电源开关打开，并且显示灯在正常工作。 网线连接：检查所有网线连接…
阅读更多...
.Net MVC 使用Areas后存在相同Controller时报错的解决办法； 从上下文获取请求的Area名及Controller名

.Net MVC 使用Areas后存在相同Controller时报错的解决办法； 从上下文获取请求的Area名及Controller名

先来说个额外的问题：如何在请求上下文（比如过滤器的中）获取请求对应的Area和Controller 名字？（假设请求上下文对象为 filterContext ）： 1. 获取Area名: (string)filterContext.RouteData.DataTo…
阅读更多...
山西3D数字化企业品牌展馆

山西3D数字化企业品牌展馆

为持续扩大展览群众性和覆盖面、强化影响力和传播力，让更多群众方便快捷、丰富生动地体验展览，展览办委托中央广播电视总台央视网建设了展览数字化网上展馆，通过网络手段，全要素呈现展览内容，全景式还原现场体验&#…
阅读更多...
腾讯云2核4G服务器5M带宽 218元一年 优惠价格明细表

腾讯云2核4G服务器5M带宽 218元一年 优惠价格明细表

腾讯云2核4G服务器5M带宽可以选择轻量应用服务器或云服务器ECS，轻量2核4G5M带宽服务器218元一年： 腾讯云2核4G服务器5M带宽收费 腾讯云2核4G服务器可以选择轻量应用服务器或者ECS云服务器，云服务器ECS是专业级云服务器，大多数使用…
阅读更多...
STM32-HAL库06-硬件IIC驱动FM24CL16B非易失存储器

STM32-HAL库06-硬件IIC驱动FM24CL16B非易失存储器

STM32-HAL库06-IIC驱动FM24CL16B非易失存储器 一、所用材料： STM32VGT6自制控制板 STM32CUBEMX（HAL库软件） MDK5 二、所学内容： 通过HAL库的硬件IIC对FM24CL16B存储器进行写与读取操作。 三、CUBEMX配置： 第一步…
阅读更多...
C++继承相关应用练习

C++继承相关应用练习

1、 实现一个图形类（Shape），包含受保护成员属性：周长、面积， 公共成员函数：特殊成员函数书写 定义一个圆形类（Circle），继承自图形类，包含私有属性&#xf…
阅读更多...
试试用Markdown来设计表单

试试用Markdown来设计表单

相信很多后端开发。对于前端知识是比较零碎的，所以很多时候写表单这样的工作，一般就是复制黏贴，然后改改字段。对于HTML格式，一直觉得比较杂乱，不够简洁。 最近TJ发现了一个有趣的小工具：Create HTML Form…
阅读更多...
新手请进，Python是什么，Python简介！

新手请进，Python是什么，Python简介！

Python 是荷兰人 Guido van Rossum （吉多范罗苏姆，中国程序员称其为“龟叔”）在 1990 年初开发的一种解释型编程语言。 图1：Python 的标志（Logo） Python 的诞生是极具戏曲性的，据 Guido 自述记载…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023