我的编程空间,编程开发者的网络收藏夹
学习永远不晚

SpringBoot整合minio服务(超详细)

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

SpringBoot整合minio服务(超详细)

一、使用docker部署minio

1、拉取镜像

docker pull minio/minio

2、创建目录

mkdir -p /home/minio/configmkdir -p /home/minio/data

3、创建Minio容器并运行

docker run -p 9000:9000 -p 9090:9090 \     --net=host \     --name minio \     -d --restart=always \     -e "MINIO_ACCESS_KEY=minioadmin" \     -e "MINIO_SECRET_KEY=minioadmin" \     -v /home/minio/data:/data \     -v /home/minio/config:/root/.minio \     minio/minio server \     /data --console-address ":9090" -address ":9000"

4、登录minio控制台

 5、创建buckets存储桶测试 

创建一个名为public的存储桶(名字可自定义),上传文件。

通过http://ip:9000/存储桶名/文件名访问文件

若出现:

可以将存储桶的访问权限设置为public.

二、SpringBoot整合minio

1、创建minio-demo项目

2、引入pom依赖

    io.minio    minio    7.0.2

3、编写配置文件

在application.yml文件中编写相关配置。

server:  port: 8081spring:  # 配置文件上传大小限制  servlet:    multipart:      max-file-size: 200MB      max-request-size: 200MBminio:  host: http://127.0.0.1:9000  url: ${minio.host}/${minio.bucket}/  access-key: minioadmin  secret-key: minioadmin  bucket: public

4、编写MinioConfig配置类

import io.minio.MinioClient;import io.minio.ObjectStat;import io.minio.PutObjectOptions;import io.minio.Result;import io.minio.messages.Bucket;import io.minio.messages.Item;import org.apache.tomcat.util.http.fileupload.IOUtils;import org.springframework.beans.factory.InitializingBean;import org.springframework.beans.factory.annotation.Value;import org.springframework.stereotype.Component;import org.springframework.util.Assert;import org.springframework.web.multipart.MultipartFile;import org.springframework.web.util.UriUtils;import javax.servlet.http.HttpServletResponse;import java.io.IOException;import java.io.InputStream;import java.net.URLEncoder;import java.nio.charset.StandardCharsets;import java.util.ArrayList;import java.util.List;@Componentpublic class MinioConfig implements InitializingBean {    @Value(value = "${minio.bucket}")    private String bucket;    @Value(value = "${minio.host}")    private String host;    @Value(value = "${minio.url}")    private String url;    @Value(value = "${minio.access-key}")    private String accessKey;    @Value(value = "${minio.secret-key}")    private String secretKey;    private MinioClient minioClient;    @Override    public void afterPropertiesSet() throws Exception {        Assert.hasText(url, "Minio url 为空");        Assert.hasText(accessKey, "Minio accessKey为空");        Assert.hasText(secretKey, "Minio secretKey为空");        this.minioClient = new MinioClient(this.host, this.accessKey, this.secretKey);    }        public String putObject(MultipartFile multipartFile) throws Exception {        // bucket 不存在,创建        if (!minioClient.bucketExists(this.bucket)) {            minioClient.makeBucket(this.bucket);        }        try (InputStream inputStream = multipartFile.getInputStream()) {            // 上传文件的名称            String fileName = multipartFile.getOriginalFilename();            // PutObjectOptions,上传配置(文件大小,内存中文件分片大小)            PutObjectOptions putObjectOptions = new PutObjectOptions(multipartFile.getSize(), PutObjectOptions.MIN_MULTIPART_SIZE);            // 文件的ContentType            putObjectOptions.setContentType(multipartFile.getContentType());            minioClient.putObject(this.bucket, fileName, inputStream, putObjectOptions);            // 返回访问路径            return this.url + UriUtils.encode(fileName, StandardCharsets.UTF_8);        }    }        public void download(String fileName, HttpServletResponse response){        // 从链接中得到文件名        InputStream inputStream;        try {            MinioClient minioClient = new MinioClient(host, accessKey, secretKey);            ObjectStat stat = minioClient.statObject(bucket, fileName);            inputStream = minioClient.getObject(bucket, fileName);            response.setContentType(stat.contentType());            response.setCharacterEncoding("UTF-8");            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));            IOUtils.copy(inputStream, response.getOutputStream());            inputStream.close();        } catch (Exception e){            e.printStackTrace();            System.out.println("有异常:" + e);        }    }        public List listBucketNames()            throws Exception {        List bucketList = listBuckets();        List bucketListName = new ArrayList<>();        for (Bucket bucket : bucketList) {            bucketListName.add(bucket.name());        }        return bucketListName;    }        public List listBuckets()            throws Exception {        return minioClient.listBuckets();    }        public boolean bucketExists(String bucketName) throws Exception {        boolean flag = minioClient.bucketExists(bucketName);        if (flag) {            return true;        }        return false;    }        public boolean makeBucket(String bucketName)            throws Exception {        boolean flag = bucketExists(bucketName);        if (!flag) {            minioClient.makeBucket(bucketName);            return true;        } else {            return false;        }    }        public boolean removeBucket(String bucketName)            throws Exception {        boolean flag = bucketExists(bucketName);        if (flag) {            Iterable> myObjects = listObjects(bucketName);            for (Result result : myObjects) {                Item item = result.get();                // 有对象文件,则删除失败                if (item.size() > 0) {                    return false;                }            }            // 删除存储桶,注意,只有存储桶为空时才能删除成功。            minioClient.removeBucket(bucketName);            flag = bucketExists(bucketName);            if (!flag) {                return true;            }        }        return false;    }        public Iterable> listObjects(String bucketName) throws Exception {        boolean flag = bucketExists(bucketName);        if (flag) {            return minioClient.listObjects(bucketName);        }        return null;    }        public List listObjectNames(String bucketName) throws Exception {        List listObjectNames = new ArrayList<>();        boolean flag = bucketExists(bucketName);        if (flag) {            Iterable> myObjects = listObjects(bucketName);            for (Result result : myObjects) {                Item item = result.get();                listObjectNames.add(item.objectName());            }        }        return listObjectNames;    }        public boolean removeObject(String bucketName, String objectName) throws Exception {        boolean flag = bucketExists(bucketName);        if (flag) {            List objectList = listObjectNames(bucketName);            for (String s : objectList) {                if(s.equals(objectName)){                    minioClient.removeObject(bucketName, objectName);                    return true;                }            }        }        return false;    }        public String getObjectUrl(String bucketName, String objectName) throws Exception {        boolean flag = bucketExists(bucketName);        String url = "";        if (flag) {            url = minioClient.getObjectUrl(bucketName, objectName);        }        return url;    }}

5、编写MinioController类

import com.minio.demo.config.MinioConfig;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;@RestController@CrossOrigin@RequestMapping("/test")public class MinioController {    @Autowired    MinioConfig minioConfig;    // 上传    @PostMapping("/upload")    public Object upload(@RequestParam("file") MultipartFile multipartFile) throws Exception {        return this.minioConfig.putObject(multipartFile);    }    // 下载文件    @GetMapping("/download")    public void download(@RequestParam("fileName")String fileName, HttpServletResponse response) {        this.minioConfig.download(fileName,response);    }    // 列出所有存储桶名称    @PostMapping("/list")    public List list() throws Exception {        return this.minioConfig.listBucketNames();    }    // 创建存储桶    @PostMapping("/createBucket")    public boolean createBucket(String bucketName) throws Exception {        return this.minioConfig.makeBucket(bucketName);    }    // 删除存储桶    @PostMapping("/deleteBucket")    public boolean deleteBucket(String bucketName) throws Exception {        return this.minioConfig.removeBucket(bucketName);    }    // 列出存储桶中的所有对象名称    @PostMapping("/listObjectNames")    public List listObjectNames(String bucketName) throws Exception {        return this.minioConfig.listObjectNames(bucketName);    }    // 删除一个对象    @PostMapping("/removeObject")    public boolean removeObject(String bucketName, String objectName) throws Exception {        return this.minioConfig.removeObject(bucketName, objectName);    }    // 文件访问路径    @PostMapping("/getObjectUrl")    public String getObjectUrl(String bucketName, String objectName) throws Exception {        return this.minioConfig.getObjectUrl(bucketName, objectName);    }}

6、测试(上传)

开发中上传接口用得较多,其他接口可自行测试。 

三、Vue+Element-ui前端交互

# npm下载element-ui

npm install element-ui -S

// 引入ElementUIimport ElementUI from 'element-ui'import 'element-ui/lib/theme-chalk/index.css'Vue.use(ElementUI)

来源地址:https://blog.csdn.net/yueyue763184/article/details/131147025

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

SpringBoot整合minio服务(超详细)

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

SpringBoot整合Jackson超详细用法

这篇文章主要介绍了SpringBoot整合Jackson超详细教程,本篇讲的是Jackson的详细用法,Jackson工具类在文章最后,直接复制粘贴即可使用,需要的朋友可以参考下
2023-03-23

Springboot怎么整合minio实现文件服务

本篇内容介绍了“Springboot怎么整合minio实现文件服务”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!首先pom文件引入相关依赖
2023-06-30

SpringBoot 2.x怎么整合MinIo文件服务

本篇内容主要讲解“SpringBoot 2.x怎么整合MinIo文件服务”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“SpringBoot 2.x怎么整合MinIo文件服务”吧!MinIO 是高
2023-06-03

《SpringBoot篇》26.SpringBoot整合Jackson超详细教程(附Jackson工具类)

陈老老老板🦸 👨‍💻本文专栏:SpringBoot篇(主要讲一些与springboot整合相关的内容) 👨‍💻本文简述:本文讲一下Jackso
2023-08-18

SpringBoot整合Zookeeper详细教程

Curator是Netflix公司开源的⼀套zookeeper客户端框架,Curator是对Zookeeper⽀持最好的客户端框架。Curator封装了⼤部分Zookeeper的功能,⽐如Leader选举、分布式锁等,减少了技术⼈员在使⽤Zookeeper时的底层细节开发⼯作
2022-12-23

SpringBoot整合RocketMQ的详细过程

这篇文章主要介绍了SpringBoot整合RocketMQ的详细过程,本文分为三部分,第一部分实现SpringBoot与RocketMQ的整合,第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们,第三部分介绍如何封装RocketMQ以便更好地使用,需要的朋友可以参考下
2023-05-15

SpringBoot整合ActiveMQ的详细步骤

昨天仔细研究了activeMQ消息队列,也遇到了些坑,下面这篇文章主要给大家介绍了关于SpringBoot整合ActiveMQ的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-11-13

Spring Boot整合Bootstrap的超详细步骤

之前做前端开发,在使用bootstrap的时候都是去官网下载,然后放到项目中,在页面引用,下面这篇文章主要给大家介绍了关于Spring Boot整合Bootstrap的超详细步骤,需要的朋友可以参考下
2023-05-19

编程热搜

  • Python 学习之路 - Python
    一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
    Python 学习之路 - Python
  • chatgpt的中文全称是什么
    chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
    chatgpt的中文全称是什么
  • C/C++中extern函数使用详解
  • C/C++可变参数的使用
    可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
    C/C++可变参数的使用
  • css样式文件该放在哪里
  • php中数组下标必须是连续的吗
  • Python 3 教程
    Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
    Python 3 教程
  • Python pip包管理
    一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
    Python pip包管理
  • ubuntu如何重新编译内核
  • 改善Java代码之慎用java动态编译

目录