微服务系列|微服务系列（分布式文件存储之 Spring Boot 集成 MinIO） boot|分布式存储|MInIo|spring

微服务系列：分布式文件存储之 MinIO 搭建指南

在上一篇文章中，我们已经学会怎么去搭建一个 MinIO 的对象存储服务，这篇文章我们会学习一下在实战 Java 项目中如何集成 MinIO 去使用。
话不多说，开始今天的学习。
项目集成 1. 引入依赖

io.minio minio 8.2.2 org.springframework.boot spring-boot-starter-web

2. 配置文件

# Tomcat server: port: 9300 # Minio配置 minio: url: http://localhost:9000 accessKey: minioadmin secretKey: minioadmin bucketName: test

【微服务系列|微服务系列（分布式文件存储之 Spring Boot 集成 MinIO）】minio 下的参数分别是 minio 服务地址，用户名，密码，存储桶名称

注意：最好是再配置一下允许的上传文件大小，Spring Boot 的默认上传文件大小是 1M

spring: # 配置文件上传大小限制 servlet: multipart: max-file-size: 100MB max-request-size: 100MB

3. 配置类

/** * Minio 配置信息 * * @author ruoyi */ @Configuration @ConfigurationProperties(prefix = "minio") public class MinioConfig { /** * 服务地址 */ private String url; /** * 用户名 */ private String accessKey; /** * 密码 */ private String secretKey; /** * 存储桶名称 */ private String bucketName; // 省略 get、set 方法@Bean public MinioClient getMinioClient() { return MinioClient.builder().endpoint(url).credentials(accessKey, secretKey).build(); } }

配置类用来读取 yml 文件中的 minio 配置，并且初始化 MinioClient 到 Spring 容器。
4. 文件上传类

首先是 service 层

public interface ISysFileService { /** * 文件上传接口 * * @param file 上传的文件 * @return 访问地址 * @throws Exception */ public String uploadFile(MultipartFile file) throws Exception; }@Service public class MinioSysFileServiceImpl implements ISysFileService { @Autowired private MinioConfig minioConfig; @Autowired private MinioClient client; /** * 本地文件上传接口 * @param file 上传的文件 * @return 访问地址 * @throws Exception */ @Override public String uploadFile(MultipartFile file) throws Exception { String fileName = file.getOriginalFilename(); PutObjectArgs args = PutObjectArgs.builder() .bucket(minioConfig.getBucketName()) .object(fileName) .stream(file.getInputStream(), file.getSize(), -1) .contentType(file.getContentType()) .build(); client.putObject(args); return minioConfig.getUrl() + "/" + minioConfig.getBucketName() + "/" + fileName; } }

然后是 controller 层

/** * 文件请求处理 */ @RestController public class SysFileController { @Autowired private ISysFileService sysFileService; /** * 文件上传请求 */ @PostMapping("upload") public Map upload(MultipartFile file) { Map map = new HashMap<>(); try { // 上传并返回访问地址 String url = sysFileService.uploadFile(file); map.put("status", "success"); map.put("data", url); return map; } catch (Exception e) { log.error("上传文件失败", e); map.put("status", "error"); map.put("msg", e.getMessage()); return map; } } }

Spring Boot 项目集成起来也是非常简单，下面我们来测试一波。
启动测试打开 postman 使用 form-data 格式发送文件上传请求，返回成功