SpringBoot使用Minio进行文件存储的实现

时间：2022-07-26 09:55:51

本文主要介绍了SpringBoot使用Minio进行文件存储的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧！

一、minio

MinIO 是一个高性能的对象存储原生支持 Kubernetes 部署的解决方案。 MinIO 提供了一个 Amazon Web Services S3 兼容 API 并支持所有核心 S3 功能。

MinIO 对象存储使用 buckets 来组织对象。存储桶类似于文件系统中的文件夹或目录，其中每个桶可以容纳任意数量的对象。 MinIO 存储桶提供与 AWS S3 存储桶相同的功能。

其中 MinIO 的优势有：

高性能：

MinIO是全球领先的对象存储先锋，在标准硬件上，读/写速度上高达183 GB / 秒 和 171 GB / 秒。

可扩展性：

MinIO利用了web缩放器的来之不易的知识，为对象存储带来了简单的存储缩放模型，在 MinIO, 扩展从单个群集开始，该群集可以与其他MinIO群集联合以创建全局名称空间, 并在需要时可以跨越多个不同的数据中心。通过添加更多集群可以扩展名称空间, 更多机架，直到实现目标。

云原生支持：

MinIO 是在过去4年的时间内从0开始打造的一款软件，符合一切原生云计算的架构和构建过程，并且包含最新的云计算的全新的技术和概念。其中包括支持Kubernetes 、微服和多租户的的容器技术。使对象存储对于 Kubernetes更加友好。

源码开放与企业级支持：

MinIO 基于Apache V2 license 100% 开放源代码。这就意味着 MinIO的客户能够自动的、无限制、自由免费使用和集成MinIO、自由的创新和创造、自由的去修改、自由的再次发行新的版本和软件. 确实, MinIO 强有力的支持和驱动了很多世界500强的企业。此外，其部署的多样性和专业性提供了其他软件无法比拟的优势。

官方文档地址：http://docs.minio.org.cn/minio/baremetal/

在实验开始前请确保安装完成了 minio ：

二、SpringBoot 使用 Minio 进行文件存储

首先新建一个 SpringBoot 项目，在 pom 中引入 minio 依赖：

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

在配置文件中，声明出 minio 的信息：

minio:
  url: http://192.168.40.169:9000   # minio配置的地址，端口9000,注意不是控制台的端口
  accessKey: minioadmin   # 账号
  secretKey: minioadmin   # 密码
  bucketName: test-bucket  # MinIO桶名字

下面创建一个配置类，对 MinioClient 进行创建：

@Data
@Configuration
@ConfigurationProperties(prefix = "minio")
public class MinioConfig {
/**
 * 服务地址
 */
private String url;
 
/**
 * 用户名
 */
private String accessKey;
 
/**
 * 密码
 */
private String secretKey;
 
/**
 * 存储桶名称
 */
private String bucketName;

@Bean
public MinioClient getMinioClient() throws Exception {
MinioClient minioClient = MinioClient.builder().endpoint(url).credentials(accessKey, secretKey).build();
//判断桶是否存在，不存在则新建
if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())){
minioClient.makeBucket(MakeBucketArgs.builder()
.bucket(bucketName)
.build());
}
return minioClient;
}
}

下面创建一个工具类 MinioTool 将常用的操作封装在工具类中：

@Component
public class MinioTool {

@Autowired
private MinioClient minioClient;

@Autowired
private MinioConfig minioConfig;
 
/**
 * 查看存储bucket是否存在
 *
 * @param bucketName 存储bucket
 * @return boolean
 */
public Boolean bucketExists(String bucketName) {
Boolean found;
try {
found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return found;
}
 
/**
 * 创建存储bucket
 *
 * @param bucketName 存储bucket名称
 * @return Boolean
 */
public Boolean makeBucket(String bucketName) {
try {
minioClient.makeBucket(MakeBucketArgs.builder()
.bucket(bucketName)
.build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
 
/**
 * 删除存储bucket
 *
 * @param bucketName 存储bucket名称
 * @return Boolean
 */
public Boolean removeBucket(String bucketName) {
try {
minioClient.removeBucket(RemoveBucketArgs.builder()
.bucket(bucketName)
.build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}

/**
 * 查看文件对象
 *
 * @param bucketName 存储bucket名称
 * @return 存储bucket内文件对象信息
 */
public Iterable<Result<Item>> listObjects(String bucketName) {
Iterable<Result<Item>> results = minioClient.listObjects(
ListObjectsArgs.builder().bucket(bucketName).build());
return results;
}

/**
 * 批量删除文件对象
 *
 * @param bucketName 存储bucket名称
 * @param objects对象名称集合
 */
public Iterable<Result<DeleteError>> removeObjects(String bucketName, List<String> objects) {
List<DeleteObject> dos = objects.stream().map(e -> new DeleteObject(e)).collect(Collectors.toList());
Iterable<Result<DeleteError>> results = minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build());
return results;
}


/**
 * 文件上传
 * 文件名称相同会覆盖
 * @param file   文件
 * @return Boolean
 */
public Boolean upload(MultipartFile file, String fileName) {
try {
if (!bucketExists(minioConfig.getBucketName())) {
makeBucket(minioConfig.getBucketName());
}
PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(minioConfig.getBucketName()).object(fileName)
.stream(file.getInputStream(), file.getSize(), -1).contentType(file.getContentType()).build();
minioClient.putObject(objectArgs);
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
 
/**
 * 文件下载
 *
 * @param fileName   文件名称
 * @param resresponse
 * @return Boolean
 */
public void download(String fileName, HttpServletResponse res) {
GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(minioConfig.getBucketName())
.object(fileName).build();
try (GetObjectResponse response = minioClient.getObject(objectArgs)) {
byte[] buf = new byte[1024];
int len;
try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()) {
while ((len = response.read(buf)) != -1) {
os.write(buf, 0, len);
}
os.flush();
byte[] bytes = os.toByteArray();
res.setCharacterEncoding("utf-8");
//设置强制下载不打开
res.setContentType("application/force-download");
res.addHeader("Content-Disposition", "attachment;fileName=" + fileName);
try (ServletOutputStream stream = res.getOutputStream()) {
stream.write(bytes);
stream.flush();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}

public String getFileUrl(String fileName){
return StringFormatter.concat(minioConfig.getUrl(), "/", minioConfig.getBucketName(), "/", fileName).getValue();
}

}

编写测试接口，进行测试：

@Component
public class MinioTool {

@Autowired
private MinioClient minioClient;

@Autowired
private MinioConfig minioConfig;
 
/**
 * 查看存储bucket是否存在
 *
 * @param bucketName 存储bucket
 * @return boolean
 */
public Boolean bucketExists(String bucketName) {
Boolean found;
try {
found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return found;
}
 
/**
 * 创建存储bucket
 *
 * @param bucketName 存储bucket名称
 * @return Boolean
 */
public Boolean makeBucket(String bucketName) {
try {
minioClient.makeBucket(MakeBucketArgs.builder()
.bucket(bucketName)
.build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
 
/**
 * 删除存储bucket
 *
 * @param bucketName 存储bucket名称
 * @return Boolean
 */
public Boolean removeBucket(String bucketName) {
try {
minioClient.removeBucket(RemoveBucketArgs.builder()
.bucket(bucketName)
.build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}

/**
 * 查看文件对象
 *
 * @param bucketName 存储bucket名称
 * @return 存储bucket内文件对象信息
 */
public Iterable<Result<Item>> listObjects(String bucketName) {
Iterable<Result<Item>> results = minioClient.listObjects(
ListObjectsArgs.builder().bucket(bucketName).build());
return results;
}

/**
 * 批量删除文件对象
 *
 * @param bucketName 存储bucket名称
 * @param objects对象名称集合
 */
public Iterable<Result<DeleteError>> removeObjects(String bucketName, List<String> objects) {
List<DeleteObject> dos = objects.stream().map(e -> new DeleteObject(e)).collect(Collectors.toList());
Iterable<Result<DeleteError>> results = minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build());
return results;
}


/**
 * 文件上传
 * 文件名称相同会覆盖
 * @param file   文件
 * @return Boolean
 */
public Boolean upload(MultipartFile file, String fileName) {
try {
if (!bucketExists(minioConfig.getBucketName())) {
makeBucket(minioConfig.getBucketName());
}
PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(minioConfig.getBucketName()).object(fileName)
.stream(file.getInputStream(), file.getSize(), -1).contentType(file.getContentType()).build();
minioClient.putObject(objectArgs);
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
 
/**
 * 文件下载
 *
 * @param fileName   文件名称
 * @param resresponse
 * @return Boolean
 */
public void download(String fileName, HttpServletResponse res) {
GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(minioConfig.getBucketName())
.object(fileName).build();
try (GetObjectResponse response = minioClient.getObject(objectArgs)) {
byte[] buf = new byte[1024];
int len;
try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()) {
while ((len = response.read(buf)) != -1) {
os.write(buf, 0, len);
}
os.flush();
byte[] bytes = os.toByteArray();
res.setCharacterEncoding("utf-8");
//设置强制下载不打开
res.setContentType("application/force-download");
res.addHeader("Content-Disposition", "attachment;fileName=" + fileName);
try (ServletOutputStream stream = res.getOutputStream()) {
stream.write(bytes);
stream.flush();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}

public String getFileUrl(String fileName){
return StringFormatter.concat(minioConfig.getUrl(), "/", minioConfig.getBucketName(), "/", fileName).getValue();
}

}