Java SpringBoot

一、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：为用户密钥

以上搭建的都是单机版的。想要了解分布式 的方式请查看官网文档。
当启动后在浏览器访问http://localhost:9000就可以访问minio的图形化界面了。

三、下面开始搭建SpringBoot环境

初始化一个SpringBoot项目大家都会，这里不多做介绍。

需要引入的依赖

  1. <!-- thymeleaf模板渲染引擎-->
  2. <dependency>
  3.   <groupId>org.springframework.boot</groupId>
  4.   <artifactId>spring-boot-starter-thymeleaf</artifactId>
  5. </dependency>
  6. <!-- 操作minio的java客户端-->
  7. <dependency>
  8.   <groupId>io.minio</groupId>
  9.   <artifactId>minio</artifactId>
  10.   <version>8.2.1</version>
  11. </dependency>
  12. <!-- lombok插件-->
  13. <dependency>
  14.   <groupId>org.projectlombok</groupId>
  15.   <artifactId>lombok</artifactId>
  16.   <optional>true</optional>
  17. </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.     }
  81.     /**
  82.      * @description: 上传文件
  83.      * @dateTime: 2021/5/13 14:17
  84.      */
  85.     public void upload(MultipartFile file, String fileName) {
  86.         // 使用putObject上传一个文件到存储桶中。
  87.         try {
  88.             InputStream inputStream = file.getInputStream();
  89.             minioClient.putObject(PutObjectArgs.builder()
  90.                     .bucket(configuration.getBucketName())
  91.                     .object(fileName)
  92.                     .stream(inputStream, file.getSize(), -1)
  93.                     .contentType(file.getContentType())
  94.                     .build());
  95.         } catch (ErrorResponseException e) {
  96.             e.printStackTrace();
  97.         } catch (InsufficientDataException e) {
  98.             e.printStackTrace();
  99.         } catch (InternalException e) {
  100.             e.printStackTrace();
  101.         } catch (InvalidKeyException e) {
  102.             e.printStackTrace();
  103.         } catch (InvalidResponseException e) {
  104.             e.printStackTrace();
  105.         } catch (IOException e) {
  106.             e.printStackTrace();
  107.         } catch (NoSuchAlgorithmException e) {
  108.             e.printStackTrace();
  109.         } catch (ServerException e) {
  110.             e.printStackTrace();
  111.         } catch (XmlParserException e) {
  112.             e.printStackTrace();
  113.         }
  114.     }
  115.   /**
  116.      * @description: 根据filename获取文件访问地址
  117.      * @dateTime: 2021/5/17 11:28
  118.      */
  119.     public String getUrl(String objectName, int time, TimeUnit timeUnit) {
  120.         String url = null;
  121.         try {
  122.             url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
  123.                     .method(Method.GET)
  124.                     .bucket(configuration.getBucketName())
  125.                     .object(objectName)
  126.                     .expiry(time, timeUnit).build());
  127.         } catch (ErrorResponseException e) {
  128.             e.printStackTrace();
  129.         } catch (InsufficientDataException e) {
  130.             e.printStackTrace();
  131.         } catch (InternalException e) {
  132.             e.printStackTrace();
  133.         } catch (InvalidKeyException e) {
  134.             e.printStackTrace();
  135.         } catch (InvalidResponseException e) {
  136.             e.printStackTrace();
  137.         } catch (IOException e) {
  138.             e.printStackTrace();
  139.         } catch (NoSuchAlgorithmException e) {
  140.             e.printStackTrace();
  141.         } catch (XmlParserException e) {
  142.             e.printStackTrace();
  143.         } catch (ServerException e) {
  144.             e.printStackTrace();
  145.         }
  146.         return url;
  147.     }
  148. }

简单说明：

  • 使用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.   <!-- import CSS -->
    6.   <link rel="stylesheet" href="https://unpkg.com/element-ui/lib/theme-chalk/index.css">
    7.   <script src="https://cdn.jsdelivr.net/npm/vue@2/dist/vue.js"></script>
    8.   <title>上传图片</title>
    9. </head>
    10. <body>
    11. <div id="app">
    13.   <el-row :gutter="2">
    14.       <el-col :span="8">
    15.           <div class="div-center-class">
    16.               <div class="">
    17.                   <center><h3>传统上传</h3></center>
    18.                   <el-upload
    19.                           class="upload-demo"
    20.                           action="#"
    21.                           drag
    22.                           :http-request="uploadHandle">
    23.                       <i class="el-icon-upload"></i>
    24.                       <div class="el-upload__text">将文件拖到此处，或<em>点击上传</em></div>
    25.                       <div class="el-upload__tip" slot="tip">只能上传jpg/png文件，且不超过500kb</div>
    26.                   </el-upload>
    27.                   <div v-if="imgUrl">
    28.                       <img :src="imgUrl" style="width: 40px;height: 40px"></img>
    29.                   </div>
    30.               </div>
    31.           </div>
    32.       </el-col>
    33.       <el-col :span="8">
    34.           <div class="div-center-class">
    35.               <div class="">
    36.                   <center><h3>前端formData直传</h3></center>
    37.                   <el-upload
    38.                           class="upload-demo"
    39.                           action="#"
    40.                           drag
    41.                           :http-request="httpRequestHandle">
    42.                       <i class="el-icon-upload"></i>
    43.                       <div class="el-upload__text">将文件拖到此处，或<em>点击上传</em></div>
    44.                       <div class="el-upload__tip" slot="tip">只能上传jpg/png文件，且不超过500kb</div>
    45.                   </el-upload>
    46.                   <div v-if="directUrl">
    47.                       <img :src="directUrl" style="width: 40px;height: 40px"></img>
    48.                   </div>
    49.               </div>
    50.           </div>
    51.       </el-col>
    52.       <el-col :span="8">
    53.           <div class="div-center-class">
    54.               <div class="">
    55.                   <center><h3>前端Url直传</h3></center>
    56.                   <el-upload
    57.                           class="upload-demo"
    58.                           action="#"
    59.                           drag
    60.                           :http-request="UrlUploadHandle">
    61.                       <i class="el-icon-upload"></i>
    62.                       <div class="el-upload__text">将文件拖到此处，或<em>点击上传</em></div>
    63.                       <div class="el-upload__tip" slot="tip">只能上传jpg/png文件，且不超过500kb</div>
    64.                   </el-upload>
    65.                   <div v-if="uploadUrl">
    66.                       <img :src="uploadUrl" style="width: 40px;height: 40px"></img>
    67.                   </div>
    68.               </div>
    69.           </div>
    70.       </el-col>
    71.   </el-row>
    72. </div>
    73. </body>
    74. <!-- import Vue before Element -->
    75. <script src="https://unpkg.com/vue/dist/vue.js"></script>
    76. <!-- import JavaScript -->
    77. <script src="https://unpkg.com/element-ui/lib/index.js"></script>
    78. <!--import  axios -->
    79. <script src="https://unpkg.com/axios/dist/axios.min.js"></script>
    80. <script>
    81.   new Vue({
    82.       el: '#app',
    83.       data: function () {
    84.           return {
    85.               imgUrl: '',
    86.               directUrl: '',
    87.               uploadUrl: ''
    88.           }
    89.       },
    90.       methods: {
    92.           uploadHandle(options) {
    93.               let {file} = options;
    94.               this.traditionPost(file);
    95.           },
    96.           traditionPost(file) {
    97.               _that = this
    98.               const form = new FormData();
    99.               form.append("fileName", file.name);
    100.               form.append("file", file);
    101.               this.axiosPost("post", "/upload", form).then(function (res) {
    102.                   if (res.status === 200) {
    103.                       _that.imgUrl = res.data.data
    104.                   } else {
    105.                       alert("上传失败！")
    106.                   }
    107.               })
    108.           },
    109.           getpolicy(file) {
    110.               _that = this
    111.               axios.get('policy?fileName=' + file.name)
    112.                   .then(function (response) {
    113.                       let {xamzalgorithm, xamzcredential, policy, xamzsignature, xamzdate, host} = response.data.data;
    114.                       let formData = new FormData();
    115.                       formData.append("key", file.name);
    116.                       formData.append("x-amz-algorithm", xamzalgorithm);  // 让服务端返回200，不设置则默认返回204。
    117.                       formData.append("x-amz-credential", xamzcredential);
    118.                       formData.append("policy", policy);
    119.                       formData.append("x-amz-signature", xamzsignature);
    120.                       formData.append("x-amz-date", xamzdate);
    121.                       formData.append("file", file);
    122.                       // 发送 POST 请求
    123.                       _that.axiosPost("post", host, formData).then(function (res) {
    124.                           if (res.status === 204) {
    125.                               axios.get('url?fileName=' + file.name).then(function (res) {
    126.                                   _that.directUrl = res.data.data;
    127.                               })
    128.                           } else {
    129.                               alert("上传失败！")
    130.                           }
    131.                       })
    132.                   })
    133.           },
    134.           httpRequestHandle(options) {
    135.               let {file} = options;
    136.               this.getpolicy(file);
    137.           },
    139.           UrlUploadHandle(options) {
    140.               let {file} = options;
    141.               this.getUploadUrl(file);
    142.           },
    143.           getUploadUrl(file) {
    144.               _that = this
    145.               console.log(file)
    146.               axios.get('uploadUrl?fileName=' + file.name)
    147.                   .then(function (response) {
    148.                       let url = response.data.data;
    149.                       // 发送 put 请求
    150.                       let config = {'Content-Type': file.type}
    151.                       _that.axiosPost("put", url, file, config).then(function (res) {
    152.                           if (res.status === 200) {
    153.                               axios.get('url?fileName=' + file.name).then(function (res) {
    154.                                   _that.uploadUrl = res.data.data;
    155.                               })
    156.                           } else {
    157.                               alert("上传失败！")
    158.                           }
    159.                       })
    160.                   })
    161.           },
    162.           //封装
    163.           //axios封装post请求
    164.           axiosPost(method, url, data, config) {
    165.               let result = axios({
    166.                   method: method,
    167.                   url: url,
    168.                   data: data,
    169.                   headers: config
    170.               }).then(resp => {
    171.                   return resp
    172.               }).catch(error => {
    173.                   return "exception=" + error;
    174.               });
    175.               return result;
    176.           }
    178.       }
    179.   })
    180. </script>
    181. <style>
    182.   .div-center-class {
    183.       padding: 28% 0%;
    184.       text-align: center;
    185.       background: beige;
    186.   }
    187. </style>
    188. </html>

    image.png
    可以分别体验不同的实现效果。
    以上就是使用SpringBoot搭建基于minio的高性能存储服务的全部步骤了。