ToB企服应用市场:ToB评测及商务社交产业平台

标题: Spring Boot + minio 实现高性能存储服务，So Easy~！ [打印本页]

---

作者: 西河刘卡车医    时间: 2023-9-18 19:51
标题: Spring Boot + minio 实现高性能存储服务，So Easy~！
什么是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开发手册（嵩山版）》最新发布，速速下载！
觉得不错，别忘了随手点赞+转发哦！

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

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4