package com.example.minio.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;


@Component
@Data
@ConfigurationProperties(prefix = "minio")
public class MinioProperties {
    private String endpoint;
    private String accessKey;
    private String secretKey;
    private String bucketName;

}

package com.example.minio.config;


import com.example.minio.properties.MinioProperties;
import com.example.minio.utils.MinioUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@Slf4j
public class MinioConfig {
    @Bean
    @ConditionalOnMissingBean
    public MinioUtils minioUtils(MinioProperties minioProperties) {
        log.info("开始创建工具类对象:{}", minioProperties);
        return new MinioUtils(minioProperties.getEndpoint(),
                minioProperties.getAccessKey(),
                minioProperties.getSecretKey(),
                minioProperties.getBucketName());
    }
}

package com.example.minio.utils;

import com.example.minio.config.MinioConfig;
import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import java.io.InputStream;



@Slf4j
@AllArgsConstructor
@Data
public class MinioUtils {
    private String endpoint;
    private String accessKey;
    private String secretKey;
    private String bucketName;

    public String upload(String objectName, InputStream inputStream) {
        try {
            MinioClient minioClient = MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();
            minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(inputStream, inputStream.available(), -1).build());
            log.info("上传文件成功");
            String URL = endpoint + "/" + bucketName + "/" + objectName;
            return URL;
        }catch (Exception e) {
            log.error("上传文件失败");
            e.printStackTrace();
        }
        return null;

    }


}

package com.example.minio.Controller;

import com.example.minio.utils.MinioUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import java.util.UUID;

@RestController
public class Controller {
    @Autowired
    private MinioUtils minioUtils;

    @PostMapping("/upload")
    public String updateFile(@RequestParam("file") MultipartFile inputStream) throws Exception {
        UUID uuid = UUID.randomUUID();
        String objectName = uuid.toString();
        String originalFilename = inputStream.getOriginalFilename();
        objectName = objectName+originalFilename.substring(originalFilename.lastIndexOf("."));
        String url = minioUtils.upload(objectName, inputStream.getInputStream());
        return url;
    }
}

@SpringBootTest
class DemoApplicationTests {
    @Autowired
    private service service;
    @Autowired
    private MinioClient minioClient;

    @Test
    void contextLoads() {
        service.testMinio();
    }

    /*测试是否存在某个bucket*/
    @Test
    void testMinio() throws Exception {
        boolean file = minioClient.bucketExists(BucketExistsArgs.builder().bucket("file").build());
        System.out.println(file);
    }

    /*创建bucket*/
    @Test
    void test2() throws Exception {
        boolean file = minioClient.bucketExists(BucketExistsArgs.builder().bucket("file").build());
        if (!file) {
            minioClient.makeBucket(MakeBucketArgs.builder().bucket("file").build());
        } else {
            System.out.println("bucket已经存在");
        }

    }

    /*列出所有bucket*/
    @Test
    void test3() throws Exception {
        List<Bucket> buckets = minioClient.listBuckets();
        for (Bucket bucket : buckets) {
            System.out.println(bucket.name() + "---" + bucket.creationDate());
        }
    }

    /*删除bucket*/
    @Test
    void test4() throws Exception {
        minioClient.removeBucket(RemoveBucketArgs.builder().bucket("file").build());
    }

    //插入图片
    @Test
    void test5() throws Exception {
        File file = new File("C:\\Users\\DREAMXIAOSHEN\\Downloads\\bc.png");
        minioClient.putObject(PutObjectArgs.builder()
                .bucket("file")
                .object("first.jpg")
                .stream(new FileInputStream(file), file.length(), -1)
                .build());


    }

    /*判断文件是否存在*/
    @Test
    void test6() throws Exception {
        StatObjectResponse file = minioClient.statObject(StatObjectArgs.builder().
                bucket("file").object("first.jpg").build()
        );
        System.out.println(file);
    }