springboot 使用 minio的示例代码

yml 配置

# ====================== ↓↓↓↓↓↓ MinIO文件服务器 ↓↓↓↓↓↓ ======================

minio:

   url: http: //114.67.110.190:9001

   accessKey: minioadmin

   secretKey: minioadmin

   bucketName: zpf

<dependency>

            <groupId>io.minio</groupId>

            <artifactId>minio</artifactId>

            <version> 7.1 . 0 </version>

  </dependency>

package com.example.minio;

import lombok.Data;

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

import org.springframework.context.annotation.Configuration;

@Data

@Configuration

@ConfigurationProperties (prefix = "minio" )

public class MinIoProperties {

     /**

      * minio地址+端口号

      */

     private String url;

      * minio用户名

     private String accessKey;

      * minio密码

     private String secretKey;

      * 文件桶的名称

     private String bucketName;

}

package com.example.minio;

import io.minio.MinioClient;

import io.minio.ObjectStat;

import io.minio.PutObjectOptions;

import io.minio.messages.Bucket;

import lombok.SneakyThrows;

import lombok.extern.slf4j.Slf4j;

import org.apache.tomcat.util.http.fileupload.IOUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import org.springframework.web.multipart.MultipartFile;

import javax.annotation.PostConstruct;

import javax.servlet.http.HttpServletResponse;

import java.io.InputStream;

import java.net.URLEncoder;

import java.util.List;

@Slf4j

@Component

public class MinIoUtil {

     @Autowired

     MinIoProperties minIoProperties;

     private static MinioClient minioClient;

     /**

      * 初始化minio配置

      *

      * @param :

      * @return: void

      * @date : 2020/8/16 20:56

      */

     @PostConstruct

     public void init() {

         try {

             minioClient = new MinioClient(minIoProperties.getUrl(), minIoProperties.getAccessKey(),

                     minIoProperties.getSecretKey());

             createBucket(minIoProperties.getBucketName());

         } catch (Exception e) {

             e.printStackTrace();

             log.error( "初始化minio配置异常: 【{}】" , e.fillInStackTrace());

         }

     }

      * 判断 bucket是否存在

      * @param bucketName:

      *            桶名

      * @return : boolean

      * @date : 2020 / 8 / 16 20 : 53

     @SneakyThrows (Exception. class )

     public static boolean bucketExists(String bucketName) {

         return minioClient.bucketExists(bucketName);

      * 创建 bucket

     public static void createBucket(String bucketName) {

         boolean isExist = minioClient.bucketExists(bucketName);

         if (!isExist) {

             minioClient.makeBucket(bucketName);

      * 获取全部bucket

      * @return : java.util.List<io.minio.messages.Bucket>

      * @date : 2020 / 8 / 16 23 : 28

     public static List<Bucket> getAllBuckets() {

         return minioClient.listBuckets();

      * 文件上传

      * @param fileName:

      *            文件名

      * @param filePath:

      *            文件路径

     public static void upload(String bucketName, String fileName, String filePath) {

         minioClient.putObject(bucketName, fileName, filePath, null );

      * @param stream:

      *            文件流

      * @return : java.lang.String : 文件url地址

      * @date : 2020 / 8 / 16 23 : 40

     public static String upload(String bucketName, String fileName, InputStream stream) {

         minioClient.putObject(bucketName, fileName, stream, new PutObjectOptions(stream.available(), - 1 ));

         return getFileUrl(bucketName, fileName);

      * @param file:

      *            文件

     public static String upload(String bucketName, MultipartFile file) {

         final InputStream is = file.getInputStream();

         final String fileName = file.getOriginalFilename();

         minioClient.putObject(bucketName, fileName, is, new PutObjectOptions(is.available(), - 1 ));

         is.close();

      * 删除文件

     public static void deleteFile(String bucketName, String fileName) {

         minioClient.removeObject(bucketName, fileName);

      * 下载文件

      * @param response:

      * @date : 2020 / 8 / 17 0 : 34

     public static void download(String bucketName, String fileName, HttpServletResponse response) {

         // 获取对象的元数据

         final ObjectStat stat = minioClient.statObject(bucketName, fileName);

         response.setContentType(stat.contentType());

         response.setCharacterEncoding( "UTF-8" );

         response.setHeader( "Content-Disposition" , "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8" ));

         InputStream is = minioClient.getObject(bucketName, fileName);

         IOUtils.copy(is, response.getOutputStream());

      * 获取minio文件的下载地址

      * @return : java.lang.String

      * @date : 2020 / 8 / 16 22 : 07

     public static String getFileUrl(String bucketName, String fileName) {

         return minioClient.presignedGetObject(bucketName, fileName);

}