一、前言

随着云计算和大数据的快速发展，企业对存储系统的需求逐渐增大，尤其是对于海量数据的存储和管理。传统的文件存储方式已经不能满足性能、可扩展性和安全性等方面的要求。对象存储（Object Storage）作为一种新的存储方式，凭借其灵活性、扩展性和高可用性，逐渐成为了现代企业存储系统的首选。

MinIO 是一个高性能、分布式对象存储服务，兼容 Amazon S3 API，非常适合用于开发和部署私有云存储服务。Spring Boot 是一个简化企业级 Java 应用程序开发的框架，它凭借开箱即用的特性，广泛用于快速开发微服务应用。

二、MinIO 概述

MinIO 是一个开源的、高性能的对象存储服务，能够与 Amazon S3 兼容，支持海量数据存储，具有以下特点：

高性能：MinIO 采用 Go 语言编写，具有非常高的性能表现，支持大规模数据存储和高并发访问。
兼容 S3 API：MinIO 提供与 Amazon S3 完全兼容的 API，使得应用程序能够无缝迁移到 MinIO 上。
易于部署：MinIO 支持容器化部署，可以在 Kubernetes、Docker 等环境中运行。
分布式架构：MinIO 支持分布式存储，能够横向扩展，满足大规模存储需求。
支持多种存储方式：MinIO 支持本地存储、远程存储等多种数据源，可根据需求灵活配置。

三、Spring Boot 项目搭建

3.1 创建 Spring Boot 项目

我们可以使用 Spring Initializr 创建一个 Spring Boot 项目，选择相关的依赖项，如 Web、Lombok 等。

访问 Spring Initializr:
项目设置：

项目：Maven Project
语言：Java
Spring Boot：选择最新版本
依赖项：Spring Web、Lombok
项目名称：minio-demo
包名：com.example.minio

点击 Generate，下载并解压项目。

3.2 添加 MinIO 依赖

在 pom.xml 文件中，添加 MinIO 相关依赖：

<dependencies>
        <dependency>
            <groupId>io.minio</groupId>
            <artifactId>minio</artifactId>
            <version>8.5.0</version>
        </dependency>
        <!-- Spring Boot Starter Web -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.24</version>
            <scope>provided</scope>
        </dependency>
 </dependencies>

3.3 配置 MinIO

在 application.properties 或 application.yml 文件中，配置 MinIO 服务器的连接信息：

minio.url=http://localhost:9090
minio.access-key=your-access-key
minio.secret-key=your-secret-key
minio.bucket-name=test-bucket

在这里，minio.url 是 MinIO 服务的访问地址，minio.access-key 和 minio.secret-key 是用于身份验证的访问密钥，minio.bucket-name 是存储桶的名称。

3.4 创建 MinIO 配置类

在 Spring Boot 中，我们可以创建一个配置类来初始化 MinIO 客户端，代码如下：

package com.example.minio.config;

import io.minio.MinioClient;
import io.minio.errors.MinioException;
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.url}")
    private String minioUrl;

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

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

    @Bean
    public MinioClient minioClient() {
       return MinioClient.builder()
                .region("cn-north-1")
                .endpoint(minioUrl)
                .credentials(accessKey, secretKey)
                .build();
    }
}

该配置类会在 Spring Boot 启动时初始化 MinIO 客户端，便于后续操作。

四、实现对象存储服务

4.1 创建文件上传接口

在 Spring Boot 中，我们可以使用 @RestController 来创建一个 RESTful API，用于文件的上传和下载。

package com.example.minio.controller;

import io.minio.MinioClient;
import io.minio.errors.MinioException;
import io.minio.messages.Bucket;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;

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

    private final MinioClient minioClient;
    private final String bucketName = "my-bucket";

    // 上传文件
    @PostMapping("/upload")
    public String uploadFile(@RequestParam("file") MultipartFile file) {
        // 使用putObject上传一个文件到存储桶中。
        try {
            InputStream inputStream = file.getInputStream();
            minioClient.putObject(PutObjectArgs.builder()
                    .bucket(bucketName)
                    .object(file.getOriginalFilename())
                    .stream(inputStream, file.getSize(), -1)
                    .contentType(file.getContentType())
                    .build());
            return "File uploaded successfully!";
        } catch (Exception e) {
            e.printStackTrace();
            return "Error occurred while uploading file: " + e.getMessage();
        }
    }

    // 获取所有桶
    @GetMapping("/buckets")
    public List<Bucket> listBuckets() {
        try {
            return minioClient.listBuckets();
        } catch (Exception e) {
            throw new RuntimeException("Error occurred while listing buckets", e);
        }
    }

    // 下载文件
    @GetMapping("/download/{fileName}")
    public void downloadFile(HttpServletResponse response, @PathVariable String fileName) {
        InputStream in = null;
        try {
            // 获取对象信息
            StatObjectResponse stat = minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(fileName).build());
            response.setContentType(stat.contentType());
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
            // 文件下载
            in = minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(fileName).build());
            IOUtils.copy(in, response.getOutputStream());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

4.2 实现文件上传和下载

文件上传：通过 MultipartFile 接收前端上传的文件，并将文件存储到 MinIO 服务中。
获取所有存储桶：列出 MinIO 中所有的存储桶。
文件下载：根据文件名从 MinIO 下载文件。

4.3 测试文件上传与下载

我们可以通过 Postman 或前端页面来测试文件上传与下载。

上传文件：向 POST /api/minio/upload 发送带有文件的请求。
下载文件：向 GET /api/minio/download/{fileName} 发送下载请求。

五、总结

在实际应用中，可以根据需求进一步扩展功能，如判断存储桶是否存在，创建存储桶，上传文件，删除文件，访问权限管理，文件搜索等操作，构建一个更加强大的文件存储系统。

桓楠百科网

编程知识、经典语录与百科知识分享平台

SpringBoot集成MinIo实现文件存储-菜鸟入门级