minio + linux + docker + spring boot实现文件上传与下载

Bertha 。 2024-02-20 09:18 63阅读 0赞

#### minio + docker + spring boot实现文件上传与下载 ####

*  1.在linux上安装并启动docker
 *  2.在docker中拉取minio并启动
 *  3.Spring Boot 整合 minio
 *  4.测试 minio 文件上传、下载及图片预览等功能

## 1.在linux上安装并启动docker ##

*  检查linux内核，必须是3.10以上

uname ‐r

*  安装docker

yum install docker

*  启动docker

systemctl start docker

## 2.在docker中拉取minio并启动 ##

*  搜索镜像

docker search minio

![在这里插入图片描述][5cf8307d75714ba390c87561c8215cc6.png]

*  拉取镜像

docker pull minio/minio

![在这里插入图片描述][892ee5d472d34ef68ddb2adb81b04146.png]

*  启动minio

docker run  -p 9000:9000 -p 9090:9090 --name minio \
     -d --restart=always \
     -e MINIO_ACCESS_KEY=vinci \
     -e MINIO_SECRET_KEY=123456\
     -v /usr/local/minio/data:/data \
     -v /usr/local/minio/config:/root/.minio \
      minio/minio server /data  --console-address ":9000" --address ":9090"

> \-p: 指定端口映射，格式为：主机端口:容器端口 (这里注意要映射两个，否则API会访问不到)  
> \-e “MINIO\_ROOT\_USER=vinci” minio用户名；  
> \-e MINIO\_SECRET\_KEY=123456 minio 密码  
> \-d: 后台运行容器，并返回容器ID；  
> \-v: 绑定一个卷

这里可以看到minio已经在docker里启动起来了  
![在这里插入图片描述][33092f618f8a41c59ba64cac47053a08.png]

接下来我们可以通过以下命令来查看 minio console和minio api 访问端口

docker logs minio

![在这里插入图片描述][338dd6d1c7a5493295ee4c0229d2ea4b.png]

*  访问minio控制台  
    在此步骤前记得开放端口号  
    ![在这里插入图片描述][16442bccb566497b8ac764e3d337f9de.png]  
    我们接下来可以使用密码和账号登录minio控制台了

## 3.Spring Boot 整合 minio ##

在此之前我们可以先通过控制台来创建一个bucket  
![在这里插入图片描述][72a2e7e7a47e48c1a62f71e058b758aa.png]

*  集成minio

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

*  编写minio配置类

/**
     * @package: com.vinci.minio.config
     * @className: MinioConfig
     * @author: Vinci
     * @description: minio配置类
     * @date: 2023/10/27 13:10
     */
    @Data
    @Configuration
    @ConfigurationProperties(prefix = "minio")
    public class MinioConfig {
        
    
        private String endpoint;
    
        private String accessKey;
    
        private String secretKey;
    
        private String bucketName;
    
        @Bean
        public MinioClient minioClient(){
        
            return MinioClient
                    .builder()
                    .endpoint(endpoint)
                    .credentials(accessKey, secretKey)
                    .build();
        }
    
    }

*  在application.properties中添加以下配置

minio.endpoint=http://108.13.21.28:9090/ 
    minio.bucket-name=images
    minio.access-key=xxxxx
    minio.secret-key=xxxxx

> 注意 minio.endpoint 是minio API地址，不是控制台地址  
> minio.bucket-name 是 bucket的名称  
> minio.access-key 是用户名  
> minio.secret-key是密码

*  编写minio工具类

package com.vinci.minio.utils;
    
    import com.vinci.minio.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.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;
    import java.util.UUID;
    
    /**
     * @description: minio工具类
     * @author: Vinci
     * @date: 2023/10/27 13:23
     **/
    @Component
    @Slf4j
    public class MinioUtil {
        
    
        @Resource
        private MinioConfig config;
    
        @Resource
        private MinioClient minioClient;
    
    
        /**
         * @description: 查看存储bucket是否存在
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @param bucketName 要查看的bucket名称
         * @return 存在即返回true
         **/
        public Boolean bucketExists(String bucketName) {
        
            try {
        
                return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return false;
            }
        }
    
        /**
         * @description: 创建存储bucket
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @param bucketName 要创建的bucket名称
         * @return 创建成功即返回true
         **/
        public Boolean makeBucket(String bucketName) {
        
            try {
        
                minioClient.makeBucket(MakeBucketArgs.builder()
                        .bucket(bucketName)
                        .build());
                return true;
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return false;
            }
        }
    
    
        /**
         * @description: 删除存储bucket
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @param bucketName 要删除的bucket名称
         * @return 删除成功即返回true
         **/
        public Boolean removeBucket(String bucketName) {
        
            try {
        
                minioClient.removeBucket(
                        RemoveBucketArgs.builder()
                                .bucket(bucketName)
                                .build()
                );
                return true;
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return false;
            }
        }
    
    
        /**
         * @description: 获取全部bucket
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @return 返回bucket结果集
         **/
        public List<Bucket> getAllBuckets() {
        
            try {
        
                return minioClient.listBuckets();
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return null;
            }
        }
    
    
    
        /**
         * @description: 文件上传
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @param file 表单上传的文件
         * @return 返回文件上传的路径
         **/
        public String upload(MultipartFile file) {
        
            String originalFilename = file.getOriginalFilename();
            if (originalFilename == null || originalFilename.isEmpty()){
        
                throw new RuntimeException();
            }
            String fileName = UUID.randomUUID() + originalFilename.substring(originalFilename.lastIndexOf("."));
            String objectName = new SimpleDateFormat("yyyyMM").format(new Date()) + "/" + fileName;
            try {
        
                PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(config.getBucketName()).object(objectName)
                        .stream(file.getInputStream(), file.getSize(), -1).contentType(file.getContentType()).build();
                minioClient.putObject(objectArgs);
                return objectName;
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return null;
            }
        }
    
    
        /**
         * @description: 预览图片
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @param fileName 文件在bucket中的全路径
         * @return 返回文件的浏览路径
         **/
        public String preview(String fileName){
        
            // 查看文件地址
            GetPresignedObjectUrlArgs build = GetPresignedObjectUrlArgs
                    .builder()
                    .bucket(config.getBucketName())
                    .object(fileName)
                    .method(Method.GET)
                    .build();
            try {
        
                return minioClient.getPresignedObjectUrl(build);
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return null;
            }
        }
    
    
        /**
         * @description: 文件下载
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @param fileName 文件在bucket中的全路径
         **/
        public void download(String fileName, HttpServletResponse res) {
        
            GetObjectArgs objectArgs = GetObjectArgs.builder()
                    .bucket(config.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", "inline;fileName=" + fileName);
                    try (ServletOutputStream stream = res.getOutputStream()){
        
                        stream.write(bytes);
                        stream.flush();
                    }
                }
            } catch (Exception e) {
        
                log.error("发现异常",e);
            }
        }
    
        /**
         * @description: 查看文件对象
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @return 存储bucket内文件对象信息
         **/
        public List<Item> listObjects() {
        
            Iterable<Result<Item>> results = minioClient.listObjects(
                    ListObjectsArgs.builder().bucket(config.getBucketName()).build());
            List<Item> items = new ArrayList<>();
            try {
        
                for (Result<Item> result : results) {
        
                    items.add(result.get());
                }
                return items;
            } catch (Exception e) {
        
                log.error("发现异常",e);
                return null;
            }
        }
    
        /**
         * @description: 删除文件信息
         * @author: Vinci
         * @date: 2023/10/27 13:24
         * @return 删除成功则返回true
         **/
        public boolean remove(String fileName){
        
            try {
        
                minioClient.removeObject(
                        RemoveObjectArgs.builder()
                                .bucket(config.getBucketName())
                                .object(fileName).build()
                );
                return true;
            }catch (Exception e){
        
                log.error("发现异常",e);
                return false;
            }
        }
        
        
    
    }

## 4.测试 minio 文件上传、下载及图片预览等功能 ##

*  编写controller通过接口的方式来测试minio功能

package com.vinci.minio.controller;
    
    import com.vinci.minio.utils.MinioUtil;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.*;
    import org.springframework.web.multipart.MultipartFile;
    
    import javax.annotation.Resource;
    import javax.servlet.http.HttpServletResponse;
    
    /**
     * @package: com.vinci.minio.controller
     * @className: TestMinioController
     * @author: Vinci
     * @description: 测试minio
     * @date: 2023/10/27 13:48
     */
    @Controller
    @RequestMapping(value = "/minio")
    public class TestMinioController {
        
    
        @Resource
        private MinioUtil minioUtil;
    
        /**
         * @description: 文件上传测试
         * @author: Vinci
         * @date: 2023/10/27 13:48
         **/
        @ResponseBody
        @PostMapping("/upload")
        public String fileUpload(MultipartFile file) {
        
            return minioUtil.upload(file);
        }
    
        /**
         * @description: 文件下载测试
         * @author: Vinci
         * @date: 2023/10/27 13:51
         **/
        @ResponseBody
        @GetMapping("/download")
        public String fileDownload(String fileName, HttpServletResponse response){
        
            minioUtil.download(fileName,response);
            return "success";
        }
    
        /**
         * @description: 图片预览
         * @author: Vinci
         * @date: 2023/10/27 13:53
         **/
        @GetMapping("/preview")
        public String imagePreview(String fileName){
        
            return minioUtil.preview(fileName);
        }
    
    }

*  测试文件上传  
    使用postMan来调用文件上传的接口  
    ![在这里插入图片描述][9846b08719e349a7a1bbd12c351fc9e0.png]  
    我们返回控制台可以看到文件已经上传上去了  
    ![在这里插入图片描述][7b8b71c97be745b9a043ad6f51d4e046.png]
 *  测试文件下载  
    ![在这里插入图片描述][df485e8697ac4d18a1bcb4431d5f9a2e.png]  
    我们借助postman工具点击发送并下载可以看到文件下载成功了  
    ![在这里插入图片描述][236c78dfa3634e9c90b5f13921d12a1f.png]  
    ![在这里插入图片描述][09cc183450e243c099f9b4e8fdfa0b73.png]
 *  图片在线预览  
    ![在这里插入图片描述][d1704e1ff28545388c93824fc8c77a5c.png]  
    我们同样借助postman工具发送请求，我们可以看到返回了图片的在线浏览地址，点击即可在线浏览图片  
    ![在这里插入图片描述][49a894a1109b4896b500ce4df781419d.png]  
    以上便是minio 整合springboot的全部流程了，感谢阅读！  
    SpringBoot案例地址：https://gitee.com/vinci99/springboot-minio-test.git

[5cf8307d75714ba390c87561c8215cc6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/edca7b31090a47c9acf57a4e599ddeb6.png
[892ee5d472d34ef68ddb2adb81b04146.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/c05d75a73d34489ab096559b19c40657.png
[33092f618f8a41c59ba64cac47053a08.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/5e1cecc803934795b74f171e8c55b128.png
[338dd6d1c7a5493295ee4c0229d2ea4b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/26fe48b464f94d4cab11ec43343bf398.png
[16442bccb566497b8ac764e3d337f9de.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/1c4d5247209c456fb0e15047b08df0a0.png
[72a2e7e7a47e48c1a62f71e058b758aa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/b38541831b5e4e05a42ab66c28cbd65e.png
[9846b08719e349a7a1bbd12c351fc9e0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/254f7ec1f0ed404fb28deb1ce26a32e3.png
[7b8b71c97be745b9a043ad6f51d4e046.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/f965c6868bec41f194c11b1bfdf1fb7e.png
[df485e8697ac4d18a1bcb4431d5f9a2e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/d83d9ee2ea354e28b7d2cf0d7afaea6a.png
[236c78dfa3634e9c90b5f13921d12a1f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/fbaa6882301348b5959f784cbd69388b.png
[09cc183450e243c099f9b4e8fdfa0b73.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/eec0e049dcc34113b114cfe98ee3a2ff.png
[d1704e1ff28545388c93824fc8c77a5c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/35b780d6ef1d41df964dda3e1313330b.png
[49a894a1109b4896b500ce4df781419d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/f6303d22feb44bf09d2575d948460e68.png