SpringBoot项目中整合MinIO

简介: SpringBoot项目中整合MinIO。

在Spring Boot项目中整合MinIO,可以按照以下步骤进行操作:

1. 添加MinIO依赖

        <dependency>
            <groupId>io.minio</groupId>
            <artifactId>minio</artifactId>
            <version>8.5.9</version>
        </dependency>

2. 配置MinIO连接

minio:
  endpoint: http://127.0.0.1:9000        #MinIO资源地址
  accessKey: minioadmin                  #访问key
  secretKey: minioadmin                  #访问密钥
  bucketName: test                       #存储桶名称

3. 创建MinIO配置类

@Data
@Configuration
public class MinioConfig  {
   

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

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

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

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

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

4. 创建MinIO工具类


@Component
public class MinioUtil {
   

    @Autowired
    private MinioClient minioClient;

    @Autowired
    private MinioConfig minioConfig;

    /**
     * 创建存储bucket
     *
     * @param bucketName 存储bucket名称
     * @return Boolean
     */
    public boolean makeBucket(String bucketName) {
   
        try {
   
            minioClient.makeBucket(MakeBucketArgs.builder()
                    .bucket(bucketName)
                    .build());
            return true;
        } catch (Exception e) {
   
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 删除存储bucket
     *
     * @param bucketName 存储bucket名称
     * @return Boolean
     */
    public boolean removeBucket(String bucketName) {
   
        try {
   
            minioClient.removeBucket(RemoveBucketArgs.builder()
                    .bucket(bucketName)
                    .build());
            return true;
        } catch (Exception e) {
   
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 查看存储bucket是否存在
     *
     * @param bucketName
     * @return
     */
    public boolean bucketExists(String bucketName) {
   
        try {
   
            return minioClient.bucketExists(BucketExistsArgs
                    .builder()
                    .bucket(bucketName)
                    .build());
        } catch (Exception e) {
   
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 文件上传
     *
     * @param objectName 对象名称
     * @param file       文件
     * @return
     */
    public String uploadFile(String objectName, MultipartFile file) {
   
        try {
   
            InputStream stream = file.getInputStream();
            PutObjectArgs putObjectArgs = PutObjectArgs.builder()
                    .bucket(minioConfig.getBucketName())
                    .object(objectName)
                    .contentType(file.getContentType())
                    .stream(file.getInputStream(), file.getSize(), -1)
                    .build();
            minioClient.putObject(putObjectArgs);
            stream.close();

            return "%s/%s/%s".formatted(minioConfig.getEndpoint(), minioConfig.getBucketName(), objectName);
        } catch (Exception e) {
   
            e.printStackTrace();
        }
        return "";
    }

    /**
     * 获取对象url
     *
     * @param objectName 对象名称
     * @return
     */
    public String getObjectUrl(String objectName) {
   
        try {
   
            return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
                    .method(Method.GET)
                    .bucket(minioConfig.getBucketName())
                    .object(objectName)
                    .build());
        } catch (Exception e) {
   
            e.printStackTrace();
        }
        return null;
    }

}

5. 控制器操作


@RestController
@RequestMapping("/api/file")
public class FileController {
   

    @Autowired
    private MinioUtil minioUtil;

    /**
     * 创建存储bucket
     *
     * @param bucketName
     * @return
     */
    @PostMapping("makeBucket")
    public Object makeBucket(String bucketName) {
   
        var success = minioUtil.makeBucket(bucketName);
        Map<String, Object> map = new HashMap<>();
        map.put("success", success);
        return map;
    }

    /**
     * 删除存储bucket
     *
     * @param bucketName
     * @return
     */
    @PostMapping("removeBucket")
    public Object removeBucket(String bucketName) {
   
        var success = minioUtil.removeBucket(bucketName);
        Map<String, Object> map = new HashMap<>();
        map.put("success", success);
        return map;
    }

    /**
     * 查看存储bucket是否存在
     *
     * @param bucketName
     * @return
     */
    @GetMapping("bucketExists")
    public Object bucketExists(String bucketName) {
   
        var success = minioUtil.bucketExists(bucketName);
        Map<String, Object> map = new HashMap<>();
        map.put("success", success);
        return map;
    }

    /**
     * 文件上传
     *
     * @param file
     * @return
     */
    @PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
    public Object uploadFile(@RequestParam("file") MultipartFile file) {
   
        String fileName = file.getOriginalFilename();
        var fileUrl = minioUtil.uploadFile(fileName, file);
        Map<String, Object> map = new HashMap<>();
        map.put("success", true);
        map.put("data", fileUrl);
        return map;
    }

    /**
     * 获取对象url
     *
     * @param objectName
     * @return
     */
    @GetMapping("getObjectUrl")
    public Object getObjectUrl(String objectName) {
   
        var fileUrl = minioUtil.getObjectUrl(objectName);
        Map<String, Object> map = new HashMap<>();
        map.put("success", true);
        map.put("data", fileUrl);
        return map;
    }
}
目录
相关文章
|
7月前
|
存储 前端开发 Java
spring boot 实现Minio分片上传
spring boot 实现Minio分片上传
578 1
|
存储 Kubernetes Java
SpringBoot整合MinIO
MinIO是一款基于Go语言开发的高性能、分布式的对象存储系统,开源可商用。一开始就被设计为服务于私有云、公有云、混合云,因此在高可用、可扩展性、高性能方面有得天独厚的优势。 MinIO完全实现了AWS S3 标准,在日常使用、扩展升级、迁移方面更易于管理,对于上层应用程序来说,存储和访问对象是统一的,即使MinIO服务迁移了,应用程序侧是无感知的。 MinIO分三个版本,开源版、标准版、企业版,开源版本免费使用,后面两个为付费产品。MinIO支持多种部署环境:Kubernetes、Docker、Linux、MacOS、Windows
479 1
SpringBoot整合MinIO
|
7月前
|
JavaScript 前端开发 Java
springboot整合minio+vue实现大文件分片上传,断点续传(复制可用,包含minio工具类)
springboot整合minio+vue实现大文件分片上传,断点续传(复制可用,包含minio工具类)
1740 0
|
7月前
|
Java Docker Windows
spring boot整合Minio
spring boot整合Minio
141 0
|
存储 Java Maven
如何使用Spring Boot和MinIO实现文件上传、读取、下载和删除的功能?
如何使用Spring Boot和MinIO实现文件上传、读取、下载和删除的功能?
1336 5
|
2月前
|
XML Java API
SpringBoot 整合 Minio
本文介绍了如何在服务器上安装并配置Minio服务,包括Minio的依赖、配置类以及基本操作。首先,通过Maven添加Minio依赖;接着,在`yml`文件中配置Minio的连接信息;然后,创建`MinIoClientConfig`类将MinioClient注入到Spring容器中;最后,定义`OSSFileService`接口及其实现类`OssFileServiceImpl`,实现文件上传、获取文件URL、临时访问URL和删除文件等操作。
|
2月前
|
XML Java Kotlin
springboot + minio + kkfile实现文件预览
本文介绍了如何在容器中安装和启动kkfileviewer,并通过Spring Boot集成MinIO实现文件上传与预览功能。首先,通过下载kkfileviewer源码并构建Docker镜像来部署文件预览服务。接着,在Spring Boot项目中添加MinIO依赖,配置MinIO客户端,并实现文件上传与获取预览链接的接口。最后,通过测试验证文件上传和预览功能的正确性。
springboot + minio + kkfile实现文件预览
|
23天前
|
存储 前端开发 JavaScript
|
23天前
|
存储 Java API
|
2月前
|
存储 前端开发 Java
springboot整合最新版minio和minio的安装(完整教程,新人必看)
本文详细介绍了如何使用Docker安装配置最新版的MinIO,并展示了如何在Spring Boot应用中整合MinIO以及如何通过前端进行文件上传测试。
221 3
springboot整合最新版minio和minio的安装(完整教程,新人必看)