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

引入依赖

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进行本地测试