开源对象存储服务(MinIO)，正在备受欢迎！

原创作者，公众号【IT技术馆】，欢迎关注公众号，转载文章请注明出处哦。

MinIO是一个高性能、开源的对象存储服务器，兼容Amazon S3 API，非常适合用于存储大量非结构化数据。MinIO的轻量级设计使其专为云原生应用而优化，并支持分布式部署，提供高可用性和强一致性。以下是MinIO在Java中的使用详解及示例：

一、添加依赖

要在Java项目中使用MinIO，首先需要添加MinIO Java客户端库的依赖。如果你使用的是Maven，可以在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>最新版本号</version>
</dependency>

注意将“最新版本号”替换为MinIO Java客户端库的当前最新版本号。

二、初始化客户端

在Java代码中，通过以下方式初始化MinIO客户端：

import io.minio.MinioClient;

public class MinioExample {
   
    public static void main(String[] args) {
   
        try {
   
            MinioClient minioClient = MinioClient.builder()
                    .endpoint("http://localhost:9000") // 替换为你的MinIO服务器地址
                    .credentials("YOUR-ACCESS-KEY", "YOUR-SECRET-KEY") // 替换为你的Access Key和Secret Key
                    .build();
            // 使用minioClient进行操作
        } catch (Exception e) {
   
            e.printStackTrace();
        }
    }
}

三、基本操作示例

1. 创建桶

使用MinIO客户端创建一个新的桶：

import io.minio.MakeBucketArgs;
import io.minio.errors.MinioException;

public void createBucket(MinioClient minioClient, String bucketName) throws Exception {
   
    boolean found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
    if (!found) {
   
        minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
        System.out.println("Bucket created: " + bucketName);
    } else {
   
        System.out.println("Bucket already exists: " + bucketName);
    }
}

2. 上传对象

将文件上传到指定的桶中：

import io.minio.PutObjectArgs;
import java.io.File;
import java.io.FileInputStream;

public void uploadObject(MinioClient minioClient, String bucketName, String objectName, String filePath) throws Exception {
   
    minioClient.putObject(
            PutObjectArgs.builder()
                    .bucket(bucketName)
                    .object(objectName)
                    .stream(new FileInputStream(filePath), new File(filePath).length(), -1)
                    .contentType("application/octet-stream")
                    .build()
    );
    System.out.println("Object uploaded: " + objectName);
}

3. 下载对象

从桶中下载对象到本地文件：

import io.minio.GetObjectArgs;
import java.io.File;

public void downloadObject(MinioClient minioClient, String bucketName, String objectName, String destFilePath) throws Exception {
   
    minioClient.getObject(
            GetObjectArgs.builder()
                    .bucket(bucketName)
                    .object(objectName)
                    .build(),
            new File(destFilePath)
    );
    System.out.println("Object downloaded: " + objectName);
}

4. 删除对象

从桶中删除指定的对象：

import io.minio.RemoveObjectArgs;

public void deleteObject(MinioClient minioClient, String bucketName, String objectName) throws Exception {
   
    minioClient.removeObject(
            RemoveObjectArgs.builder()
                    .bucket(bucketName)
                    .object(objectName)
                    .build()
    );
    System.out.println("Object deleted: " + objectName);
}

四、高级功能

1. 设置桶策略

通过设置桶策略，可以控制对桶和对象的访问权限：

import io.minio.SetBucketPolicyArgs;
import java.nio.charset.StandardCharsets;

public void setBucketPolicy(MinioClient minioClient, String bucketName, String policy) throws Exception {
   
    minioClient.setBucketPolicy(
            SetBucketPolicyArgs.builder()
                    .bucket(bucketName)
                    .config(policy.getBytes(StandardCharsets.UTF_8))
                    .build()
    );
    System.out.println("Bucket policy set for: " + bucketName);
}

2. 使用预签名URL

预签名URL允许临时访问对象，无需暴露访问密钥。这个功能在需要分享文件但不想暴露服务器密钥时非常有用。

五、SpringBoot集成MinIO示例

在Spring Boot项目中，可以通过以下步骤集成MinIO：

1. 在pom.xml中添加MinIO依赖。
2. 在application.yml或application.properties中增加MinIO配置。
3. 创建一个配置类来获取MinIO客户端。
4. 编写一个工具类来封装对MinIO的操作。

以下是一个简单的Spring Boot集成MinIO的示例：

pom.xml：

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>最新版本号</version>
</dependency>

application.yml：

minio:
  endpoint: http://localhost:9000
  accesskey: YOUR-ACCESS-KEY
  secretkey: YOUR-SECRET-KEY

MinioConfig.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.endpoint}")
    private String endpoint;

    @Value("${minio.accesskey}")
    private String accesskey;

    @Value("${minio.secretkey}")
    private String secretkey;

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

MinioUtils.java：

import io.minio.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MinioUtils {
   

    @Autowired
    private MinioClient minioClient;

    // 封装创建桶、上传文件等操作的方法...
}

通过以上步骤，你就可以在Spring Boot项目中轻松地使用MinIO进行对象存储操作了。