springboot集成minIO实现文件上传下载预览

springboot集成minIO

前置课程：Dockercompose搭建minIO文件服务器以及简单使用

1. 引入依赖

7.1.0


 
     io.minio
     minio
     ${minio.version}

2. yml配置

# minio 连接参数
minio:
  url: http://ip:port  // ip和端口号
  accessKey: tomato	// 账号
  secretKey: tomato123 // 密码
  bucketName: blog	// bucket名
#  preview-expiry: 24 //图片预览过期时间 不需要可注掉

3. config文件

package com.tk.blog.config;

import io.minio.MinioClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Configuration
@ConfigurationProperties(prefix = "minio")
public class MinIOConfig {
    
    private String url;

    
    private String accessKey;

    
    private String secretKey;

    
    private String bucketName;

    
    private Integer previewExpiry;

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    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;
    }

    public String getBucketName() {
        return bucketName;
    }

    public void setBucketName(String bucketName) {
        this.bucketName = bucketName;
    }

    public Integer getPreviewExpiry() {
        return previewExpiry;
    }

    public void setPreviewExpiry(Integer previewExpiry) {
        this.previewExpiry = previewExpiry;
    }

    @Bean
    public MinioClient getMinIOClient()
    {
        return MinioClient.builder().endpoint(url).credentials(accessKey, secretKey).build();
    }
}

4. 实体类

package com.tk.blog.entity;

import java.io.Serializable;


public class FileVo implements Serializable {
    private String fileName;
    private String previewUrl;
    
    private String module;

    public String getFileName() {
        return fileName;
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    public String getPreviewUrl() {
        return previewUrl;
    }

    public void setPreviewUrl(String previewUrl) {
        this.previewUrl = previewUrl;
    }

    public String getModule() {
        return module;
    }

    public void setModule(String module) {
        this.module = module;
    }
}

package com.tk.blog.entity;

import org.springframework.web.multipart.MultipartFile;

import java.io.Serializable;


public class FileUploadBody implements Serializable {
    
    private MultipartFile[] files;
    
    private String module;
    
    private String fileName;

    public MultipartFile[] getFiles() {
        return files;
    }

    public void setFiles(MultipartFile[] files) {
        this.files = files;
    }

    public String getModule() {
        return module;
    }

    public void setModule(String module) {
        this.module = module;
    }

    public String getFileName() {
        return fileName;
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }
}

5. service

package com.tk.blog.service;

import com.tk.blog.entity.FileUploadBody;
import com.tk.blog.entity.FileVo;

import javax.servlet.http.HttpServletResponse;
import java.util.List;


public interface MinIOFileService {
    List uploadFile(FileUploadBody body);

    String getPreviewUrl(String fileName, String bucketName);

    void downloadFile(HttpServletResponse response, String fileName, String bucketName);

    String delFile(String fileName, String bucketName);
}

package com.tk.blog.service.impl;

import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.tk.blog.config.MinIOConfig;
import com.tk.blog.entity.FileUploadBody;
import com.tk.blog.entity.FileVo;
import com.tk.blog.service.MinIOFileService;

import io.minio.*;
import io.minio.http.Method;
import lombok.extern.slf4j.Slf4j;
import org.apache.tomcat.util.http.fileupload.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.net.URLEncoder;
import java.util.*;
import java.util.concurrent.TimeUnit;


@Service
@Slf4j
public class MinIOFileServiceImpl implements MinIOFileService {

    @Autowired
    private MinIOConfig minIOConfig;
    @Autowired
    private MinioClient minioClient;

    @Override
    public List uploadFile(FileUploadBody body){
        MultipartFile[] files=body.getFiles();
        if (Objects.nonNull(files) && files.length > 0) {
            String bucketName = StringUtils.isNotBlank(body.getModule()) ? body.getModule().replaceAll(",", "") : minIOConfig.getBucketName();
            List resultList = new ArrayList<>();
            for (MultipartFile file : files) {
                try {
                    log.info("file: " + file);
                    if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {
                        minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
                    }
                    String fileName = file.getOriginalFilename();
                    if (StringUtils.isNotBlank(body.getFileName())){
                        fileName = body.getFileName();
                    }
                    StringBuffer fileNameSB = new StringBuffer();
                    fileNameSB.append(System.currentTimeMillis()).append("_").append(bucketName).append("_");
                    if (StringUtils.isNotBlank(fileName)){
                        fileNameSB.append(fileName.replaceAll(",", ""));
                    }
                    fileName = fileNameSB.toString();
                    PutObjectArgs args = PutObjectArgs.builder()
                            .bucket(bucketName)
                            .object(fileName)
                            .stream(file.getInputStream(), file.getSize(), -1)
                            .contentType(file.getContentType())
                            .build();
                    minioClient.putObject(args);
                    FileVo fileVo=new FileVo();
                    fileVo.setFileName(fileName);
                    fileVo.setModule(bucketName);
                    fileVo.setPreviewUrl(getPreviewUrl(fileName,bucketName));
                    resultList.add(fileVo);
                }catch (Exception e){
                    log.info("上传图片失败：",e.getMessage());
                }
            }
            return resultList;
        }
        return Collections.emptyList();
    }

    @Override
    public String getPreviewUrl(String fileName, String bucketName) {
        if (StringUtils.isNotBlank(fileName)) {
            bucketName = StringUtils.isNotBlank(bucketName) ? bucketName : minIOConfig.getBucketName();
            try {
                minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(fileName).build());
                if (null != minIOConfig.getPreviewExpiry()){
                    return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(bucketName).object(fileName).expiry(minIOConfig.getPreviewExpiry(), TimeUnit.HOURS).build());
                }else {
                    return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(bucketName).object(fileName).build());
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    @Override
    public void downloadFile(HttpServletResponse response, String fileName, String bucketName) {
        if (StringUtils.isNotBlank(fileName)) {
            bucketName = StringUtils.isNotBlank(bucketName) ? bucketName : minIOConfig.getBucketName();
            try {
                ObjectStat objectStat = minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(fileName).build());
                response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
                response.setContentType(objectStat.contentType());
                response.setCharacterEncoding("UTF-8");
                InputStream inputStream = minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(fileName).build());
                IOUtils.copy(inputStream, response.getOutputStream());
            } catch (Exception e) {
            }
        }
    }

    @Override
    public String delFile(String fileName, String bucketName) {
        if (StringUtils.isNotBlank(fileName)) {
            bucketName = StringUtils.isNotBlank(bucketName) ? bucketName : minIOConfig.getBucketName();
            try {
                minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build());
                return "success";
            }catch (Exception e) {
                return "删除文件失败，请刷新后重试";
            }
        }
        return "文件不能为空";
    }
}

6. controller

package com.tk.blog.study.minIO;

import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.tk.blog.entity.FileUploadBody;
import com.tk.blog.entity.FileVo;
import com.tk.blog.service.MinIOFileService;
import com.tk.blog.vo.Result;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("minIO")
public class UploadTestController {

    private final MinIOFileService fileService;

    public UploadTestController(MinIOFileService fileService) {
        this.fileService = fileService;
    }


    @PostMapping("/upload")
    public Result uploadTest(FileUploadBody body) {
        List list;
        try {
            list = fileService.uploadFile(body);
        } catch (Exception e) {
            return Result.fail("上传失败，请刷新后重试！");
        }
        return ObjectUtils.isNull(list) ? Result.fail("上传文件不能为空") : Result.ok(list,"上传成功");
    }
}

7. 测试

成功上传到bucket中

springboot集成minIO实现文件上传下载预览

Java相关栏目本月热门文章