Spring Boot + minio 实现高性能存储服务，So Easy~！

西河刘卡车医  金牌会员 | 2023-9-18 19:51:24 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 938|帖子 938|积分 2814

什么是minio

引用官网：
MinIO是根据GNU Affero通用公共许可证v3.0发布的高性能对象存储。它与Amazon S3云存储服务兼容。使用MinIO构建用于机器学习，分析和应用程序数据工作负载的高性能基础架构。
官网地址：
https://min.io/
文档地址：
https://docs.min.io/
一. 使用docker 搭建minio 服务。

GNU / Linux和macOS
  1. docker run -p 9000:9000 \
  2.   --name minio1 \
  3.   -v /mnt/data:/data \
  4.   -e "MINIO_ROOT_USER=AKIAIOSFODNN7EXAMPLE" \
  5.   -e "MINIO_ROOT_PASSWORD=wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY" \
  6.   minio/minio server /data
复制代码
windows
  1. docker run -p 9000:9000 \
  2.   --name minio1 \
  3.   -v D:\data:/data \
  4.   -e "MINIO_ROOT_USER=AKIAIOSFODNN7EXAMPLE" \
  5.   -e "MINIO_ROOT_PASSWORD=wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY" \
  6.   minio/minio server /data
复制代码

  • MINIO_ROOT_USER：为用户key
  • MINIO_ROOT_PASSWORD：为用户密钥
以上搭建的都是单机版的。想要了解分布式 的方式请查看官网文档。

这就是在win的docker上运行的。
当启动后在浏览器访问http://localhost:9000就可以访问minio的图形化界面了，如图所示：


二. 下面开始搭建springboot 环境

初始化一个springboot项目大家都会，这里不多做介绍。
推荐一个 Spring Boot 基础教程及实战示例：https://github.com/javastacks/spring-boot-best-practice
主要是介绍需要引入的依赖：
  1.   <dependency>
  2.             <groupId>org.springframework.boot</groupId>
  3.             <artifactId>spring-boot-starter-thymeleaf</artifactId>
  4.         </dependency>
  6.          <dependency>
  7.             <groupId>io.minio</groupId>
  8.             <artifactId>minio</artifactId>
  9.             <version>8.2.1</version>
  10.         </dependency>
  12.          <dependency>
  13.             <groupId>org.projectlombok</groupId>
  14.             <artifactId>lombok</artifactId>
  15.             <optional>true</optional>
  16.         </dependency>
复制代码
依赖可以官方文档里找：https://docs.min.io/docs/java-client-quickstart-guide.html
下面介绍配置文件：
  1. spring:
  2.   servlet:
  3.     multipart:
  4.       max-file-size: 10MB
  5.       max-request-size: 10MB
  6. #minio配置
  7.   minio:
  8.     access-key: AKIAIOSFODNN7EXAMPLE      #key就是docker初始化是设置的，密钥相同
  9.     secret-key: wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY
  10.     url: http://localhost:9000
  11.     bucket-name: wdhcr
  12.   thymeleaf:
  13.     cache: false
复制代码
创建minio的配置类:
  1. @Configuration
  2. @ConfigurationProperties(prefix = "spring.minio")
  3. @Data
  4. public class MinioConfiguration {
  5.     private String accessKey;
  7.     private String secretKey;
  9.     private String url;
  11.     private String bucketName;
  13.     @Bean
  14.     public MinioClient minioClient() {
  15.         return MinioClient.builder()
  16.                 .endpoint(url)
  17.                 .credentials(accessKey, secretKey)
  18.                 .build();
  19.     }
  20. }
复制代码
使用配置属性绑定进行参数绑定,并初始化一个minio client对象放入容器中。
下面就是我封装的minio client 操作minio的简单方法的组件。
  1. @Component
  2. public class MinioComp {
  4.     @Autowired
  5.     private MinioClient minioClient;
  7.     @Autowired
  8.     private MinioConfiguration configuration;
  10.     /**
  11.      * @description: 获取上传临时签名
  12.      * @dateTime: 2021/5/13 14:12
  13.      */
  14.     public Map getPolicy(String fileName, ZonedDateTime time) {
  15.         PostPolicy postPolicy = new PostPolicy(configuration.getBucketName(), time);
  16.         postPolicy.addEqualsCondition("key", fileName);
  17.         try {
  18.             Map<String, String> map = minioClient.getPresignedPostFormData(postPolicy);
  19.             HashMap<String, String> map1 = new HashMap<>();
  20.             map.forEach((k,v)->{
  21.                map1.put(k.replaceAll("-",""),v);
  22.            });
  23.             map1.put("host",configuration.getUrl()+"/"+configuration.getBucketName());
  24.             return map1;
  25.         } catch (ErrorResponseException e) {
  26.             e.printStackTrace();
  27.         } catch (InsufficientDataException e) {
  28.             e.printStackTrace();
  29.         } catch (InternalException e) {
  30.             e.printStackTrace();
  31.         } catch (InvalidKeyException e) {
  32.             e.printStackTrace();
  33.         } catch (InvalidResponseException e) {
  34.             e.printStackTrace();
  35.         } catch (IOException e) {
  36.             e.printStackTrace();
  37.         } catch (NoSuchAlgorithmException e) {
  38.             e.printStackTrace();
  39.         } catch (ServerException e) {
  40.             e.printStackTrace();
  41.         } catch (XmlParserException e) {
  42.             e.printStackTrace();
  43.         }
  44.         return null;
  45.     }
  47.     /**
  48.      * @description: 获取上传文件的url
  49.      * @dateTime: 2021/5/13 14:15
  50.      */
  51.     public String getPolicyUrl(String objectName, Method method, int time, TimeUnit timeUnit) {
  52.         try {
  53.             return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
  54.                     .method(method)
  55.                     .bucket(configuration.getBucketName())
  56.                     .object(objectName)
  57.                     .expiry(time, timeUnit).build());
  58.         } catch (ErrorResponseException e) {
  59.             e.printStackTrace();
  60.         } catch (InsufficientDataException e) {
  61.             e.printStackTrace();
  62.         } catch (InternalException e) {
  63.             e.printStackTrace();
  64.         } catch (InvalidKeyException e) {
  65.             e.printStackTrace();
  66.         } catch (InvalidResponseException e) {
  67.             e.printStackTrace();
  68.         } catch (IOException e) {
  69.             e.printStackTrace();
  70.         } catch (NoSuchAlgorithmException e) {
  71.             e.printStackTrace();
  72.         } catch (XmlParserException e) {
  73.             e.printStackTrace();
  74.         } catch (ServerException e) {
  75.             e.printStackTrace();
  76.         }
  77.         return null;
  78.     }
  80.     /**
  81.      * @description: 上传文件
  82.      * @dateTime: 2021/5/13 14:17
  83.      */
  84.     public void upload(MultipartFile file, String fileName) {
  85.         // 使用putObject上传一个文件到存储桶中。
  86.         try {
  87.             InputStream inputStream = file.getInputStream();
  88.             minioClient.putObject(PutObjectArgs.builder()
  89.                     .bucket(configuration.getBucketName())
  90.                     .object(fileName)
  91.                     .stream(inputStream, file.getSize(), -1)
  92.                     .contentType(file.getContentType())
  93.                     .build());
  94.         } catch (ErrorResponseException e) {
  95.             e.printStackTrace();
  96.         } catch (InsufficientDataException e) {
  97.             e.printStackTrace();
  98.         } catch (InternalException e) {
  99.             e.printStackTrace();
  100.         } catch (InvalidKeyException e) {
  101.             e.printStackTrace();
  102.         } catch (InvalidResponseException e) {
  103.             e.printStackTrace();
  104.         } catch (IOException e) {
  105.             e.printStackTrace();
  106.         } catch (NoSuchAlgorithmException e) {
  107.             e.printStackTrace();
  108.         } catch (ServerException e) {
  109.             e.printStackTrace();
  110.         } catch (XmlParserException e) {
  111.             e.printStackTrace();
  112.         }
  113.     }
  114.   /**
  115.      * @description: 根据filename获取文件访问地址
  116.      * @dateTime: 2021/5/17 11:28
  117.      */
  118.     public String getUrl(String objectName, int time, TimeUnit timeUnit) {
  119.         String url = null;
  120.         try {
  121.             url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
  122.                     .method(Method.GET)
  123.                     .bucket(configuration.getBucketName())
  124.                     .object(objectName)
  125.                     .expiry(time, timeUnit).build());
  126.         } catch (ErrorResponseException e) {
  127.             e.printStackTrace();
  128.         } catch (InsufficientDataException e) {
  129.             e.printStackTrace();
  130.         } catch (InternalException e) {
  131.             e.printStackTrace();
  132.         } catch (InvalidKeyException e) {
  133.             e.printStackTrace();
  134.         } catch (InvalidResponseException e) {
  135.             e.printStackTrace();
  136.         } catch (IOException e) {
  137.             e.printStackTrace();
  138.         } catch (NoSuchAlgorithmException e) {
  139.             e.printStackTrace();
  140.         } catch (XmlParserException e) {
  141.             e.printStackTrace();
  142.         } catch (ServerException e) {
  143.             e.printStackTrace();
  144.         }
  145.         return url;
  146.     }
  147. }
复制代码
简单说明：

  • 使用MultipartFile接收前端文件流，再上传到minio。
  • 构建一个formData的签名数据，给前端，让前端之前上传到minio。
  • 构建一个可以上传的临时URL给前端，前端通过携带文件请求该URL进行上传。
  • 使用filename请求服务端获取临时访问文件的URL。（最长时间为7 天，想要永久性访问，需要其他设置，这里不做说明。）
下面展示页面html，使用的是VUE+element-ui进行渲染。
  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4.     <meta charset="UTF-8">
  5.    
  6.     <link rel="stylesheet" href="https://unpkg.com/element-ui/lib/theme-chalk/index.css">
  7.     <title>上传图片</title>
  8. </head>
  9. <body>
  12.     <el-row :gutter="2">
  13.         <el-col :span="8">
  14.             
  15.                
  16.                     <center><h3>传统上传</h3></center>
  17.                     <el-upload
  18.                            
  19.                             action="#"
  20.                             drag
  21.                             :http-request="uploadHandle">
  22.                         <i ></i>
  23.                         将文件拖到此处，或<em>点击上传</em>
  24.                         只能上传jpg/png文件，且不超过500kb
  25.                     </el-upload>
  26.                     
  27.                         <img :src="imgUrl" ></img>
  28.                     
  29.                
  30.             
  31.         </el-col>
  32.         <el-col :span="8">
  33.             
  34.                
  35.                     <center><h3>前端formData直传</h3></center>
  36.                     <el-upload
  37.                            
  38.                             action="#"
  39.                             drag
  40.                             :http-request="httpRequestHandle">
  41.                         <i ></i>
  42.                         将文件拖到此处，或<em>点击上传</em>
  43.                         只能上传jpg/png文件，且不超过500kb
  44.                     </el-upload>
  45.                     
  46.                         <img :src="directUrl" ></img>
  47.                     
  48.                
  49.             
  50.         </el-col>
  51.         <el-col :span="8">
  52.             
  53.                
  54.                     <center><h3>前端Url直传</h3></center>
  55.                     <el-upload
  56.                            
  57.                             action="#"
  58.                             drag
  59.                             :http-request="UrlUploadHandle">
  60.                         <i ></i>
  61.                         将文件拖到此处，或<em>点击上传</em>
  62.                         只能上传jpg/png文件，且不超过500kb
  63.                     </el-upload>
  64.                     
  65.                         <img :src="uploadUrl" ></img>
  66.                     
  67.                
  68.             
  69.         </el-col>
  70.     </el-row>
  72. </body>
  81. </html>
复制代码
页面效果


可以分别体验不同的实现效果。
以上就是使用springboot搭建基于minio的高性能存储服务的全部步骤了。
项目地址：https://gitee.com/jack_whh/minio-upload
原文链接：https://blog.csdn.net/weixin_45089791/article/details/116921075
版权声明：本文为CSDN博主「HUWD」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
近期热文推荐：
1.1,000+ 道 Java面试题及答案整理(2022最新版)
2.劲爆！Java 协程要来了。。。
3.Spring Boot 2.x 教程，太全了！
4.别再写满屏的爆爆爆炸类了，试试装饰器模式，这才是优雅的方式！！
5.《Java开发手册（嵩山版）》最新发布，速速下载！
觉得不错，别忘了随手点赞+转发哦！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

西河刘卡车医

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表