Spring Boot配置MinIO（实现文件上传、下载、删除）

小灰灰 2022-11-19 06:27 511阅读 0赞

## 1 MinIO ##

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

MinIO是一个非常轻量的服务,可以很简单的和其他应用的结合，类似 NodeJS, Redis 或者 MySQL。

## 2 MinIO安装和启动 ##

由于MinIO是一个单独的服务器，需要单独部署，有关MinIO在Windows系统上的使用请查看以下博客。

[Windows MinIO使用教程（启动，登录，修改密码）][Windows MinIO]

## 3 pom.xml（maven依赖文件） ##

<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		<dependency>
    			<groupId>cn.hutool</groupId>
    			<artifactId>hutool-all</artifactId>
    			<version>5.5.7</version>
    		</dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>io.minio</groupId>
                <artifactId>minio</artifactId>
                <version>7.0.2</version>
            </dependency>

##  4 applicatin.properties（配置文件） ##

# 设置单个文件大小
    spring.servlet.multipart.max-file-size= 50MB
    #minio文件服务器配置
    minio.address=http://localhost:9000
    minio.accessKey=admin
    minio.secretKey=12345678
    minio.bucketName=myfile

## 5 MinIOService ##

minio有关的操作（判断存储桶是否存在，创建存储桶，上传文件，下载文件，删除文件）

package com.service;
    
    import cn.hutool.core.date.DateUtil;
    import cn.hutool.core.util.StrUtil;
    import io.minio.MinioClient;
    import io.minio.PutObjectOptions;
    import lombok.Data;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
    import org.springframework.web.multipart.MultipartFile;
    
    import javax.servlet.ServletOutputStream;
    import javax.servlet.http.HttpServletResponse;
    import java.io.InputStream;
    import java.nio.charset.StandardCharsets;
    import java.util.Date;
    
    @Data
    @Component
    public class MinIOService {
        @Value("${minio.address}")
        private String address;
        @Value("${minio.accessKey}")
        private String accessKey;
        @Value("${minio.secretKey}")
        private String secretKey;
        @Value("${minio.bucketName}")
        private String bucketName;
    
        public MinioClient getMinioClient() {
            try {
                return new MinioClient(address, accessKey, secretKey);
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    
        /**
         * 检查存储桶是否存在
         *
         * @param bucketName 存储桶名称
         * @return
         */
        public boolean bucketExists(MinioClient minioClient, String bucketName) {
            boolean flag = false;
            try {
                flag = minioClient.bucketExists(bucketName);
                if (flag) {
                    return true;
                }
            } catch (Exception e) {
                e.printStackTrace();
                return false;
            }
            return false;
        }
    
        /**
         * 创建存储桶
         *
         * @param bucketName 存储桶名称
         */
        public boolean makeBucket(MinioClient minioClient, String bucketName) {
            try {
                boolean flag = bucketExists(minioClient, bucketName);
                //存储桶不存在则创建存储桶
                if (!flag) {
                    minioClient.makeBucket(bucketName);
                }
                return true;
            } catch (Exception e) {
                e.printStackTrace();
                return false;
            }
        }
    
        /**
         * 上传文件
         *
         * @param file 上传文件
         * @return 成功则返回文件名，失败返回空
         */
        public String uploadFile(MinioClient minioClient, MultipartFile file) {
            //创建存储桶
            boolean createFlag = makeBucket(minioClient, bucketName);
            //创建存储桶失败
            if (createFlag == false) {
                return "";
            }
            try {
                PutObjectOptions putObjectOptions = new PutObjectOptions(file.getSize(), PutObjectOptions.MIN_MULTIPART_SIZE);
                putObjectOptions.setContentType(file.getContentType());
                String originalFilename = file.getOriginalFilename();
                int pointIndex = originalFilename.lastIndexOf(".");
                //得到文件流
                InputStream inputStream = file.getInputStream();
                //保证文件不重名(并且没有特殊字符)
                String fileName = bucketName+ DateUtil.format(new Date(), "_yyyyMMddHHmmss") + (pointIndex > -1 ? originalFilename.substring(pointIndex) : "");
                minioClient.putObject(bucketName, fileName, inputStream, putObjectOptions);
                return fileName;
            } catch (Exception e) {
                e.printStackTrace();
                return "";
            }
        }
    
        /**
         * 下载文件
         *
         * @param originalName 文件路径
         */
        public InputStream downloadFile(MinioClient minioClient, String originalName, HttpServletResponse response) {
            try {
                InputStream file = minioClient.getObject(bucketName, originalName);
                String filename = new String(originalName.getBytes("ISO8859-1"), StandardCharsets.UTF_8);
                if (StrUtil.isNotBlank(originalName)) {
                    filename = originalName;
                }
                response.setHeader("Content-Disposition", "attachment;filename=" + filename);
                ServletOutputStream servletOutputStream = response.getOutputStream();
                int len;
                byte[] buffer = new byte[1024];
                while ((len = file.read(buffer)) > 0) {
                    servletOutputStream.write(buffer, 0, len);
                }
                servletOutputStream.flush();
                file.close();
                servletOutputStream.close();
                return file;
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    
        /**
         * 删除文件
         *
         * @param fileName 文件路径
         * @return
         */
        public boolean deleteFile(MinioClient minioClient, String fileName) {
            try {
                minioClient.removeObject(bucketName, fileName);
            } catch (Exception e) {
                e.printStackTrace();
                return false;
            }
            return true;
        }
    
        /**
         * 得到指定文件的InputStream
         *
         * @param originalName 文件路径
         * @return
         */
        public InputStream getObject(MinioClient minioClient, String originalName) {
            try {
                return minioClient.getObject(bucketName, originalName);
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    
        /**
         * 根据文件路径得到预览文件绝对地址
         *
         * @param minioClient
         * @param fileName    文件路径
         * @return
         */
        public String getPreviewFileUrl(MinioClient minioClient, String fileName) {
            try {
                return minioClient.presignedGetObject(bucketName,fileName);
            }catch (Exception e){
                e.printStackTrace();
                return "";
            }
        }
    }

##  6 FileController ##

文件上传、文件下载、文件删除接口。

package com.controller;
    
    import com.service.MinIOService;
    import io.minio.MinioClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    import org.springframework.web.multipart.MultipartFile;
    
    import javax.servlet.http.HttpServletResponse;
    
    @RequestMapping("/file")
    @RestController
    public class FileController {
        @Autowired
        private MinIOService minIOService;
    
        /**
         * 上传文件
         *
         * @param file 文件
         * @return
         */
        @PostMapping("/uploadFile")
        public String uploadFile(@RequestBody MultipartFile file) {
            MinioClient minioClient = minIOService.getMinioClient();
            if (minioClient == null) {
                return "连接MinIO服务器失败";
            }
            return minIOService.uploadFile(minioClient, file);
        }
    
        /**
         * 下载文件
         *
         * @param response 返回请求
         * @param fileName 文件路径
         * @return
         */
        @GetMapping("/downloadFile")
        public String downloadFile(HttpServletResponse response,@RequestParam String fileName) {
            MinioClient minioClient = minIOService.getMinioClient();
            if (minioClient == null) {
                return "连接MinIO服务器失败";
            }
            return minIOService.downloadFile(minioClient, fileName, response) != null ? "下载成功" : "下载失败";
        }
    
        /**
         * 删除文件
         *
         * @param fileName 文件路径
         * @return
         */
        @DeleteMapping("/deleteFile/{fileName}")
        public String deleteFile(@PathVariable("fileName") String fileName) {
            MinioClient minioClient = minIOService.getMinioClient();
            if (minioClient == null) {
                return "连接MinIO服务器失败";
            }
            boolean flag = minIOService.deleteFile(minioClient, fileName);
            return flag == true ? "删除成功" : "删除失败";
        }
    }

## 7 调试结果 ##

###  7.1 文件上传 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTc0NjM4_size_16_color_FFFFFF_t_70][]

### 7.2 文件下载  ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTc0NjM4_size_16_color_FFFFFF_t_70 1][]

### 7.3 文件删除  ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTc0NjM4_size_16_color_FFFFFF_t_70 2][]

## 注： ##

文件删除之后，如果该文件夹下没有文件存在，MinIO会自动删除该空文件夹及上级空文件夹。

[Windows MinIO]: https://blog.csdn.net/qq_38974638/article/details/115678147
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTc0NjM4_size_16_color_FFFFFF_t_70]: /images/20221022/c88678f11a1b4946a946a0d550a81d75.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTc0NjM4_size_16_color_FFFFFF_t_70 1]: /images/20221022/5008b361678e46f8a0fb9650157fcd54.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTc0NjM4_size_16_color_FFFFFF_t_70 2]: /images/20221022/17cf29d9767e40bfa3f0de7b7834766d.png