SpringBoot 集成 MinIO 文件服务器配置与使用

SpringBoot 集成 MinIO 文件服务器配置与使用 | 极客日志

方案类型	突出差异化特点	适用场景
MinIO（分布式对象存储）	1. 轻量极致：单机部署仅需单个二进制文件； 2. S3 协议完美兼容：无缝对接 AWS 生态； 3. 纠删码轻量化实现：同等冗余级别下硬件成本低； 4. 云原生无缝适配：Docker/K8s 一键部署	1. 云原生/容器化环境下的文件存储； 2. 需私有部署且追求低硬件成本的分布式存储； 3. 需对接 S3 生态或未来可能迁移至 AWS 的业务； 4. 大文件高并发上传下载场景
本地存储（DAS 架构）	1. 零门槛部署：直接复用服务器本地硬盘； 2. 无网络开销：文件读写延迟极低； 3. 成本趋近于零	1. 开发/测试环境临时文件存储； 2. 单机版应用本地数据存储； 3. 非核心业务的日志、缓存等临时数据存储
NAS（网络附加存储）	1. 开箱即用：专用硬件 + 预制系统； 2. 多终端跨系统兼容； 3. 一体化文件管理	1. 企业内部团队办公文件协作； 2. 家庭/小型办公多媒体集中存储； 3. 中小型企业固定容量的文件归档与共享
公有云对象存储	1. 零运维负担：硬件维护、容灾备份全由厂商负责； 2. 无限弹性扩容； 3. 增值服务丰富	1. 无专业 IT 运维团队的中小企业； 2. 流量波动大的文件存储； 3. 需全球访问的内容分发场景
分布式文件系统	1. 统一存储池：整合多品牌、多规格服务器存储资源； 2. POSIX 接口兼容； 3. 极致扩展性	1. 大型企业数据中心统一存储平台； 2. 大数据分析/AI 训练场景； 3. 需保留复杂目录结构的分布式存储场景

@echo off
chcp 65001 > nul
echo 正在启动 MinIO 服务...
cd D:\Develop\Env\MinIO\bin
minio.exe server D:\Develop\Env\MinIO\data --console-address ":9001"
pause

<!-- MinIO 官方 Java SDK -->
<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.5.6</version>
</dependency>
<!-- 用于文件流处理的工具类 -->
<dependency>
    <groupId>commons-io</groupId>
    <artifactId>commons-io</artifactId>
    <version>2.11.0</version>
</dependency>

spring:
  minio:
    endpoint: http://localhost:9000
    access-key: minioadmin
    secret-key: minioadmin
    bucket-name: test-bucket
    base-url: http://localhost:9000/test-bucket/

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("${spring.minio.endpoint}")
    private String endpoint;

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

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

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

import io.minio.*;
import io.minio.http.Method;
import io.minio.messages.Bucket;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.concurrent.TimeUnit;

@Component
public class MinioUtil {
    @Autowired
    private MinioClient minioClient;

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

    @Value("${spring.minio.base-url}")
    private String baseUrl;

    public void createBucket(String bucketName) throws Exception {
        if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
        }
    }

    public String uploadFile(MultipartFile file, String bucketName) throws Exception {
        if (bucketName == null || bucketName.isEmpty()) {
            bucketName = defaultBucket;
        }
        createBucket(bucketName);
        String originalFilename = file.getOriginalFilename();
        String fileName = "upload/" + System.currentTimeMillis() + "_" + originalFilename;
        minioClient.putObject(
                PutObjectArgs.builder()
                        .bucket(bucketName)
                        .object(fileName)
                        .stream(file.getInputStream(), file.getSize(), -1)
                        .contentType(file.getContentType())
                        .build());
        return baseUrl + fileName;
    }

    public InputStream downloadFile(String fileName, String bucketName) throws Exception {
        if (bucketName == null || bucketName.isEmpty()) {
            bucketName = defaultBucket;
        }
        return minioClient.getObject(
                GetObjectArgs.builder()
                        .bucket(bucketName)
                        .object(fileName)
                        .build());
    }

    public void deleteFile(String fileName, String bucketName) throws Exception {
        if (bucketName == null || bucketName.isEmpty()) {
            bucketName = defaultBucket;
        }
        minioClient.removeObject(
                RemoveObjectArgs.builder()
                        .bucket(bucketName)
                        .object(fileName)
                        .build());
    }

    public List<Bucket> getBucketList() throws Exception {
        return minioClient.listBuckets();
    }

    public String getPresignedUrl(String fileName, String bucketName, int expireSeconds) throws Exception {
        if (bucketName == null || bucketName.isEmpty()) {
            bucketName = defaultBucket;
        }
        return minioClient.getPresignedObjectUrl(
                GetPresignedObjectUrlArgs.builder()
                        .method(Method.GET)
                        .bucket(bucketName)
                        .object(fileName)
                        .expiry(expireSeconds, TimeUnit.SECONDS)
                        .build());
    }
}

import org.apache.commons.io.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
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 MinioUtil minioUtil;

    @PostMapping("/upload")
    public String uploadFile(@RequestParam("file") MultipartFile file) {
        try {
            return minioUtil.uploadFile(file, null);
        } catch (Exception e) {
            return "上传失败：" + e.getMessage();
        }
    }

    @GetMapping("/download")
    public ResponseEntity<byte[]> downloadFile(@RequestParam("fileName") String fileName) {
        try {
            InputStream in = minioUtil.downloadFile(fileName, null);
            byte[] bytes = IOUtils.toByteArray(in);
            HttpHeaders headers = new HttpHeaders();
            headers.setContentDispositionFormData("attachment", new String(fileName.getBytes("UTF-8"), "ISO-8859-1"));
            headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
            return new ResponseEntity<>(bytes, headers, HttpStatus.OK);
        } catch (Exception e) {
            return ResponseEntity.status(500).body(("下载失败：" + e.getMessage()).getBytes());
        }
    }

    @DeleteMapping("/delete")
    public String deleteFile(@RequestParam("fileName") String fileName) {
        try {
            minioUtil.deleteFile(fileName, null);
            return "删除成功";
        } catch (Exception e) {
            return "删除失败：" + e.getMessage();
        }
    }

    @GetMapping("/getUrl")
    public String getFileUrl(@RequestParam("fileName") String fileName) {
        try {
            return minioUtil.getPresignedUrl(fileName, null, 3600);
        } catch (Exception e) {
            return "获取链接失败：" + e.getMessage();
        }
    }
}

SpringBoot 集成 MinIO 文件服务器配置与使用

一、MinIO 是什么？

二、MinIO 的核心定位：不止是'文件服务器'

三、MinIO 的核心特性（为什么适合当文件服务器？）

四、MinIO 适用场景界定

五、MinIO 与主流存储方案的对比分析

六、Windows 环境下 MinIO 部署与配置

1. 下载 MinIO

2. 启动 MinIO

3. 汉化操作

4. MinIO 核心概念解析

5. MinIO 基础操作指南（Web 控制台）

七、SpringBoot 集成 MinIO

1. 引入 Maven

2. 配置 MinIO 连接信息

3. 创建 MinIO 客户端配置类

4. 封装 MinIO 工具类

5. 编写测试接口

6. 测试验证

更多推荐文章

相关免费在线工具

SpringBoot 集成 MinIO 文件服务器配置与使用

一、MinIO 是什么？

二、MinIO 的核心定位：不止是'文件服务器'

三、MinIO 的核心特性（为什么适合当文件服务器？）

四、MinIO 适用场景界定

五、MinIO 与主流存储方案的对比分析

六、Windows 环境下 MinIO 部署与配置

1. 下载 MinIO

2. 启动 MinIO

3. 汉化操作

4. MinIO 核心概念解析

5. MinIO 基础操作指南（Web 控制台）

七、SpringBoot 集成 MinIO

1. 引入 Maven

2. 配置 MinIO 连接信息

3. 创建 MinIO 客户端配置类

4. 封装 MinIO 工具类

5. 编写测试接口

6. 测试验证

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具