Minio对象存储及Springboot整合Minio分片上传文章-代码

package com.example.minio.common.utils; import cn.hutool.core.date.DateUtil; import com.example.minio.common.config.ParamConfig; import io.minio.*; import io.minio.http.Method; import io.minio.messages.Bucket; import io.minio.messages.DeleteObject; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import org.springframework.web.multipart.MultipartFile; import javax.annotation.PostConstruct; import java.io.InputStream; import java.util.Date; import java.util.List; import java.util.Optional; import java.util.stream.Stream; /** * @Author: HOUJL * @Date: 2023/2/14 * @Description: */ @Slf4j @Component public class MinIoUtil { public static MinioClient minioClient; public final ParamConfig paramConfig; public MinIoUtil(ParamConfig paramConfig) { this.paramConfig = paramConfig; } /** * 初始化minio配置 */ @PostConstruct public void init() { try { log.info("Minio Initialize........................"); minioClient = MinioClient.builder().endpoint(paramConfig.getEndpoint()).credentials(paramConfig.getAccessKey(), paramConfig.getSecretKey()).build(); createBucket(paramConfig.getBucketName()); log.info("Minio Initialize........................successful"); } catch (Exception e) { log.error("初始化minio配置异常: 【{}】", e.fillInStackTrace()); } } /****************************** Operate Bucket Start ******************************/ /** * 判断bucket是否存在 */ @SneakyThrows(Exception.class) public boolean bucketExists(String bucketName) { return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build()); } /** * 创建bucket */ @SneakyThrows(Exception.class) public void createBucket(String bucketName) { boolean isExist = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build()); if (!isExist) { minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build()); } } /** * 获取全部bucket */ @SneakyThrows(Exception.class) public List<Bucket> getAllBuckets() { return minioClient.listBuckets(); } /** * 根据bucketName获取其相关信息 * * @param bucketName * @return */ @SneakyThrows(Exception.class) public Optional<Bucket> getBucket(String bucketName) { return getAllBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst(); } /** * 根据bucketName删除Bucket，true：删除成功； false：删除失败，文件或已不存在 * * @param bucketName * @throws Exception */ @SneakyThrows(Exception.class) public void removeBucket(String bucketName) { minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build()); } /****************************** Operate Bucket End ******************************/ /** * 上传本地文件 * * @param bucketName 存储桶 * @param fileName 对象名称 * @param filePath 本地文件路径 * @return */ @SneakyThrows(Exception.class) public ObjectWriteResponse uploadFile(String bucketName, String fileName, String filePath) { return minioClient.uploadObject( UploadObjectArgs.builder() .bucket(bucketName) .object(fileName) .filename(filePath) .build()); } /** * 上传文件 * 返回可以直接预览文件的URL */ public String uploadFile(MultipartFile file) { try { //如果存储桶不存在则创建 if (!bucketExists(paramConfig.getBucketName())) { createBucket(paramConfig.getBucketName()); } String originalFilename = file.getOriginalFilename(); if ("".equals(originalFilename)) { originalFilename = file.getName(); } //保证文件不重名(并且没有特殊字符) String fileName = DateUtil.format(new Date(), "yyyyMMddHHmmss") + "_" + originalFilename; minioClient.putObject(PutObjectArgs.builder() .bucket(paramConfig.getBucketName()) .object(fileName) .stream(file.getInputStream(), file.getInputStream().available(), -1) .contentType(file.getContentType()) .build()); return getPreviewFileUrl(paramConfig.getBucketName(), fileName); } catch (Exception e) { log.error(e.getMessage(), e); return ""; } } @SneakyThrows(Exception.class) public String putFile(String bucketName, String fileName, InputStream stream) { return upload(bucketName, fileName, stream, "application/octet-stream"); } /** * 文件上传 * 返回下载文件url地址 和下面upload方法仅传参不同 * bucketName 也可以直接从ParamConfig对象中获取 */ @SneakyThrows(Exception.class) public String upload(String bucketName, String fileName, InputStream stream, String contentType) { minioClient.putObject(PutObjectArgs.builder() .bucket(bucketName) .object(fileName) .stream(stream, stream.available(), -1) .contentType(contentType) .build()); return getPreviewFileUrl(bucketName, fileName); } /** * 文件上传 * 返回下载文件url地址 和上面upload方法仅传参不同 */ @SneakyThrows(Exception.class) public String upload(String bucketName, MultipartFile file) { final InputStream is = file.getInputStream(); final String fileName = file.getOriginalFilename(); minioClient.putObject(PutObjectArgs.builder() .bucket(bucketName) .object(fileName) .stream(is, is.available(), -1) .contentType(file.getContentType()) .build()); is.close(); return getPreviewFileUrl(bucketName, fileName); } /** * 删除文件 * * @param bucketName: 桶名 * @param fileName: 文件名 */ @SneakyThrows(Exception.class) public void deleteFile(String bucketName, String fileName) { minioClient.removeObject( RemoveObjectArgs.builder() .bucket(bucketName) .object(fileName) .build()); } /** * 批量删除 * * @param fileNames */ @SneakyThrows(Exception.class) public void removeFiles(List<String> fileNames) { removeFiles(paramConfig.getBucketName(), fileNames); } /** * @param bucketName * @param fileNames */ @SneakyThrows(Exception.class) public void removeFiles(String bucketName, List<String> fileNames) { Stream<DeleteObject> stream = fileNames.stream().map(DeleteObject::new); minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(stream::iterator).build()); } /** * 获取minio文件的下载或者预览地址 * 取决于调用本方法的方法中的PutObjectOptions对象有没有设置contentType * * @param bucketName: 桶名 * @param fileName: 文件名 */ @SneakyThrows(Exception.class) public String getPreviewFileUrl(String bucketName, String fileName) { GetPresignedObjectUrlArgs args = GetPresignedObjectUrlArgs.bu