MinIO#

package com.upda.miniodemo.config;

import io.minio.MinioClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author luguosong
 */
@Configuration
public class Config {

    @Bean
    public MinioClient minioClient() {
        return MinioClient.builder()
                .endpoint("http://127.0.0.1:9000")
                .credentials("minioadmin", "minioadmin")
                .build();
    }
}

package com.upda.miniodemo;

import io.minio.*;
import io.minio.errors.*;
import io.minio.messages.Bucket;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.util.List;

/**
 * @author luguosong
 */
@SpringBootTest
public class BucketTest {

    @Resource
    private MinioClient minioClient;

    /*
     * 判断Bucket是否存在
     * */
    @Test
    void isBucketExist() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        boolean exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket("test-bucket").build());
        System.out.println(exists);
    }


    /*
     * 创建Bucket
     * */
    @Test
    void createBucket() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        boolean exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket("test-bucket").build());
        if (!exists) {
            // 创建Bucket
            minioClient.makeBucket(MakeBucketArgs.builder().bucket("test-bucket").build());

        } else {
            System.out.println("Bucket已存在");
        }
    }

    /*
    * 自定义Bucket策略
    * */
    @Test
    void setBucketPolicy() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        // 自定义Bucket策略
        String policyJson = "{\n" +
                "  \"Statement\": [\n" +
                "    {\n" +
                "      \"Action\": [\n" +
                "        \"s3:GetBucketLocation\",\n" +
                "        \"s3:ListBucket\"\n" +
                "      ],\n" +
                "      \"Effect\": \"Allow\",\n" +
                "      \"Principal\": \"*\",\n" +
                "      \"Resource\": \"arn:aws:s3:::test-bucket\"\n" +
                "    },\n" +
                "    {\n" +
                "      \"Action\": \"s3:GetObject\",\n" +
                "      \"Effect\": \"Allow\",\n" +
                "      \"Principal\": \"*\",\n" +
                "      \"Resource\": \"arn:aws:s3:::test-bucket/myobject*\"\n" +
                "    }\n" +
                "  ],\n" +
                "  \"Version\": \"2012-10-17\"\n" +
                "}";

        minioClient.setBucketPolicy(
                SetBucketPolicyArgs
                        .builder()
                        .bucket("test-bucket")
                        .config(policyJson)
                        .build());
    }

    /*
     * 遍历Bucket
     * */
    @Test
    void listBucket() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        List<Bucket> list = minioClient.listBuckets();
        list.forEach(bucket -> System.out.println(bucket.name()));
    }

    /*
     * 删除Bucket
     * */
    @Test
    void removeBucket() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        minioClient.removeBucket(RemoveBucketArgs.builder().bucket("test-bucket").build());
    }
}

package com.upda.miniodemo;

import io.minio.*;
import io.minio.errors.*;
import io.minio.http.Method;
import io.minio.messages.Item;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.util.concurrent.TimeUnit;

/**
 * @author luguosong
 */
@SpringBootTest
public class ObjectTest {

    @Resource
    private MinioClient minioClient;


    /*
     * 判断文件是否存在
     *
     * 如果文件不存在，会抛出异常
     * */
    @Test
    void isExist() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        StatObjectResponse response = minioClient.statObject(StatObjectArgs.builder().
                bucket("test-bucket").
                object("sample.txt").build());
        System.out.println(response);
    }

    /*
     * 文件上传
     * */
    @Test
    void putObject() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        File file = new File(getClass().getClassLoader().getResource("sample.txt").getFile());
        minioClient.putObject(PutObjectArgs.builder()
                .bucket("test-bucket")
                .object("sample.txt")
                .stream(new FileInputStream(file), file.length(), -1)
                .build());
    }

    /*
     * 获取文件访问路径
     * */
    @Test
    void getFilePath() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        //获取对象的预签名 URL 用于 HTTP 方法、到期时间和自定义请求参数。
        String url = minioClient.getPresignedObjectUrl(
                GetPresignedObjectUrlArgs.builder()
                        .bucket("test-bucket") //桶
                        .object("sample.txt") //文件名
                        .expiry(3, TimeUnit.MINUTES) //设置链接有效时间为3分钟
                        .method(Method.GET) // GET 方法
                        .build());
        System.out.println(url);
    }

    /*下载文件
     * */
    @Test
    void getFile() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        GetObjectResponse response = minioClient.getObject(
                GetObjectArgs
                        .builder()
                        .bucket("test-bucket")
                        .object("sample.txt")
                        .build());
        response.transferTo(new FileOutputStream("./sample_download.txt"));
    }

    /*
     * 遍历文件
     * */
    @Test
    void listObject() {
        Iterable<Result<Item>> listObjects = minioClient.listObjects(
                ListObjectsArgs.builder()
                        .bucket("test-bucket")
                        .build());

        listObjects.forEach(itemResult -> {
            Item item = null;
            try {
                item = itemResult.get();
                System.out.println(item.objectName());
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        });
    }

    /*
     * 删除文件
     * */
    @Test
    void removeObject() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
        minioClient.removeObject(
                RemoveObjectArgs
                        .builder()
                        .bucket("test-bucket")
                        .object("sample.txt")
                        .build());
    }

}