腾讯大佬手把手教你SpringBoot轻松整合Minio

清疚 2022-11-14 14:57 337阅读 0赞

**这篇文章主要介绍了手把手教你SpringBoot轻松整合Minio的方法，帮助大家更好的理解和使用springboot框架，感兴趣的朋友可以了解下**

**使用Spring Boot 可以非常方便、快速搭建项目,使我们不用关心框架之间的兼容性,适用版本等各种问题,我们想使用任何东西,仅仅添加一个配置就可以。**

**提示：以下是本篇文章正文内容，下面案例可供参考**  
**一、技术介绍**  
**1.Minio是什么？**  
**MinIO 是一个基于Apache License v2.0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口，非常适合于存储大容量非结构化的数据，例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等，而一个对象文件可以是任意大小，从几kb到最大5T不等**。

**二、使用步骤**  
**1.引入maven库**  
**代码如下（示例）：**

<parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>2.4.1</version>
          <relativePath/>
        </parent>
      <dependencies>
      <dependency>
        <groupId>io.minio</groupId>
        <artifactId>minio</artifactId>
        <version>8.0.3</version>
      </dependency>
    </dependencies>

**2.封装Minio**  
**IFile类：**

package com.hyh.minio;
     
    /**
     * File接口类
     *
     * @Author: heyuhua
     * @Date: 2021/1/12 10:33
     */
    public interface IFile {
        
     
      /**
       * 上传
       *
       * @param filename 文件名
       */
      void upload(String filename);
     
      /**
       * 上传
       *
       * @param filename 文件名
       * @param object  保存对象文件名称
       */
      void upload(String filename, String object);
    }

**File接口类：**

package com.hyh.minio.service;
     
    import com.hyh.minio.IFile;
     
    /**
     * File接口
     *
     * @Author: heyuhua
     * @Date: 2021/1/12 10:53
     */
    public interface FileService extends IFile {
        
     
      /**
       * 上传
       *
       * @param filename 文件名称
       * @param object  保存对象文件名称
       * @param bucket  存储桶
       */
      void upload(String filename, String object, String bucket);
    }

**File接口实现类：**

package com.hyh.minio.service.impl;
     
    import com.hyh.minio.service.FileService;
    import com.hyh.utils.common.StringUtils;
    import io.minio.BucketExistsArgs;
    import io.minio.MakeBucketArgs;
    import io.minio.MinioClient;
    import io.minio.UploadObjectArgs;
    import io.minio.errors.MinioException;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Service;
     
    import java.io.IOException;
    import java.security.InvalidKeyException;
    import java.security.NoSuchAlgorithmException;
     
    /**
     * 文件接口服务实现
     *
     * @Author: heyuhua
     * @Date: 2021/1/12 10:53
     */
    @Service
    public class FileServiceImpl implements FileService {
        
     
      /**
       * 日志
       */
      private static final Logger LOG = LoggerFactory.getLogger(FileServiceImpl.class);
     
      /**
       * minio 客户端
       */
      @Autowired
      private MinioClient minioClient;
     
      /**
       * 默认存储桶名称
       */
      @Value("${minio.bucketName:}")
      private String defaultBucketName;
     
     
      @Override
      public void upload(String filename) {
        
        uploadObject(filename, null, defaultBucketName);
      }
     
      @Override
      public void upload(String filename, String object) {
        
        uploadObject(filename, object, defaultBucketName);
      }
     
     
      @Override
      public void upload(String filename, String object, String bucket) {
        
        uploadObject(filename, object, bucket);
      }
     
      /**
       * 上传
       *
       * @param filename
       * @param object
       * @param bucket
       */
      private void uploadObject(String filename, String object, String bucket) {
        
        if (StringUtils.isAnyBlank(filename, bucket))
          return;
        try {
        
          //存储桶构建
          bucketBuild(bucket);
          //保存的文件名称
          object = StringUtils.isBlank(object) ? filename.substring(filename.lastIndexOf("/") > 0 ? filename.lastIndexOf("/") : filename.lastIndexOf("\\")) : object;
     
          minioClient.uploadObject(
              UploadObjectArgs.builder()
                  .bucket(bucket)
                  .object(object)
                  .filename(filename)
                  .build());
        } catch (MinioException | InvalidKeyException | IOException | NoSuchAlgorithmException exception) {
        
          LOG.error("uploadObject error", exception);
        }
      }
     
     
      /**
       * 存储桶构建
       *
       * @param bucketName
       */
      private void bucketBuild(String bucketName) {
        
        try {
        
          boolean found =
              minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
          if (!found) {
        
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
            LOG.info("Bucket " + bucketName + " make success.");
          } else {
        
            LOG.info("Bucket " + bucketName + " already exists.");
          }
        } catch (MinioException | InvalidKeyException | IOException | NoSuchAlgorithmException exception) {
        
          LOG.error("bucketBuild error", exception);
        }
      }
     
      public String getDefaultBucketName() {
        
        return defaultBucketName;
      }
     
      public void setDefaultBucketName(String defaultBucketName) {
        
        this.defaultBucketName = defaultBucketName;
      }
    }

**Minio配置类：**

package com.hyh.minio.config;
     
    import io.minio.MinioClient;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
     
    /**
     * @Author: heyuhua
     * @Date: 2021/1/12 10:42
     */
    @Configuration
    @ConfigurationProperties(prefix = "minio")
    public class MinioConfig {
        
     
      /**
       * endPoint是一个URL，域名，IPv4或者IPv6地址
       */
      private String endpoint;
     
      /**
       * 端口
       */
      private int port;
     
      /**
       * accessKey类似于用户ID，用于唯一标识你的账户
       */
      private String accessKey;
     
      /**
       * secretKey是你账户的密码
       */
      private String secretKey;
     
      /**
       * 如果是true，则用的是https而不是http,默认值是true
       */
      private Boolean secure;
     
      /**
       * 默认存储桶
       */
      private String bucketName;
     
      /**
       * 配置目录
       */
      private String configDir;
     
      @Bean
      public MinioClient getMinClient() {
        
        return MinioClient.builder()
            .endpoint(endpoint, port, secure)//http
            .credentials(accessKey, secretKey)
            .build();
      }
     
     
      public String getEndpoint() {
        
        return endpoint;
      }
     
      public void setEndpoint(String endpoint) {
        
        this.endpoint = endpoint;
      }
     
      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 Boolean getSecure() {
        
        return secure;
      }
     
      public void setSecure(Boolean secure) {
        
        this.secure = secure;
      }
     
      public String getBucketName() {
        
        return bucketName;
      }
     
      public void setBucketName(String bucketName) {
        
        this.bucketName = bucketName;
      }
     
      public String getConfigDir() {
        
        return configDir;
      }
     
      public void setConfigDir(String configDir) {
        
        this.configDir = configDir;
      }
     
      public int getPort() {
        
        return port;
      }
     
      public void setPort(int port) {
        
        this.port = port;
      }
    }
    Minio助手类封装：
    
    package com.hyh.minio.helper;
     
    import com.hyh.minio.service.FileService;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import org.springframework.util.Assert;
     
    /**
     * Minio助手
     *
     * @Author: heyuhua
     * @Date: 2021/1/12 10:54
     */
    @Component
    public class MinioHelper {
        
     
      /**
       * 日志
       */
      private static final Logger LOG = LoggerFactory.getLogger(MinioHelper.class);
     
      /**
       * 文件接口服务
       */
      @Autowired
      private FileService fileService;
     
     
      /**
       * 上传
       *
       * @param filename
       */
      public void upload(String filename) {
        
        Assert.notNull(filename, "filename is null.");
        fileService.upload(filename);
      }
     
      /**
       * 上传
       *
       * @param filename
       * @param object
       */
      public void upload(String filename, String object) {
        
        Assert.notNull(filename, "filename is null.");
        Assert.notNull(object, "object is null.");
        fileService.upload(filename, object);
      }
     
      /**
       * 上传
       *
       * @param filename
       * @param object
       * @param bucket
       */
      public void upload(String filename, String object, String bucket) {
        
        Assert.notNull(filename, "filename is null.");
        Assert.notNull(object, "object is null.");
        Assert.notNull(bucket, "bucket is null.");
        fileService.upload(filename, object, bucket);
      }
     
     
    }

**3.配置文件**  
**代码如下（示例）：**

server:
     port: 8088
    #minio配置
    minio:
     endpoint: 39.108.49.252
     port: 9000
     accessKey: admin
     secretKey: admin123
     secure: false
     bucketName: "hyh-bucket"
     configDir: "/home/data/"

**4.单元测试**  
**测试代码如下（示例）：**

`package` `com.hyh.core.test;`
    
    `import` `com.hyh.core.test.base.HyhTest;`
    
    `import` `com.hyh.minio.helper.MinioHelper;`
    
    `import` `org.junit.Test;`
    
    `import` `org.springframework.beans.factory.annotation.Autowired;`
    
    `/**`
    
    `* Minio Test`
    
    `*`
    
    `* @Author: heyuhua`
    
    `* @Date: 2021/1/12 11:54`
    
    `*/`
    
    `public` `class` `MinioTest` `extends` `HyhTest {
        `
    
    `@Autowired`
    
    `private` `MinioHelper minioHelper;`
    
    `@Test`
    
    `public` `void` `testUpload() {
        `
    
    `//直接指向你本地的路径测试`
    
    `String filename =` `"E:\\home\\static\\img\\fsPic\\0c34de99ac6b4c56812e83c4eab13a6f.jpg"``;`
    
    `String object =` `"hyh-test-name.jpg"``;`
    
    `String bucket =` `"hyh-test-bucket"``;`
    
    `minioHelper.upload(filename);`
    
    `minioHelper.upload(filename, object);`
    
    `minioHelper.upload(filename, object, bucket);`
    
    `//上传完后打开浏览器访问 [http://ip:9000](http://ip:9000/) 登录控制台可查看上传的文件`
    
    `}`
    
    `@Test`
    
    `@Override`
    
    `public` `void` `test() {
        `
    
    `System.out.println(``"---minio 测试---"``);`
    
    `}`
    
    `}`

**总结**  
**是不是感觉很简单？关注我带你揭秘更多Minio高级用法 源码地址：点此查看源码.**

**以上就是手把手教你SpringBoot轻松整合Minio的详细内容，更多关于SpringBoot整合Minio的资料请关注小编**