Docker 搭建 Minio 容器 (完备详细版)

Docker 搭建 Minio 容器 (完备详细版)

简介：

   Minio 是一个基于Apache License v2.0开源协议的对象存储服务，固然轻量，却拥有着不错的性能。它兼容亚马逊S3云存储服务接口，非常适合于存储大容量非布局化的数据。
  例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等，而一个对象文件可以是任意巨细，从几 kb 到最大 5T 不等。
  最重要的是免费
  阐明：

   Docker如果想安装软件 , 必须先到Docker镜像堆栈下载镜像。
  Docker官方镜像
1、探求Minio镜像

2、下载Minio镜像

1. # 下载镜像
2. docker pull minio/minio
4. #查看镜像
5. docker images

复制代码

下令形貌docker pull minio/minio下载最新版Minio镜像 (其实此下令就等同于 : docker pull minio/minio:latest )docker pull minio/minio:RELEASE.2023-11-20T22-40-07Z.fips下载指定版本的Minio镜像 (xxx指详细版本号)

3、创建目录

   一个用来存放配置，一个用来存储上传文件的目录
  启动前需要先创建Minio外部挂载的配置文件（ /opt/minio/config）,和存储上传文件的目录（ /opt/minio/data）

1. mkdir -p /opt/minio/config
3. mkdir -p /opt/minio/data

复制代码

4、创建Minio容器并运行

1. docker run \
2. -p 19000:9000 \
3. -p 9090:9090 \
4. --net=host \
5. --name minio \
6. -d --restart=always \
7. -e "MINIO_ACCESS_KEY=minioadmin" \
8. -e "MINIO_SECRET_KEY=minioadmin" \
9. -v /opt/minio/data:/data \
10. -v /opt/minio/config:/root/.minio \
11. minio/minio server \
12. /data --console-address ":9090" -address ":19000"

复制代码

下令形貌-p 9000:9000 -p 9090:9090这是端口映射，前一个是服务器的端口，后一个是客户端也就是api接口访问的端口地点–name minio这是给新创建的容器命名的选项，名字是 “minio”–net=host这是网络设置，表示容器将使用主机的网络栈，如许就不需要在容器内部配置网络-d --restart=always这是运行容器的其他选项，-d使容器在背景运行，–restart=always表示容器总是会在退出后自动重启-e “MINIO_ACCESS_KEY=minioadmin”用户名-e “MINIO_SECRET_KEY=minioadmin”密码-v /opt/minio/data:/data这意味着将宿主机上的 /opt/minio/data 目录挂载到容器内的 /data 目录-v /opt/minio/config:/root/.minio将宿主机上的 /opt/minio/config 目录挂载到容器内的 /root/.minio 目录minio/minio server /data --console-address “:9090” -address “:9000”这是容器内要运行的下令，启动一个名为 “minio” 的服务器，数据存储在 /data 目录下，服务器的控制台地点为 “:9090”，服务地点为 “:9000”\换行 4.1、访问操作

访问：http://47.117.160.102:9090/login 用户名：密码 minioadmin：minioadmin

4.2、创建用户

4.3、创建组

4.4、创建Buckets

4.5、创建Access Keys

4.6、文件上传

4.6、浏览器访问上传文件

4.6.1、输入ip:19000/Buckets名/文件名，如果不行，看看端口是否开放

5、Springboot简朴使用

5.1、添加MinIO依赖Pom

1. <dependencies>
2.         
3.         <dependency>
4.             <groupId>org.springframework.boot</groupId>
5.             <artifactId>spring-boot-starter-web</artifactId>
6.         </dependency>
8.         <!-- MinIO 客户端 -->
9.         <dependency>
10.             <groupId>io.minio</groupId>
11.             <artifactId>minio</artifactId>
12.             <version>8.5.7</version>
13.         </dependency>
14.    
15.         <dependency>
16.             <groupId>org.projectlombok</groupId>
17.             <artifactId>lombok</artifactId>
18.         </dependency>
20.         <dependency>
21.             <groupId>org.apache.commons</groupId>
22.             <artifactId>commons-lang3</artifactId>
23.             <version>3.11</version>
24.         </dependency>
25.    
26. </dependencies>

复制代码

5.2、配置MinIO的yaml

1. server:
2.   port: 3333
4. spring:
5.   servlet:
6.     multipart:
7.       max-request-size: 200MB
8.       max-file-size: 200MB
10. minio:
11.   url: http://127.0.0.1:19000 #换成自己的minio服务端地址
12.   accessKey: minioadmin # 用户名
13.   secretKey: minioadmin # 密码
14.   bucketName: demo  # bucketName指的就是之前创建的MinIO桶Bucket

复制代码

5.3、配置类Config

1. /**
2. * @author HAOYANG
3. * @create 2023-12-01 20:40
4. */
5. @Data
6. @Configuration
7. public class MinioConfig {
9.     /**
10.      * 访问地址
11.      */
12.     @Value("${minio.url}")
13.     private String endpoint;
15.     /**
16.      * accessKey类似于用户ID，用于唯一标识你的账户
17.      */
18.     @Value("${minio.accessKey}")
19.     private String accessKey;
21.     /**
22.      * secretKey是你账户的密码
23.      */
24.     @Value("${minio.secretKey}")
25.     private String secretKey;
27.     /**
28.      * 默认存储桶
29.      */
30.     @Value("${minio.bucketName}")
31.     private String bucketName;
33.     @Bean
34.     public MinioClient minioClient() {
35.         MinioClient minioClient = MinioClient.builder()
36.                 .endpoint(endpoint)
37.                 .credentials(accessKey, secretKey)
38.                 .build();
39.         return minioClient;
40.     }
41. }

复制代码

5.4、创建MinIO工具类

1. /**
2. * MinIO工具类
3. *
4. */
5. @Slf4j
6. @Component
7. @RequiredArgsConstructor
8. public class MinioUtils {
10.     private final MinioClient minioClient;
12.     /******************************  Operate Bucket Start  ******************************/
14.     /**
15.      * 启动SpringBoot容器的时候初始化Bucket
16.      * 如果没有Bucket则创建
17.      *
18.      * @param bucketName
19.      */
20.     @SneakyThrows(Exception.class)
21.     private void createBucket(String bucketName) {
22.         if (!bucketExists(bucketName)) {
23.             minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
24.         }
25.     }
27.     /**
28.      * 判断Bucket是否存在，true：存在，false：不存在
29.      *
30.      * @param bucketName
31.      * @return
32.      */
33.     @SneakyThrows(Exception.class)
34.     public boolean bucketExists(String bucketName) {
35.         return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
36.     }
38.     /**
39.      * 获得Bucket的策略
40.      *
41.      * @param bucketName
42.      * @return
43.      */
44.     @SneakyThrows(Exception.class)
45.     public String getBucketPolicy(String bucketName) {
46.         return minioClient.getBucketPolicy(GetBucketPolicyArgs
47.                 .builder()
48.                 .bucket(bucketName)
49.                 .build());
50.     }
52.     /**
53.      * 获得所有Bucket列表
54.      *
55.      * @return
56.      */
57.     @SneakyThrows(Exception.class)
58.     public List<Bucket> getAllBuckets() {
59.         return minioClient.listBuckets();
60.     }
62.     /**
63.      * 根据bucketName获取其相关信息
64.      *
65.      * @param bucketName
66.      * @return
67.      */
68.     @SneakyThrows(Exception.class)
69.     public Optional<Bucket> getBucket(String bucketName) {
70.         return getAllBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();
71.     }
73.     /**
74.      * 根据bucketName删除Bucket，true：删除成功； false：删除失败，文件或已不存在
75.      *
76.      * @param bucketName
77.      * @throws Exception
78.      */
79.     @SneakyThrows(Exception.class)
80.     public void removeBucket(String bucketName) {
81.         minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());
82.     }
84.     /******************************  Operate Bucket End  ******************************/
87.     /******************************  Operate Files Start  ******************************/
89.     /**
90.      * 判断文件是否存在
91.      *
92.      * @param bucketName
93.      * @param objectName
94.      * @return
95.      */
96.     public boolean isObjectExist(String bucketName, String objectName) {
97.         boolean exist = true;
98.         try {
99.             minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build());
100.         } catch (Exception e) {
101.             log.error("[Minio工具类]>>>> 判断文件是否存在, 异常：", e);
102.             exist = false;
103.         }
104.         return exist;
105.     }
107.     /**
108.      * 判断文件夹是否存在
109.      *
110.      * @param bucketName
111.      * @param objectName
112.      * @return
113.      */
114.     public boolean isFolderExist(String bucketName, String objectName) {
115.         boolean exist = false;
116.         try {
117.             Iterable<Result<Item>> results = minioClient.listObjects(
118.                     ListObjectsArgs.builder().bucket(bucketName).prefix(objectName).recursive(false).build());
119.             for (Result<Item> result : results) {
120.                 Item item = result.get();
121.                 if (item.isDir() && objectName.equals(item.objectName())) {
122.                     exist = true;
123.                 }
124.             }
125.         } catch (Exception e) {
126.             log.error("[Minio工具类]>>>> 判断文件夹是否存在，异常：", e);
127.             exist = false;
128.         }
129.         return exist;
130.     }
132.     /**
133.      * 根据文件前置查询文件
134.      *
135.      * @param bucketName 存储桶
136.      * @param prefix     前缀
137.      * @param recursive  是否使用递归查询
138.      * @return MinioItem 列表
139.      */
140.     @SneakyThrows(Exception.class)
141.     public List<Item> getAllObjectsByPrefix(String bucketName,
142.                                             String prefix,
143.                                             boolean recursive) {
144.         List<Item> list = new ArrayList<>();
145.         Iterable<Result<Item>> objectsIterator = minioClient.listObjects(
146.                 ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(recursive).build());
147.         if (objectsIterator != null) {
148.             for (Result<Item> o : objectsIterator) {
149.                 Item item = o.get();
150.                 list.add(item);
151.             }
152.         }
153.         return list;
154.     }
156.     /**
157.      * 获取文件流
158.      *
159.      * @param bucketName 存储桶
160.      * @param objectName 文件名
161.      * @return 二进制流
162.      */
163.     @SneakyThrows(Exception.class)
164.     public InputStream getObject(String bucketName, String objectName) {
165.         return minioClient.getObject(
166.                 GetObjectArgs.builder()
167.                         .bucket(bucketName)
168.                         .object(objectName)
169.                         .build());
170.     }
172.     /**
173.      * 断点下载
174.      *
175.      * @param bucketName 存储桶
176.      * @param objectName 文件名称
177.      * @param offset     起始字节的位置
178.      * @param length     要读取的长度
179.      * @return 二进制流
180.      */
181.     @SneakyThrows(Exception.class)
182.     public InputStream getObject(String bucketName, String objectName, long offset, long length) {
183.         return minioClient.getObject(
184.                 GetObjectArgs.builder()
185.                         .bucket(bucketName)
186.                         .object(objectName)
187.                         .offset(offset)
188.                         .length(length)
189.                         .build());
190.     }
192.     /**
193.      * 获取路径下文件列表
194.      *
195.      * @param bucketName 存储桶
196.      * @param prefix     文件名称
197.      * @param recursive  是否递归查找，false：模拟文件夹结构查找
198.      * @return 二进制流
199.      */
200.     public Iterable<Result<Item>> listObjects(String bucketName, String prefix, boolean recursive) {
201.         return minioClient.listObjects(
202.                 ListObjectsArgs.builder()
203.                         .bucket(bucketName)
204.                         .prefix(prefix)
205.                         .recursive(recursive)
206.                         .build());
207.     }
209.     /**
210.      * 使用MultipartFile进行文件上传
211.      *
212.      * @param bucketName  存储桶
213.      * @param file        文件名
214.      * @param objectName  对象名
215.      * @param contentType 类型
216.      * @return
217.      */
218.     @SneakyThrows(Exception.class)
219.     public ObjectWriteResponse uploadFile(String bucketName, MultipartFile file, String objectName, String contentType) {
220.         InputStream inputStream = file.getInputStream();
221.         return minioClient.putObject(
222.                 PutObjectArgs.builder()
223.                         .bucket(bucketName)
224.                         .object(objectName)
225.                         .contentType(contentType)
226.                         .stream(inputStream, inputStream.available(), -1)
227.                         .build());
228.     }
230.     /**
231.      * 图片上传
232.      * @param bucketName
233.      * @param imageBase64
234.      * @param imageName
235.      * @return
236.      */
237.     public ObjectWriteResponse uploadImage(String bucketName, String imageBase64, String imageName) {
238.         if (!StringUtils.isEmpty(imageBase64)) {
239.             InputStream in = base64ToInputStream(imageBase64);
240.             String newName = System.currentTimeMillis() + "_" + imageName + ".jpg";
241.             String year = String.valueOf(new Date().getYear());
242.             String month = String.valueOf(new Date().getMonth());
243.             return uploadFile(bucketName, year + "/" + month + "/" + newName, in);
245.         }
246.         return null;
247.     }
248. // BASE64Decoder在jdk8以上的版本移除了，报错最简单解决换成jdk8就行了
249.     public static InputStream base64ToInputStream(String base64) {
250.         ByteArrayInputStream stream = null;
251.         try {
252.             byte[] bytes = new BASE64Decoder().decodeBuffer(base64.trim());
253.             stream = new ByteArrayInputStream(bytes);
254.         } catch (Exception e) {
255.             e.printStackTrace();
256.         }
257.         return stream;
258.     }
261.     /**
262.      * 上传本地文件
263.      *
264.      * @param bucketName 存储桶
265.      * @param objectName 对象名称
266.      * @param fileName   本地文件路径
267.      * @return
268.      */
269.     @SneakyThrows(Exception.class)
270.     public ObjectWriteResponse uploadFile(String bucketName, String objectName, String fileName) {
271.         return minioClient.uploadObject(
272.                 UploadObjectArgs.builder()
273.                         .bucket(bucketName)
274.                         .object(objectName)
275.                         .filename(fileName)
276.                         .build());
277.     }
279.     /**
280.      * 通过流上传文件
281.      *
282.      * @param bucketName  存储桶
283.      * @param objectName  文件对象
284.      * @param inputStream 文件流
285.      * @return
286.      */
287.     @SneakyThrows(Exception.class)
288.     public ObjectWriteResponse uploadFile(String bucketName, String objectName, InputStream inputStream) {
289.         return minioClient.putObject(
290.                 PutObjectArgs.builder()
291.                         .bucket(bucketName)
292.                         .object(objectName)
293.                         .stream(inputStream, inputStream.available(), -1)
294.                         .build());
295.     }
297.     /**
298.      * 创建文件夹或目录
299.      *
300.      * @param bucketName 存储桶
301.      * @param objectName 目录路径
302.      * @return
303.      */
304.     @SneakyThrows(Exception.class)
305.     public ObjectWriteResponse createDir(String bucketName, String objectName) {
306.         return minioClient.putObject(
307.                 PutObjectArgs.builder()
308.                         .bucket(bucketName)
309.                         .object(objectName)
310.                         .stream(new ByteArrayInputStream(new byte[]{}), 0, -1)
311.                         .build());
312.     }
314.     /**
315.      * 获取文件信息, 如果抛出异常则说明文件不存在
316.      *
317.      * @param bucketName 存储桶
318.      * @param objectName 文件名称
319.      * @return
320.      */
321.     @SneakyThrows(Exception.class)
322.     public String getFileStatusInfo(String bucketName, String objectName) {
323.         return minioClient.statObject(
324.                 StatObjectArgs.builder()
325.                         .bucket(bucketName)
326.                         .object(objectName)
327.                         .build()).toString();
328.     }
330.     /**
331.      * 拷贝文件
332.      *
333.      * @param bucketName    存储桶
334.      * @param objectName    文件名
335.      * @param srcBucketName 目标存储桶
336.      * @param srcObjectName 目标文件名
337.      */
338.     @SneakyThrows(Exception.class)
339.     public ObjectWriteResponse copyFile(String bucketName, String objectName, String srcBucketName, String srcObjectName) {
340.         return minioClient.copyObject(
341.                 CopyObjectArgs.builder()
342.                         .source(CopySource.builder().bucket(bucketName).object(objectName).build())
343.                         .bucket(srcBucketName)
344.                         .object(srcObjectName)
345.                         .build());
346.     }
348.     /**
349.      * 删除文件
350.      *
351.      * @param bucketName 存储桶
352.      * @param objectName 文件名称
353.      */
354.     @SneakyThrows(Exception.class)
355.     public void removeFile(String bucketName, String objectName) {
356.         minioClient.removeObject(
357.                 RemoveObjectArgs.builder()
358.                         .bucket(bucketName)
359.                         .object(objectName)
360.                         .build());
361.     }
363.     /**
364.      * 批量删除文件
365.      *
366.      * @param bucketName 存储桶
367.      * @param keys       需要删除的文件列表
368.      * @return
369.      */
370.     public void removeFiles(String bucketName, List<String> keys) {
371.         List<DeleteObject> objects = new LinkedList<>();
372.         keys.forEach(s -> {
373.             objects.add(new DeleteObject(s));
374.             try {
375.                 removeFile(bucketName, s);
376.             } catch (Exception e) {
377.                 log.error("[Minio工具类]>>>> 批量删除文件，异常：", e);
378.             }
379.         });
380.     }
382.     /**
383.      * 获取文件外链
384.      *
385.      * @param bucketName 存储桶
386.      * @param objectName 文件名
387.      * @param expires    过期时间 <=7 秒 （外链有效时间（单位：秒））
388.      * @return url
389.      */
390.     @SneakyThrows(Exception.class)
391.     public String getPresignedObjectUrl(String bucketName, String objectName, Integer expires) {
392.         GetPresignedObjectUrlArgs args = GetPresignedObjectUrlArgs.builder().expiry(expires).bucket(bucketName).object(objectName).build();
393.         return minioClient.getPresignedObjectUrl(args);
394.     }
396.     /**
397.      * 获得文件外链
398.      *
399.      * @param bucketName
400.      * @param objectName
401.      * @return url
402.      */
403.     @SneakyThrows(Exception.class)
404.     public String getPresignedObjectUrl(String bucketName, String objectName) {
405.         GetPresignedObjectUrlArgs args = GetPresignedObjectUrlArgs.builder()
406.                 .bucket(bucketName)
407.                 .object(objectName)
408.                 .method(Method.GET).build();
409.         return minioClient.getPresignedObjectUrl(args);
410.     }
412.     /**
413.      * 将URLDecoder编码转成UTF8
414.      *
415.      * @param str
416.      * @return
417.      * @throws UnsupportedEncodingException
418.      */
419.     public String getUtf8ByURLDecoder(String str) throws UnsupportedEncodingException {
420.         String url = str.replaceAll("%(?![0-9a-fA-F]{2})", "%25");
421.         return URLDecoder.decode(url, "UTF-8");
422.     }
423. }

复制代码

5.5、创建Controller

1. /**
2. * @author HAOYANG
3. * @create 2023-12-01 20:38
4. */
5. @Slf4j
6. @RestController
7. @RequestMapping("/oss")
8. public class OSSController {
10.     @Autowired
11.     private MinioUtils minioUtils;
13.     @Autowired
14.     private MinioConfig minioConfig;
16.     /**
17.      * 文件上传
18.      *
19.      * @param file
20.      */
21.     @PostMapping("/upload")
22.     public String upload(@RequestParam("file") MultipartFile file) {
23.         try {
24.             //文件名
25.             String fileName = file.getOriginalFilename();
26.             String newFileName = System.currentTimeMillis() + "." + StringUtils.substringAfterLast(fileName, ".");
27.             //类型
28.             String contentType = file.getContentType();
29.             minioUtils.uploadFile(minioConfig.getBucketName(), file, newFileName, contentType);
30.             return "上传成功";
31.         } catch (Exception e) {
32.             log.error("上传失败");
33.             return "上传失败";
34.         }
35.     }
37.     /**
38.      * 删除
39.      *
40.      * @param fileName
41.      */
42.     @DeleteMapping("/")
43.     public void delete(@RequestParam("fileName") String fileName) {
44.         minioUtils.removeFile(minioConfig.getBucketName(), fileName);
45.     }
47.     /**
48.      * 获取文件信息
49.      *
50.      * @param fileName
51.      * @return
52.      */
53.     @GetMapping("/info")
54.     public String getFileStatusInfo(@RequestParam("fileName") String fileName) {
55.         return minioUtils.getFileStatusInfo(minioConfig.getBucketName(), fileName);
56.     }
58.     /**
59.      * 获取文件外链
60.      *
61.      * @param fileName
62.      * @return
63.      */
64.     @GetMapping("/url")
65.     public String getPresignedObjectUrl(@RequestParam("fileName") String fileName) {
66.         return minioUtils.getPresignedObjectUrl(minioConfig.getBucketName(), fileName);
67.     }
69.     /**
70.      * 文件下载
71.      *
72.      * @param fileName
73.      * @param response
74.      */
75.     @GetMapping("/download")
76.     public void download(@RequestParam("fileName") String fileName, HttpServletResponse response) {
77.         try {
78.             InputStream fileInputStream = minioUtils.getObject(minioConfig.getBucketName(), fileName);
79.             response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
80.             response.setContentType("application/force-download");
81.             response.setCharacterEncoding("UTF-8");
82.             IOUtils.copy(fileInputStream, response.getOutputStream());
83.         } catch (Exception e) {
84.             log.error("下载失败");
85.         }
86.     }
88. }

复制代码

6、测试验证

6.1、文件上传

使用Postman调用http://localhost:3333/oss/upload 接口，选择某个文件测试上传功能，如下图所示：

6.2、文件下载

在浏览器中，调用http://localhost:3333/oss/download?fileName=1701436432918.gif 接口，验证文件下载接口，如下图所示：

更多精彩文章可以关注 鹏摇星海 公众号


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。