SpringBoot整合MinIO实现文件存储系统的代码示例

xmlCopy code
<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>RELEASE.2022-05-19T03-37-25Z</version>
</dependency>

propertiesCopy code
# MinIO连接信息
minio.url=http://localhost:9000
minio.accessKey=minio-access-key
minio.secretKey=minio-secret-key

javaCopy code
@Configuration
public class MinIOConfig {
    @Value("${minio.url}")
    private String minioUrl;
    @Value("${minio.accessKey}")
    private String accessKey;
    @Value("${minio.secretKey}")
    private String secretKey;
    @Bean
    public MinioClient minioClient() {
        return MinioClient.builder()
                .endpoint(minioUrl)
                .credentials(accessKey, secretKey)
                .build();
    }
}

javaCopy code
@Service
public class FileStorageService {
    private final MinioClient minioClient;
    private final String bucketName = "my-bucket";
    public FileStorageService(MinioClient minioClient) {
        this.minioClient = minioClient;
    }
    public void storeFile(MultipartFile file) {
        try {
            String objectName = UUID.randomUUID().toString() + "-" + file.getOriginalFilename();
            minioClient.putObject(
                    PutObjectArgs.builder()
                            .bucket(bucketName)
                            .object(objectName)
                            .stream(file.getInputStream(), file.getSize(), -1)
                            .contentType(file.getContentType())
                            .build());
        } catch (Exception e) {
            // 处理异常
        }
    }
}

javaCopy code
@Service
public class FileStorageService {
    // ...
    public Resource getFile(String objectName) {
        try {
            InputStream stream = minioClient.getObject(
                    GetObjectArgs.builder()
                            .bucket(bucketName)
                            .object(objectName)
                            .build());
            return new InputStreamResource(stream);
        } catch (Exception e) {
            // 处理异常
        }
    }
}

javaCopy code
@Service
public class FileStorageService {
    // ...
    public void deleteFile(String objectName) {
        try {
            minioClient.removeObject(
                    RemoveObjectArgs.builder()
                            .bucket(bucketName)
                            .object(objectName)
                            .build());
        } catch (Exception e) {
            // 处理异常
        }
    }
}