SpringBoot项目集成MinIO

最近在学习MinIO，所以想让自己的SpringBoot项目集成MinIO,在网上查阅资料，并进行操作的过程中遇到一些问题，所以想把自己遇到的坑和完成步骤记录下来供自己和各位查阅。

一. MinIO的下载安装以及基本使用

1. 下载地址：https://dl.min.io/server/minio/release/windows-amd64/minio.exe

2. 下载好后需要手动创建data文件夹用于存储MinIO中的数据。

3. 键入cmd

4. 设置MinIO的一些变量

set MINIO_ROOT_USER=admin

set MINIO_ROOT_PASSWORD=admin123

set MINIO_ACCESS_KEY=admin

set MINIO_SECRET_KEY=admin123

下面是我踩的坑，如果只设置了MINIO_ROOT_USER和MINIO_ROOT_PASSWORD的值，而不设置MINIO_ACCESS_KEY和MINIO_SECRET_KEY的值，当启动minio服务的时候就会报以下异常：

所以一定要设置好后面两个变量的值。

5. 启动minio服务

> minio.exeserver data

启动后就会出现minio服务的地址，按住ctrl再点击即可访问该网址。

6.进入登录页面后，输入对应的用户名和密码，也就是之前设置的MINIO_ROOT_USER和MINIO_ROOT_PASSWORD的值。

7. 进入主界面后，点击左侧导航栏中的Buckets，然后点击Create Bucket。

8. 创建好之后，点击左侧导航栏中的Object Browser就可以看到创建好的桶了。

9. 进入该桶，点击upload,上传一个文件，桶的默认权限是private,所以外界访问不到，需要修改访问权限为public，但是要注意安全问题。

10. 点击左侧导航栏中的Buckets，进入该桶，修改权限为public，这样外界就可以访问上传的文件了。

二. SpringBoot集成MinIO

1. 引入依赖

io.minio minio 7.0.2

2. 编写配置文件

server:
port: 8081
spring:

配置文件上传大小限制

servlet:
multipart:
max-file-size: 200MB
max-request-size: 200MB
minio:
host: http://127.0.0.1:9000
url: $minio.host/${minio.bucket}/
access-key: minioadmin
secret-key: minioadmin
bucket: public

3. 添加配置文件

package com.suwell.serv.ocr.component;
?
import io.minio.MinioClient;
import io.minio.ObjectStat;
import io.minio.PutObjectOptions;
import io.minio.Result;
import io.minio.messages.Bucket;
import io.minio.messages.Item;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.util.UriUtils;
?
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
?
?
@Component
public class MinioConfig implements InitializingBean {
?
 ? ?@Value(value = "${minio.bucket}")
 ? ?private String bucket;
?
 ? ?@Value(value = "${minio.host}")
 ? ?private String host;
?
 ? ?@Value(value = "${minio.url}")
 ? ?private String url;
?
 ? ?@Value(value = "${minio.access-key}")
 ? ?private String accessKey;
?
 ? ?@Value(value = "${minio.secret-key}")
 ? ?private String secretKey;
?
 ? ?private MinioClient minioClient;
?
 ? ?@Override
 ? ?public void afterPropertiesSet() throws Exception {
 ? ? ? ?Assert.hasText(url, "Minio url 为空");
 ? ? ? ?Assert.hasText(accessKey, "Minio accessKey为空");
 ? ? ? ?Assert.hasText(secretKey, "Minio secretKey为空");
 ? ? ? ?this.minioClient = new MinioClient(this.host, this.accessKey, this.secretKey);
 ?  }
?
?
?
 ? ?/**
 ? ? * 上传
 ? ? */
 ? ?public String putObject(MultipartFile multipartFile) throws Exception {
 ? ? ? ?// bucket 不存在，创建
 ? ? ? ?if (!minioClient.bucketExists(this.bucket)) {
 ? ? ? ? ? ?minioClient.makeBucket(this.bucket);
 ? ? ?  }
 ? ? ? ?try (InputStream inputStream = multipartFile.getInputStream()) {
 ? ? ? ? ? ?// 上传文件的名称
 ? ? ? ? ? ?String fileName = multipartFile.getOriginalFilename();
 ? ? ? ? ? ?// PutObjectOptions，上传配置(文件大小，内存中文件分片大小)
 ? ? ? ? ? ?PutObjectOptions putObjectOptions = new PutObjectOptions(multipartFile.getSize(), PutObjectOptions.MIN_MULTIPART_SIZE);
 ? ? ? ? ? ?// 文件的ContentType
 ? ? ? ? ? ?putObjectOptions.setContentType(multipartFile.getContentType());
 ? ? ? ? ? ?minioClient.putObject(this.bucket, fileName, inputStream, putObjectOptions);
 ? ? ? ? ? ?// 返回访问路径
 ? ? ? ? ? ?return this.url + UriUtils.encode(fileName, StandardCharsets.UTF_8);
 ? ? ?  }
 ?  }
?
 ? ?/**
 ? ? * 文件下载
 ? ? */
 ? ?public void download(String fileName, HttpServletResponse response){
 ? ? ? ?// 从链接中得到文件名
 ? ? ? ?InputStream inputStream;
 ? ? ? ?try {
 ? ? ? ? ? ?MinioClient minioClient = new MinioClient(host, accessKey, secretKey);
 ? ? ? ? ? ?ObjectStat stat = minioClient.statObject(bucket, fileName);
 ? ? ? ? ? ?inputStream = minioClient.getObject(bucket, fileName);
 ? ? ? ? ? ?response.setContentType(stat.contentType());
 ? ? ? ? ? ?response.setCharacterEncoding("UTF-8");
 ? ? ? ? ? ?response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
 ? ? ? ? ? ?byte[] buffer = new byte[1024];
 ? ? ? ? ? ?int length;
 ? ? ? ? ? ?while ((length = inputStream.read(buffer)) > 0) {
 ? ? ? ? ? ? ? ?response.getOutputStream().write(buffer, 0, length);
 ? ? ? ? ?  }
 ? ? ? ? ? ?inputStream.close();
 ? ? ?  } catch (Exception e){
 ? ? ? ? ? ?e.printStackTrace();
 ? ? ? ? ? ?System.out.println("有异常：" + e);
 ? ? ?  }
 ?  }
?
 ? ?/**
 ? ? * 列出所有存储桶名称
 ? ? *
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public List<String> listBucketNames()
 ? ? ? ? ? ?throws Exception {
 ? ? ? ?List<Bucket> bucketList = listBuckets();
 ? ? ? ?List<String> bucketListName = new ArrayList<>();
 ? ? ? ?for (Bucket bucket : bucketList) {
 ? ? ? ? ? ?bucketListName.add(bucket.name());
 ? ? ?  }
 ? ? ? ?return bucketListName;
 ?  }
?
 ? ?/**
 ? ? * 查看所有桶
 ? ? *
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public List<Bucket> listBuckets()
 ? ? ? ? ? ?throws Exception {
 ? ? ? ?return minioClient.listBuckets();
 ?  }
?
 ? ?/**
 ? ? * 检查存储桶是否存在
 ? ? *
 ? ? * @param bucketName
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public boolean bucketExists(String bucketName) throws Exception {
 ? ? ? ?boolean flag = minioClient.bucketExists(bucketName);
 ? ? ? ?if (flag) {
 ? ? ? ? ? ?return true;
 ? ? ?  }
 ? ? ? ?return false;
 ?  }
?
 ? ?/**
 ? ? * 创建存储桶
 ? ? *
 ? ? * @param bucketName
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public boolean makeBucket(String bucketName)
 ? ? ? ? ? ?throws Exception {
 ? ? ? ?boolean flag = bucketExists(bucketName);
 ? ? ? ?if (!flag) {
 ? ? ? ? ? ?minioClient.makeBucket(bucketName);
 ? ? ? ? ? ?return true;
 ? ? ?  } else {
 ? ? ? ? ? ?return false;
 ? ? ?  }
 ?  }
?
 ? ?/**
 ? ? * 删除桶
 ? ? *
 ? ? * @param bucketName
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public boolean removeBucket(String bucketName)
 ? ? ? ? ? ?throws Exception {
 ? ? ? ?boolean flag = bucketExists(bucketName);
 ? ? ? ?if (flag) {
 ? ? ? ? ? ?Iterable<Result<Item>> myObjects = listObjects(bucketName);
 ? ? ? ? ? ?for (Result<Item> result : myObjects) {
 ? ? ? ? ? ? ? ?Item item = result.get();
 ? ? ? ? ? ? ? ?// 有对象文件，则删除失败
 ? ? ? ? ? ? ? ?if (item.size() > 0) {
 ? ? ? ? ? ? ? ? ? ?return false;
 ? ? ? ? ? ? ?  }
 ? ? ? ? ?  }
 ? ? ? ? ? ?// 删除存储桶，注意，只有存储桶为空时才能删除成功。
 ? ? ? ? ? ?minioClient.removeBucket(bucketName);
 ? ? ? ? ? ?flag = bucketExists(bucketName);
 ? ? ? ? ? ?if (!flag) {
 ? ? ? ? ? ? ? ?return true;
 ? ? ? ? ?  }
?
 ? ? ?  }
 ? ? ? ?return false;
 ?  }
?
 ? ?/**
 ? ? * 列出存储桶中的所有对象
 ? ? *
 ? ? * @param bucketName 存储桶名称
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public Iterable<Result<Item>> listObjects(String bucketName) throws Exception {
 ? ? ? ?boolean flag = bucketExists(bucketName);
 ? ? ? ?if (flag) {
 ? ? ? ? ? ?return minioClient.listObjects(bucketName);
 ? ? ?  }
 ? ? ? ?return null;
 ?  }
?
 ? ?/**
 ? ? * 列出存储桶中的所有对象名称
 ? ? *
 ? ? * @param bucketName 存储桶名称
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public List<String> listObjectNames(String bucketName) throws Exception {
 ? ? ? ?List<String> listObjectNames = new ArrayList<>();
 ? ? ? ?boolean flag = bucketExists(bucketName);
 ? ? ? ?if (flag) {
 ? ? ? ? ? ?Iterable<Result<Item>> myObjects = listObjects(bucketName);
 ? ? ? ? ? ?for (Result<Item> result : myObjects) {
 ? ? ? ? ? ? ? ?Item item = result.get();
 ? ? ? ? ? ? ? ?listObjectNames.add(item.objectName());
 ? ? ? ? ?  }
 ? ? ?  }
 ? ? ? ?return listObjectNames;
 ?  }
?
 ? ?/**
 ? ? * 删除一个对象
 ? ? *
 ? ? * @param bucketName 存储桶名称
 ? ? * @param objectName 存储桶里的对象名称
 ? ? * @throws Exception
 ? ? */
 ? ?public boolean removeObject(String bucketName, String objectName) throws Exception {
 ? ? ? ?boolean flag = bucketExists(bucketName);
 ? ? ? ?if (flag) {
 ? ? ? ? ? ?List<String> objectList = listObjectNames(bucketName);
 ? ? ? ? ? ?for (String s : objectList) {
 ? ? ? ? ? ? ? ?if(s.equals(objectName)){
 ? ? ? ? ? ? ? ? ? ?minioClient.removeObject(bucketName, objectName);
 ? ? ? ? ? ? ? ? ? ?return true;
 ? ? ? ? ? ? ?  }
 ? ? ? ? ?  }
 ? ? ?  }
 ? ? ? ?return false;
 ?  }
?
 ? ?/**
 ? ? * 文件访问路径
 ? ? *
 ? ? * @param bucketName 存储桶名称
 ? ? * @param objectName 存储桶里的对象名称
 ? ? * @return
 ? ? * @throws Exception
 ? ? */
 ? ?public String getObjectUrl(String bucketName, String objectName) throws Exception {
 ? ? ? ?boolean flag = bucketExists(bucketName);
 ? ? ? ?String url = "";
 ? ? ? ?if (flag) {
 ? ? ? ? ? ?url = minioClient.getObjectUrl(bucketName, objectName);
 ? ? ?  }
 ? ? ? ?return url;
 ?  }
?
}

4. 编写测试类进行测试

package com.suwell.serv.ocr.controller;
?
import com.suwell.serv.ocr.component.MinioConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
?
import javax.servlet.http.HttpServletResponse;
import java.util.List;
?
@RestController
@CrossOrigin
@RequestMapping("/test")
public class MinioController {
?
 ? ?@Autowired
 ? ?MinioConfig minioConfig;
?
 ? ?// 上传
 ? ?@PostMapping("/upload")
 ? ?public Object upload(@RequestParam("file") MultipartFile multipartFile) throws Exception {
 ? ? ? ?return this.minioConfig.putObject(multipartFile);
 ?  }
?
 ? ?// 下载文件
 ? ?@GetMapping("/download")
 ? ?public void download(@RequestParam("fileName")String fileName, HttpServletResponse response) {
 ? ? ? ?this.minioConfig.download(fileName,response);
 ?  }
?
 ? ?// 列出所有存储桶名称
 ? ?@PostMapping("/list")
 ? ?public List<String> list() throws Exception {
 ? ? ? ?return this.minioConfig.listBucketNames();
 ?  }
?
 ? ?// 创建存储桶
 ? ?@PostMapping("/createBucket")
 ? ?public boolean createBucket(String bucketName) throws Exception {
 ? ? ? ?return this.minioConfig.makeBucket(bucketName);
 ?  }
?
 ? ?// 删除存储桶
 ? ?@PostMapping("/deleteBucket")
 ? ?public boolean deleteBucket(String bucketName) throws Exception {
 ? ? ? ?return this.minioConfig.removeBucket(bucketName);
 ?  }
?
 ? ?// 列出存储桶中的所有对象名称
 ? ?@PostMapping("/listObjectNames")
 ? ?public List<String> listObjectNames(String bucketName) throws Exception {
 ? ? ? ?return this.minioConfig.listObjectNames(bucketName);
 ?  }
?
 ? ?// 删除一个对象
 ? ?@PostMapping("/removeObject")
 ? ?public boolean removeObject(String bucketName, String objectName) throws Exception {
 ? ? ? ?return this.minioConfig.removeObject(bucketName, objectName);
 ?  }
?
 ? ?// 文件访问路径
 ? ?@PostMapping("/getObjectUrl")
 ? ?public String getObjectUrl(String bucketName, String objectName) throws Exception {
 ? ? ? ?return this.minioConfig.getObjectUrl(bucketName, objectName);
 ?  }
}

5. 使用postman进行本地测试

6. 最后查看public桶中是否有刚才上传的文件就可以了。如果有则表明你的项目已经成功集成minio了。

以上就是springboot项目如何集成minio的全部内容了，如果对你有帮助我会感到非常荣幸。

原文地址：https://blog.csdn.net/m0_74824823/article/details/145272886

免责声明：本站文章内容转载自网络资源，如侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！