手把手教你SpringBoot轻松整合Minio

更新时间：2021年01月28日 09:39:01 作者：何裕华

这篇文章主要介绍了手把手教你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 登录控制台可查看上传的文件
  }

  @Test
  @Override
  public void test() {
    System.out.println("---minio 测试---");
  }
}

总结

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

以上就是手把手教你SpringBoot轻松整合Minio的详细内容，更多关于SpringBoot整合Minio的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

邻接表无向图的Java语言实现完整源码
这篇文章主要介绍了邻接表无向图的Java语言实现完整源码，具有一定借鉴价值，需要的朋友可以参考下。
2017-12-12
SpringBoot整合Mybatis-plus案例及用法实例
mybatis-plus是一个 Mybatis 的增强工具,在 Mybatis 的基础上只做增强不做改变,为简化开发、提高效率而生,下面这篇文章主要给大家介绍了关于SpringBoot整合Mybatis-plus案例及用法实例的相关资料,需要的朋友可以参考下
2022-11-11
解决Spring在Thread中注入Bean无效的问题
这篇文章主要介绍了解决Spring在Thread中注入Bean无效的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-02-02
Java简单计算器的实现
这篇文章主要为大家详细介绍了Java简单计算器的实现，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-12-12
Java线上死锁问题从定位到解决的全链路指南
在分布式系统高并发场景下,死锁如同定时炸弹,随时可能引发服务雪崩,本文将分享一套完整的死锁应对策略,结合实战案例与生产级解决方案,助你快速化解危机,需要的朋友可以参考下
2025-06-06
Java使用CompletableFuture实现异步编程
在现代 Java 开发中,异步编程是一项重要技能,而 CompletableFuture 是从 Java 8 开始提供的一个功能强大的工具,用于简化异步任务的编写和组合,本文将详细介绍 CompletableFuture 的基本使用和一些常见的应用场景,需要的朋友可以参考下
2025-01-01
通过Session案例分析一次性验证码登录
这篇文章主要介绍了通过Session案例分析一次性验证码登录,非常不错，具有参考借鉴价值，需要的朋友可以参考下
2017-03-03
MyBatis如何调用存储过程与存储函数
这篇文章主要介绍了MyBatis如何调用存储过程与存储函数，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-11-11
Java实现的自定义类加载器示例
这篇文章主要介绍了Java实现的自定义类加载器,结合具体实例形式分析了java自定义类加载器的原理与具体实现技巧,需要的朋友可以参考下
2019-07-07
Java深入讲解static操作符
static关键字基本概念我们可以一句话来概括:方便在没有创建对象的情况下来进行调用。也就是说:被static关键字修饰的不需要创建对象去调用,直接根据类名就可以去访问，让我们来了解一下你可能还不知道情况
2022-07-07