Spring Boot 3 如何整合 MinIO 实现分布式文件存储？

发布于：2025-07-27 ⋅ 阅读:(15) ⋅ 点赞:(0)

全文目录：

开篇语

哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛

  今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。

  我是一名后端开发爱好者，工作日常接触到最多的就是Java语言啦，所以我都尽量抽业余时间把自己所学到所会的，通过文章的形式进行输出，希望以这种方式帮助到更多的初学者或者想入门的小伙伴们，同时也能对自己的技术进行沉淀，加以复盘，查缺补漏。

小伙伴们在批阅的过程中，如果觉得文章不错，欢迎点赞、收藏、关注哦。三连即是对作者我写作道路上最好的鼓励与支持！

前言

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

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

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

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>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.getMessage());
        }
    }
}

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

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

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.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();
        }
    }

    @DeleteMapping("/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 配置，例如配置高可用部署、设置访问控制、使用加密等。此外，还可以扩展文件存储服务，例如添加文件缓存、支持更复杂的存储结构等。

… …

文末

好啦，以上就是我这期的全部内容，如果有任何疑问，欢迎下方留言哦，咱们下期见。

… …

学习不分先后，知识不分多少；事无巨细，当以虚心求教；三人行，必有我师焉！！！

wished for you successed ！！！

⭐️若喜欢我，就请关注我叭。

⭐️若对您有用，就请点赞叭。
⭐️若有疑问，就请评论留言告诉我叭。

版权声明：本文由作者原创，转载请注明出处，谢谢支持！

网站公告

今日签到

点亮在社区的每一天
去签到

热门文章

最新发布