SpringBoot3整合MinIO实现分布式文件存储系统

2025-07-29 10:28 开发作者：喵手

前言

MinIO 是一个高性能的分布式对象存储系统，兼容 Amazon S3 协议，广泛用于存储大量非结构化数据，如图片、视频、日志等。Spring Boot 3 提供了与 MinIO 的良好集成，可以很方便地将 MinIO 用于分布式文件存储。

在这篇文章中，我们将介绍如何在 Spring Boot 3 中集成 MinIO，搭建一个分布式文件存储系统，具体内容包括：

MinIO 的基本配置。
如何在 Spring Boot 中集成 MinIO。
实现文件上传、下载、删除等操作。

1. MinIO 简介

MinIO 是一个开源的对象存储服务，专为云原生应用和大数据存储场景设计。它支持 Amazon S3 API，因此可以与 S3 兼容的应用程序一起使用。它非常适合存储大量的对象数据，并提供高可用、高性能、分布式的存储服务。

MinIO 的核心功能包括：

存储对象数据。
支持分布式部署。
支持多种访问权限控制。
支持 S3 协议，兼容现有的 S3 客户端。

2. 搭建 MinIO 服务

首先，您需要在本地或服务器上搭建 MinIO 服务。可以通过 Docker 快速搭建 MinIO。

2.1 使用 Docker 搭建 MinIO

如果您已经安装了 Docker，可以使用以下命令启动 MinIO：

docker run -d -p 9000:9000 \
  -e "MINIO_ROOT_USER=minioadmin" \
  -e "MINIO_ROOT_PASSWORD=minioadmin" \
  --name minio \
  minio/minio server /data

MINIO_ROOT_USER 和 MINIO_ROOT_PASSWORD：设置 MinIO 的管理员账户。
minio/minio：MinIO 官方镜像。
/data：MinIO 存储数据的目录。

启动后，MinIO 服务会监听在 http://localhost:9000，您可以通过浏览器访问并使用管理员账户进行登录。

2.2 创建桶（Bucket）

使用 MinIO 浏览器，您可以创建一个或多个桶（Bucket），作为文件存储的容器。例如，可以创建一个名为 file-storage 的桶来存储上传的文件。

3. Spring Boot 3 集成 MinIO

3.1 引入 MinIO 依赖

在 Spring Boot 项目中，首先需要引入 MinIO 的依赖。可以通过 Maven 或 Gradle 方式引入 MinIO 客户端。

Maven 配置

在 pom.XML 文件中添加以下依赖：

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version&phpgt;8.3.3</version> <!-- 请根据需要使用最新版本 -->
</dependency>

Gradle 配置

在 build.gradle 文件中添加以下依赖：

implementation 'io.minio:minio:8.3.3' // 请根据需要使用最新版本

3.2 配置 MinIO 客户端

在 application.properties 或 application.yml 中配置 MinIO 连接参数：

application.properties

minio.url=http://localhost:9000
minio.Access-key=minioadmin
minio.secret-key=minioadmin
minio.bucket-name=file-storage

application.yml

minio:
  url: http://localhost:9000
  access-key: minioadmin
  secret-key: minioadmin
  bucket-name: file-storage

3.3 配置 MinIO 客户端 Bean

接下来，我们需要配置一个 MinIO 客户端 Bean，使其能够与 Spring Boot 的依赖注入机制配合工作。

import io.minio.MinioClient;
import io.minio.credentials.Provider;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MinioConfig {

    @Bean
    public MinioClient minioClient() {
        return MinioClient.builder()
                .endpoint("http://localhost:9000")
                .credentials("minioadmin", "minioadmin")
                .build();
    }
}

MinioClient.builder()：创建一个 MinIO 客户端。
.endpoint()：MinIO 服务的访问地址。
.credentials()：MinIO 的访问密钥和密钥。

4. 实现文件上传、下载和删除操作

4.1 文件上传

我们可以使用 MinIO 客户端的 putObject 方法将文件上传到 MinIO 的桶（Bucket）中。

import io.minio.MinioClient;
import io.minio.errors.MinioException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import Java.io.InputStream;

@Service
public class FileService {

    @Autowired
    private MinioClient minioClient;

    private static final String BUCKET_NAME = "file-storage"; // 存储桶名

    public void uploadFile(String fileName, InputStream fileInputStream, String contentType) throws MinioException {
        try {
            // 上传文件
            minioClient.putObject(
                    BUCKET_NAME,       // 桶名
                    fileName,          // 文件名
                    fileInputStream,   // 文件内容流
                    contentType        // 文件类型
            );
            System.out.println("File uploaded successfully.");
        } catch (Exception e) {
            throw new MinioException("Error uploading file: " + e.getMessage());
        }
    }
}

4.2 文件下载

可以使用 getObject 方法从 MinIO 下载文件：

import io.minio.MinioClient;
import io.minio.errors.MinioException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.InputStream;

@Service
public class FileService {

    @Autowired
    private MinioClient minioClient;

    private static final String BUCKET_NAME = "file-storage";

    public InputStream downloadFile(String fileName) throws MinioException {
        try {
            // 获取文件输入流
            return minioClient.getObject(BUCKET_NAME, fileName);
        } catch (Exception e) {
            throw new MinioException("Error downloading file: " + e.getMessage());
        }
    }
}

4.3 文件删除

删除文件同样可以通过 removeObject 方法来实现：

import io.minio.MinioClient;
import io.minio.errors.MinioException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class FileService {

    @Autowired
    private MinioClient minioClient;

    private static final String BUCKET_NAME = "file-storage";

    public void deleteFile(String fileName) throws MinioException {
        try {
            // 删除文件
            minioClient.removeObject(BUCKET_NAME, fileName);
            System.out.println("File deleted successfully.");
        } catch (Exception e) {
            throw new MinioException("Error deleting file: " + e.gjsetMessage());
        }
    }
}

5. 测试文件上传、下载和删除

可以通过以下代码进行测试：

import org.springframework.beans.factory.annotation.Autowired;
import org.spjsringframework.web.bind.annotation.*;

import java.io.InputStream;

@RestController
@RequestMapping("/files")
public class FileController {

    @Autowired
    private FileService fileService;

    @PostMapping("/upload")
    public String uploadFile(@RequestParam("file") InputStream fileInputStream,
                             @RequestParam("fileName") String fileName,
                             @RequestParam("contentType") String contentType) {
        try {
            fileService.uploadFile(fileName, fileInputStream, contentType);
            return "File uploaded successfully.";
        } catch (Exception e) {
            return "Error: " + e.getMessage();
        }
    }

    @GetMapping("/download/{fileName}")
    public String downloadFile(@PathVariable("fileName") String fileName) {
        try {
            InputStream fileStream = fileService.downloadFile(fileName);
            return "File downloaded successfully.";
        } catch (Exception e) {
            return "Error: " + e.getMessage();
        }
    }

    @Del编程客栈eteMapping("/delete/{fileName}")
    public String deleteFile(@PathVariable("fileName") String fileName) {
        try {
            fileService.deleteFile(fileName);
            return "File deleted successfully.";
        } catch (Exception e) {
            return "Error: " + e.getMessage();
        }
    }
}

5.1 测试文件上传

通过 POST 请求上传文件：

POST /files/upload
Content-Type: multipart/form-data
file: <fileInputStream>
fileName: "example.txt"
contentType: "text/plain"

5.2 测试文件下载

通过 GET 请求下载文件：

GET /files/download/example.txt

5.3 测试文件删除

通过 DELETE 请求删除文件：

DELETE /files/delete/example.txt

6. 小结

通过以上步骤，我们成功地将 MinIO 集成到 Spring Boot 项目中，实现了一个分布式文件存储系统，支持文件上传、下载和删除操作。MinIO 提供了高性能、可靠的对象存储服务，且与 S3 协议兼容，因此非常适合用于构建现代分布式应用的存储系统。

在实际生产环境中，您可以根据需要调整 MinIO http://www.devze.com配置，例如配置高可用部署、设置访问控制、使用加密等。此外，还可以扩展文件存储服务，例如添加文件缓存、支持更复杂的存储结构等。

以上就是SpringBoot3整合MinIO实现分布式文件存储系统的详细内容，更多关于SpringBoot3 MinIO文件存储的资料请关注编程客栈(www.devze.com)其它相关文章！

继续阅读：SpringBoot3 MinIO SpringBoot3 MinIO文件存储 SpringBoot3分布式文件存储 SpringBoot3文件存储

SpringBoot3整合MinIO实现分布式文件存储系统

目录

前言

1. MinIO 简介

2. 搭建 MinIO 服务

2.1 使用 Docker 搭建 MinIO

2.2 创建桶（Bucket）

3. Spring Boot 3 集成 MinIO

3.1 引入 MinIO 依赖

Maven 配置

Gradle 配置

3.2 配置 MinIO 客户端

application.properties

application.yml

3.3 配置 MinIO 客户端 Bean

4. 实现文件上传、下载和删除操作

4.1 文件上传

4.2 文件下载

4.3 文件删除

5. 测试文件上传、下载和删除

5.1 测试文件上传

5.2 测试文件下载

5.3 测试文件删除

6. 小结

更多精彩内容

精彩评论

最新开发

Java使用validation拦截非法提交的数据的方法实现

SpringBoot配置文件中常用配置属性详解(application.properties/application.yml)

Spring AI 框架中集成 MCP的方法

Spring4改造Dubbo实现注解配置兼容的完整指南

从零开始设计基于SpringBoot的Serverless(本地函数计算)引擎

开发排行榜

springboot后端存储富文本内容的思路与步骤(含图片内容)

PyCharm运行python测试,报错“没有发现测试”/“空套件”的解决

return base64.b64encode(b).decode(

基于C语言实现钻石棋游戏的示例代码

Sublime Text 3解决中文乱码问题（实测可用）