java语言操控minio实现文件的版本管理（基于springboot项目）

2024-05-24 13:04
文章标签 java 语言 实现 springboot 项目 spring 管理 版本 操控 minio

本文主要是介绍java语言操控minio实现文件的版本管理（基于springboot项目），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

    • 一、简介
    • 二、相关依赖
    • 三、功能实现
      • 3.1、minio客户端初始化
      • 3.2、创建带有版本管理的bucket
      • 3.3、文件上传
      • 3.4、获取minio文件夹下所有文件以及对应的所有版本
      • 3.5、获取minio文件夹下所有文件
      • 3.6、文件下载
      • 3.7、文件删除

一、简介

minio是一款分布式的对象存储服务，本文主要介绍通过springboot项目实现对minio存储系统中文件的版本管理。minio存储服务中可以手动开启版本管理的功能，开启版本管理后每个文件的变更都会生成一个新的版本，包括文件的第一次上传、文件的覆盖以及文件的删除等，每个版本都会有一个版本编号versionId，后续都会根据每个文件的各个版本编号进行版本管理。

minio中文官网java指南：https://minio.org.cn/docs/minio/linux/developers/java/minio-java.html
minio中文官网java API：https://minio.org.cn/docs/minio/linux/developers/java/API.html
minio环境搭建：https://blog.csdn.net/weixin_42684368/article/details/136449419

二、相关依赖

		<!-- 注意minio版本，不同版本对应api不一样 --><dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.10</version></dependency><dependency><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId><version>4.9.3</version></dependency>

三、功能实现

3.1、minio客户端初始化

// minio的所有操作都是基于minio客户端对象实现的，首先需要初始化minio客户端对象
MinioClient minioClient = MinioClient.builder().endpoint("http://127.0.0.1:19011").credentials("minioadmin", "minioadmin").build();

3.2、创建带有版本管理的bucket

    public void createVersionBucket(String bucketName,MinioClient minioClient){try {//  判断当前bucket是否存在boolean found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());if(!found){// 创建bucketminioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());// 开启当前bucket的版本管理功能VersioningConfiguration versioningConfiguration = new VersioningConfiguration(VersioningConfiguration.Status.ENABLED,true);minioClient.setBucketVersioning(SetBucketVersioningArgs.builder().bucket(bucketName).config(versioningConfiguration).build());log.info("minio初始化桶："+bucketName);}} catch (Exception e) {log.error(e.getMessage());}}

3.3、文件上传

    /*** 单个文件上传到minio并返回对应的版本id* * 其中objectName 是文件上传到minio中的全路径* fileName是本地文件全路径* bucketName 是桶名称* 如 fileName = "D:/test.txt",objectName = "测试/test.txt"* 则会将D盘下的test.txt文件上传到minio对应bucketName桶（bucket）下的测试目录中*/public static String minio_uploadSingleFile(String objectName,String fileName){objectName = objectName.replace("\\","/");// 上传文件try {ObjectWriteResponse objectWriteResponse = minioClient.uploadObject(UploadObjectArgs.builder().bucket(bucketName).object(objectName)  // 上传到分布式系统的文件名称.filename(fileName) // 本地文件路径.build());return objectWriteResponse.versionId();} catch (Exception e) {throw new RuntimeException(e);}}// 本地文件夹上传public static void minio_uploadLocalFile(String dirName){File files = new File(dirName);for (File file : files.listFiles()) {String versionId = minio_uploadSingleFile(dirName + "/" + file.getName(), file.getPath());}}// 文件流上传public static String minio_uploadFile(MultipartFile file,String objectName){try {InputStream inputStream = file.getInputStream();return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).contentType(file.getContentType()).stream(inputStream, inputStream.available(), -1).build()).versionId();} catch (Exception e) {log.error("文件上传至minio出错："+e.getMessage());}return null;}// 多文件流上传 将文件都上传到bucketName桶下dirName目录中public static void uploadToMinio(List<MultipartFile> multipartFiles, String dirName) {if(multipartFiles != null) {for (int i = 0; i < multipartFiles.size(); i++) {String versionId = minio_uploadFile(multipartFiles.get(i), dirName+"/"+multipartFiles.get(i).getName());}}}

3.4、获取minio文件夹下所有文件以及对应的所有版本

    public static void minio_listVersion(String dirName){try {// includeVersions为true表示查找结果包含文件的所有历史版本，recursive为true表示对整个文件夹进行递归查找，会获取所有文件// prefix 表示查找文件名的前缀，minio每个文件都会有个objectName属性，比如test.txt在"测试"目录下,// 那么test.txt的objectName则是-> 测试/test.txt ,也就是测试目录下的所有文件objectName都包含前缀 "测试/"Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().includeVersions(true).bucket("java-bucket").prefix(dirName+"/").recursive(true).build());for (Result<Item> result : results) {System.out.println(result.get().objectName());System.out.println(result.get().versionId());}} catch (Exception e) {throw new RuntimeException(e);}}

3.5、获取minio文件夹下所有文件

    public static void minio_list(String dirName){try {// recursive为true表示对整个文件夹进行递归查找，会获取所有文件// prefix 表示查找文件名的前缀，minio每个文件都会有个objectName属性，比如test.txt在"测试"目录下,// 那么test.txt的objectName则是-> 测试/test.txt ,也就是测试目录下的所有文件objectName都包含前缀 "测试/"Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket("java-bucket").prefix(dirName+"/").recursive(true).build());for (Result<Item> result : results) {System.out.println(result.get().objectName());System.out.println(result.get().versionId());}} catch (Exception e) {throw new RuntimeException(e);}}

3.6、文件下载

    // 下载单个文件到本地public static void minio_downloadFile(String objectName,String fileName){try {minioClient.downloadObject(DownloadObjectArgs.builder().bucket(bucketName).object(objectName).filename(fileName)//.versionId(versionId) 如果需要下载该文件的特定版本则需要指定.build());} catch (Exception e) {log.info("下载minio文件出现错误："+e.getMessage());}}// 文件流压缩下载public static void minio_downloadByStream(String dirName, HttpServletResponse response){ZipOutputStream zos = null;try {response.setHeader("Content-Disposition", "attachment;filename=" +  java.net.URLEncoder.encode(dirName+".zip","UTF-8"));//压缩流传输zos =  new ZipOutputStream(response.getOutputStream());// 获取当前目录下的所有文件列表Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(dirName+"/").recursive(true).build());for (Result<Item> result : results) {InputStream in ;byte[] buf = new byte[1024];int len;// 获取文件流in = minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(result.get().objectName()).build());zos.putNextEntry(new ZipEntry(result.get().objectName()));while ((len = in.read(buf)) > 0) {zos.write(buf, 0, len);}}response.setContentType("application/zip");response.flushBuffer();} catch (Exception e) {throw new RuntimeException(e);} finally {assert zos != null;try {zos.close();} catch (IOException e) {throw new RuntimeException(e);}}}

注意：当需要下载特定版本的文件只需要加上.versionId(versionId)即可

in = minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(result.get().objectName()).versionId(versionId).build());

3.7、文件删除

/*** 彻底从minio中删除目录，即删除所有文件的所有版本* @param modelName*/public static void deleteDirFromMinioComplete(String dirName){try {Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(dirName+"/").includeVersions(true).recursive(true).build());for (Result<Item> result : results) {minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(result.get().objectName()).versionId(result.get().versionId()).build());}log.info(Thread.currentThread().getName()+" 线程成功从minio中删除目录 "+ finalModelName);} catch (Exception e) {log.error("删除minio中文件出现错误："+e.getMessage());}}// 删除文件，但是会留下新版本，还可以通过版本id恢复public static void deleteDirFromMinio(String dirName){try {Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(dirName+"/").recursive(true).build());for (Result<Item> result : results) {minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(result.get().objectName()).build());}} catch (Exception e) {log.error("删除minio中文件出现错误："+e.getMessage());}}

这篇关于java语言操控minio实现文件的版本管理（基于springboot项目）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/998479。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
这15个Vue指令，让你的项目开发爽到爆

这15个Vue指令，让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件，按住 Control 和回车键再显示它吗？小菜一碟： <template
阅读更多...
Java进阶13讲__第12讲_1/2

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory
阅读更多...
如何用Docker运行Django项目

如何用Docker运行Django项目

本章教程，介绍如何用Docker创建一个Django，并运行能够访问。 一、拉取镜像 这里我们使用python3.11版本的docker镜像 docker pull python:3.11 二、运行容器 这里我们将容器内部的8080端口，映射到宿主机的80端口上。 docker run -itd --name python311 -p
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2