阿里p9手把手教你SpringBoot整合Minio

这篇文章主要介绍了手把手教你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的资料请关注小编

©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 199,711评论 5赞 468
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 83,932评论 2赞 376
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 146,770评论 0赞 330
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 53,799评论 1赞 271
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 62,697评论 5赞 359
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,069评论 1赞 276
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,535评论 3赞 390
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,200评论 0赞 254
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,353评论 1赞 294
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,290评论 2赞 317
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,331评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,020评论 3赞 315
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,610评论 3赞 303
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,694评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,927评论 1赞 255
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,330评论 2赞 346
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 41,904评论 2赞 341

推荐阅读更多精彩内容