Spring Boot集成MinIO

程序浅谈后端 2024-12-02

Spring Boot集成MinIO

在Spring Boot项目中集成MinIO（一个高性能的分布式对象存储服务）是一个相对简单的过程。以下是一个详细的步骤指南，帮助你完成这个集成。

1. 引入依赖

在你的Spring Boot项目中，你需要在pom.xml中添加MinIO的依赖。如果你使用的是Maven，可以添加如下依赖：xml

 代码解读
复制代码
<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.4.0</version> <!-- 确保使用最新版本 -->
</dependency>

2. 配置MinIO属性

在application.properties或application.yml中，添加MinIO的配置参数：properties

 代码解读
复制代码
minio.url=http://localhost:9000  # MinIO服务的URL
minio.access-key=YOUR_ACCESS_KEY  # 替换为你的Access Key
minio.secret-key=YOUR_SECRET_KEY  # 替换为你的Secret Key
minio.bucket-name=YOUR_BUCKET_NAME  # 替换为你的桶名

3. 创建MinIO配置类

你可以创建一个配置类，用于初始化MinIO客户端：java

 代码解读
复制代码
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.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()
                .endpoint(minioUrl)
                .credentials(accessKey, secretKey)
                .build();
    }
}

4. 创建服务类

接下来，你可以创建一个服务类来处理文件的上传和下载等操作：java

 代码解读
复制代码
import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import io.minio.GetObjectArgs;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.InputStream;
import java.nio.file.Files;
import java.nio.file.Path;

@Service
public class MinioService {

    @Autowired
    private MinioClient minioClient;

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

    public void uploadFile(String objectName, InputStream inputStream, long size) throws Exception {
        minioClient.putObject(
                PutObjectArgs.builder()
                        .bucket(bucketName)
                        .object(objectName)
                        .stream(inputStream, size, -1)
                        .build()
        );
    }

    public InputStream downloadFile(String objectName) throws Exception {
        return minioClient.getObject(
                GetObjectArgs.builder()
                        .bucket(bucketName)
                        .object(objectName)
                        .build()
        );
    }
}

5. 使用服务类

在你的控制器中，你可以使用刚刚创建的MinioService类来进行文件上传和下载操作：java

 代码解读
复制代码
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 MinioService minioService;

    @PostMapping("/upload")
    public String uploadFile(@RequestParam("file") InputStream inputStream,
                             @RequestParam("name") String name,
                             @RequestParam("size") long size) throws Exception {
        minioService.uploadFile(name, inputStream, size);
        return "File uploaded successfully.";
    }

    @GetMapping("/download/{name}")
    public InputStream downloadFile(@PathVariable String name) throws Exception {
        return minioService.downloadFile(name);
    }
}