微服务系列：分布式文件存储之 Spring Boot 集成 MinIO

微服务系列：分布式文件存储之 Spring Boot 集成 MinIO

微服务系列：分布式文件存储之 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

minio 下的参数分别是 minio 服务地址，用户名，密码，存储桶名称

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

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

3. 配置类

@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
{
    
    public String uploadFile(MultipartFile file) throws Exception;
}


@Service
public class MinioSysFileServiceImpl implements ISysFileService
{
    @Autowired
    private MinioConfig minioConfig;

    @Autowired
    private MinioClient client;

    
    @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 格式发送文件上传请求，返回成功

浏览器访问返回的文件 url

然后再去我们的 MinIO 控制台看一下

测试成功。

补充

存储桶命名要求

存储桶的命名需符合以下一个或多个规则

存储桶名称的长度介于 3 和 63 个字符之间，并且只能包含小写字母、数字、句点和短划线。存储桶名称中的每个标签必须以小写字母或数字开头。存储桶名称不能包含下划线、以短划线结束、包含连续句点或在句点旁边使用短划线。存储桶名称不能采用 IP 地址格式 (198.51.100.24)。存储桶用作可公开访问的 URL，因此您选择的存储桶名称必须具有全局唯一性。如果您选择的名称已被其他一些帐户用于创建存储桶，则必须使用其他名称。