Spring Boot 整合 MinIO 实现文件的上传下载

MinIO 是一个高性能的对象存储服务，兼容亚马逊 S3 API，适合用于云原生应用、数据存储等场景。在 Spring Boot 项目中集成 MinIO，可以实现文件的上传和下载功能。以下是完整的实现步骤。

1. 添加依赖

在 pom.xml 中引入 MinIO 的 Java SDK 依赖：

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.3.2</version>
</dependency>

此外，确保 Spring Boot 的 Web 相关依赖已经配置：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

2. MinIO 配置

在 application.yml 或 application.properties 中配置 MinIO 的连接信息：

minio:
  endpoint: http://localhost:9000
  access-key: minioadmin
  secret-key: minioadmin
  bucket-name: my-bucket

3. 配置类

创建一个配置类 MinioConfig，用于初始化 MinIO 客户端。

import io.minio.MinioClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MinioConfig {

    @Value("${minio.endpoint}")
    private String endpoint;

    @Value("${minio.access-key}")
    private String accessKey;

    @Value("${minio.secret-key}")
    private String secretKey;

    @Bean
    public MinioClient minioClient() {
        return MinioClient.builder()
                .endpoint(endpoint)
                .credentials(accessKey, secretKey)
                .build();
    }
}

4. 服务类

创建 MinioService，实现文件上传和下载功能。

import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import io.minio.GetObjectArgs;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;

@Service
public class MinioService {

    @Autowired
    private MinioClient minioClient;

    @Value("${minio.bucket-name}")
    private String bucketName;

    // 文件上传
    public String uploadFile(MultipartFile file) throws Exception {
        String fileName = file.getOriginalFilename();

        minioClient.putObject(
            PutObjectArgs.builder()
                    .bucket(bucketName)
                    .object(fileName)
                    .stream(file.getInputStream(), file.getSize(), -1)
                    .contentType(file.getContentType())
                    .build()
        );

        return fileName;
    }

    // 文件下载
    public InputStream downloadFile(String fileName) throws Exception {
        return minioClient.getObject(
            GetObjectArgs.builder()
                    .bucket(bucketName)
                    .object(fileName)
                    .build()
        );
    }
}

5. 控制器类

创建控制器 MinioController，用于处理文件上传和下载的 HTTP 请求。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;

@RestController
@RequestMapping("/minio")
public class MinioController {

    @Autowired
    private MinioService minioService;

    @PostMapping("/upload")
    public ResponseEntity<String> uploadFile(@RequestParam("file") MultipartFile file) {
        try {
            String fileName = minioService.uploadFile(file);
            return ResponseEntity.ok("File uploaded successfully: " + fileName);
        } catch (Exception e) {
            return ResponseEntity.status(500).body("File upload failed: " + e.getMessage());
        }
    }

    @GetMapping("/download")
    public ResponseEntity<InputStream> downloadFile(@RequestParam("filename") String fileName) {
        try {
            InputStream file = minioService.downloadFile(fileName);
            return ResponseEntity.ok()
                    .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + fileName + "\"")
                    .contentType(MediaType.APPLICATION_OCTET_STREAM)
                    .body(file);
        } catch (Exception e) {
            return ResponseEntity.status(500).body(null);
        }
    }
}

总结

通过 Spring Boot 与 MinIO 的整合，可以轻松实现文件的上传和下载。MinIO 兼容 S3 API，具有高性能和易用性，在构建云存储应用时非常适合。本文展示了配置、实现服务类以及处理 HTTP 请求的完整流程，能够帮助您快速集成 MinIO 实现文件操作功能。