Vite App

commit fbfed7311648d70c844ba371e134a0cd375c5837 Author: LAN Date: Fri Dec 13 14:36:03 2024 +0800 minio diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..13566b8 --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/.idea/encodings.xml b/.idea/encodings.xml new file mode 100644 index 0000000..ce358e4 --- /dev/null +++ b/.idea/encodings.xml @@ -0,0 +1,4 @@ + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..9c80558 --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,68 @@ + + + + + + + + + JVM 语言 + + + Java + + + Java 10Java 语言级别迁移帮助Java + + + Java 11Java 语言级别迁移帮助Java + + + Java 14Java 语言级别迁移帮助Java + + + Java 15Java 语言级别迁移帮助Java + + + Java 5Java 语言级别迁移帮助Java + + + Java 7Java 语言级别迁移帮助Java + + + Java 8Java 语言级别迁移帮助Java + + + Java 9Java 语言级别迁移帮助Java + + + Java 互操作问题Kotlin + + + Java 语言级别迁移帮助Java + + + JavaScript and TypeScript + + + Kotlin + + + 有效性问题JavaScript and TypeScript + + + 模块化问题Java + + + 迁移Kotlin + + + + + Android + + + + + + \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000..a953099 --- /dev/null +++ b/README.md @@ -0,0 +1 @@ +# SpringBoot3+Minio+Vue3+ElementPlus实现断点续传/分片上传/文件秒传 diff --git a/minio-admin/.gitignore b/minio-admin/.gitignore new file mode 100644 index 0000000..549e00a --- /dev/null +++ b/minio-admin/.gitignore @@ -0,0 +1,33 @@ +HELP.md +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### IntelliJ IDEA ### +.idea +*.iws +*.iml +*.ipr + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ diff --git a/minio-admin/logs/error.log b/minio-admin/logs/error.log new file mode 100644 index 0000000..e69de29 diff --git a/minio-admin/logs/info.log b/minio-admin/logs/info.log new file mode 100644 index 0000000..40d5d16 --- /dev/null +++ b/minio-admin/logs/info.log @@ -0,0 +1,48 @@ +11:56:44.842 [background-preinit] INFO o.h.v.i.util.Version - [,21] - HV000001: Hibernate Validator 8.0.0.Final +11:56:44.859 [restartedMain] INFO c.m.MinioUploadFileApplication - [logStarting,51] - Starting MinioUploadFileApplication using Java 19.0.1 with PID 18717 (/Users/lan/minio-project-master/minio-admin/target/classes started by lan in /Users/lan/minio-project-master/minio-admin) +11:56:44.861 [restartedMain] INFO c.m.MinioUploadFileApplication - [logStartupProfileInfo,630] - No active profile set, falling back to 1 default profile: "default" +11:56:47.883 [restartedMain] INFO o.a.c.h.Http11NioProtocol - [log,173] - Initializing ProtocolHandler ["http-nio-9090"] +11:56:47.885 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat] +11:56:47.885 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.5] +11:56:47.954 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext +11:56:49.612 [restartedMain] INFO o.a.c.h.Http11NioProtocol - [log,173] - Starting ProtocolHandler ["http-nio-9090"] +11:56:49.642 [restartedMain] INFO c.m.MinioUploadFileApplication - [logStarted,57] - Started MinioUploadFileApplication in 5.269 seconds (process running for 7.524) +12:14:01.766 [http-nio-9090-exec-1] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet' +12:14:01.881 [http-nio-9090-exec-1] INFO c.m.c.FileMinioController - [checkFileUploadedByMd5,74] - REST: 通过查询 <036ee500fdb624314479780c6daf547d> 文件是否存在、是否进行断点续传 +12:14:01.882 [http-nio-9090-exec-1] INFO c.m.s.i.UploadServiceImpl - [getByFileMD5,48] - tip message: 通过 <036ee500fdb624314479780c6daf547d> 查询redis是否存在 +12:14:02.490 [http-nio-9090-exec-1] INFO c.m.s.i.UploadServiceImpl - [getByFileMD5,59] - tip message: 通过 <036ee500fdb624314479780c6daf547d> 查询mysql是否存在 +12:14:02.681 [http-nio-9090-exec-1] INFO c.z.h.HikariDataSource - [getConnection,110] - HikariPool-1 - Starting... +12:14:02.962 [http-nio-9090-exec-1] INFO c.z.h.p.HikariPool - [checkFailFast,565] - HikariPool-1 - Added connection com.mysql.cj.jdbc.ConnectionImpl@1b0794cd +12:14:02.964 [http-nio-9090-exec-1] INFO c.z.h.HikariDataSource - [getConnection,123] - HikariPool-1 - Start completed. +12:14:03.297 [http-nio-9090-exec-2] INFO c.m.c.FileMinioController - [initMultiPartUpload,90] - REST: 通过初始化上传任务 +12:14:03.301 [http-nio-9090-exec-2] INFO c.m.s.i.UploadServiceImpl - [initMultiPartUpload,85] - tip message: 通过开始初始化<分片上传>任务 +12:14:03.834 [http-nio-9090-exec-2] INFO c.m.s.i.UploadServiceImpl - [initMultiPartUpload,91] - tip message: 当前分片数量 <1> 进行单文件上传 +12:14:03.847 [http-nio-9090-exec-2] INFO c.m.c.MybatisPlusConfig - [insertFill,37] - start insert fill .... +12:14:03.941 [http-nio-9090-exec-2] INFO c.m.utils.MinioUtils - [getUploadObjectUrl,64] - tip message: 通过 <036ee500fdb624314479780c6daf547d.png-image> 开始单文件上传 +12:14:03.947 [http-nio-9090-exec-2] INFO c.m.utils.MinioUtils - [getUploadObjectUrl,74] - tip message: 单个文件上传、成功 +12:18:57.075 [SpringApplicationShutdownHook] INFO c.z.h.HikariDataSource - [close,350] - HikariPool-1 - Shutdown initiated... +12:18:57.082 [SpringApplicationShutdownHook] INFO c.z.h.HikariDataSource - [close,352] - HikariPool-1 - Shutdown completed. +12:19:02.637 [background-preinit] INFO o.h.v.i.util.Version - [,21] - HV000001: Hibernate Validator 8.0.0.Final +12:19:02.653 [restartedMain] INFO c.m.MinioUploadFileApplication - [logStarting,51] - Starting MinioUploadFileApplication using Java 19.0.1 with PID 20456 (/Users/lan/minio-project-master/minio-admin/target/classes started by lan in /Users/lan/minio-project-master/minio-admin) +12:19:02.654 [restartedMain] INFO c.m.MinioUploadFileApplication - [logStartupProfileInfo,630] - No active profile set, falling back to 1 default profile: "default" +12:19:04.851 [restartedMain] INFO o.a.c.h.Http11NioProtocol - [log,173] - Initializing ProtocolHandler ["http-nio-9090"] +12:19:04.851 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat] +12:19:04.852 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.5] +12:19:04.915 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext +12:19:06.455 [restartedMain] INFO o.a.c.h.Http11NioProtocol - [log,173] - Starting ProtocolHandler ["http-nio-9090"] +12:19:06.558 [restartedMain] INFO c.m.MinioUploadFileApplication - [logStarted,57] - Started MinioUploadFileApplication in 4.334 seconds (process running for 5.695) +12:19:30.858 [http-nio-9090-exec-1] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet' +12:19:30.918 [http-nio-9090-exec-1] INFO c.m.c.FileMinioController - [checkFileUploadedByMd5,74] - REST: 通过查询文件是否存在、是否进行断点续传 +12:19:30.919 [http-nio-9090-exec-1] INFO c.m.s.i.UploadServiceImpl - [getByFileMD5,48] - tip message: 通过查询redis是否存在 +12:19:31.237 [http-nio-9090-exec-1] INFO c.m.s.i.UploadServiceImpl - [getByFileMD5,59] - tip message: 通过查询mysql是否存在 +12:19:31.343 [http-nio-9090-exec-1] INFO c.z.h.HikariDataSource - [getConnection,110] - HikariPool-1 - Starting... +12:19:31.551 [http-nio-9090-exec-1] INFO c.z.h.p.HikariPool - [checkFailFast,565] - HikariPool-1 - Added connection com.mysql.cj.jdbc.ConnectionImpl@42d42417 +12:19:31.552 [http-nio-9090-exec-1] INFO c.z.h.HikariDataSource - [getConnection,123] - HikariPool-1 - Start completed. +12:19:31.708 [http-nio-9090-exec-2] INFO c.m.c.FileMinioController - [initMultiPartUpload,90] - REST: 通过初始化上传任务 +12:19:31.712 [http-nio-9090-exec-2] INFO c.m.s.i.UploadServiceImpl - [initMultiPartUpload,85] - tip message: 通过开始初始化<分片上传>任务 +12:19:32.184 [http-nio-9090-exec-2] INFO c.m.s.i.UploadServiceImpl - [initMultiPartUpload,91] - tip message: 当前分片数量 <1> 进行单文件上传 +12:19:32.202 [http-nio-9090-exec-2] INFO c.m.c.MybatisPlusConfig - [insertFill,37] - start insert fill .... +12:19:32.279 [http-nio-9090-exec-2] INFO c.m.utils.MinioUtils - [getUploadObjectUrl,64] - tip message: 通过开始单文件上传 +12:19:32.287 [http-nio-9090-exec-2] INFO c.m.utils.MinioUtils - [getUploadObjectUrl,74] - tip message: 单个文件上传、成功 +12:35:11.549 [SpringApplicationShutdownHook] INFO c.z.h.HikariDataSource - [close,350] - HikariPool-1 - Shutdown initiated... +12:35:11.575 [SpringApplicationShutdownHook] INFO c.z.h.HikariDataSource - [close,352] - HikariPool-1 - Shutdown completed. diff --git a/minio-admin/pom.xml b/minio-admin/pom.xml new file mode 100644 index 0000000..3f9e4ee --- /dev/null +++ b/minio-admin/pom.xml @@ -0,0 +1,104 @@ + + + 4.0.0 + com.mmg + minio-admin + 0.0.1-SNAPSHOT + minio-admin + minio-admin + + 17 + UTF-8 + UTF-8 + 3.0.2 + + + + org.springframework.boot + spring-boot-starter-web + + + org.mybatis.spring.boot + mybatis-spring-boot-starter + 3.0.0 + + + + org.springframework.boot + spring-boot-devtools + runtime + true + + + com.mysql + mysql-connector-j + runtime + + + org.projectlombok + lombok + true + + + org.springframework.boot + spring-boot-starter-test + test + + + com.alibaba + fastjson + 1.2.50 + + + com.baomidou + mybatis-plus-boot-starter + 3.5.5 + + + io.minio + minio + 8.3.1 + + + org.springframework.boot + spring-boot-starter-data-redis + + + org.springframework.boot + spring-boot-starter-validation + + + cn.hutool + hutool-all + 5.7.20 + + + + + + + org.springframework.boot + spring-boot-dependencies + ${spring-boot.version} + pom + import + + + + + + + + org.apache.maven.plugins + maven-compiler-plugin + 3.8.1 + + 17 + 17 + UTF-8 + + + + + diff --git a/minio-admin/src/main/java/com/mmg/MinioUploadFileApplication.java b/minio-admin/src/main/java/com/mmg/MinioUploadFileApplication.java new file mode 100644 index 0000000..0982f3f --- /dev/null +++ b/minio-admin/src/main/java/com/mmg/MinioUploadFileApplication.java @@ -0,0 +1,11 @@ +package com.mmg; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class MinioUploadFileApplication { + public static void main(String[] args) { + SpringApplication.run(MinioUploadFileApplication.class, args); + } +} diff --git a/minio-admin/src/main/java/com/mmg/config/CustomMinioClient.java b/minio-admin/src/main/java/com/mmg/config/CustomMinioClient.java new file mode 100644 index 0000000..40171e4 --- /dev/null +++ b/minio-admin/src/main/java/com/mmg/config/CustomMinioClient.java @@ -0,0 +1,72 @@ +package com.mmg.config; + + +import com.google.common.collect.Multimap; +import io.minio.CreateMultipartUploadResponse; +import io.minio.ListPartsResponse; +import io.minio.MinioClient; +import io.minio.ObjectWriteResponse; +import io.minio.messages.Part; + +public class CustomMinioClient extends MinioClient { + + /** + * 继承父类 + * @param client + */ + public CustomMinioClient(MinioClient client) { + super(client); + } + + + /** + * 初始化分片上传、获取 uploadId + * + * @param bucket String 存储桶名称 + * @param region String + * @param object String 文件名称 + * @param headers Multimap 请求头 + * @param extraQueryParams Multimap + * @return String + */ + public String initMultiPartUpload(String bucket, String region, String object, Multimap headers, Multimap extraQueryParams) throws Exception { + CreateMultipartUploadResponse response = this.createMultipartUpload(bucket, region, object, headers, extraQueryParams); + return response.result().uploadId(); + } + + /** + * 合并分片 + * + * @param bucketName String 桶名称 + * @param region String + * @param objectName String 文件名称 + * @param uploadId String 上传的 uploadId + * @param parts Part[] 分片集合 + * @param extraHeaders Multimap + * @param extraQueryParams Multimap + * @return ObjectWriteResponse + */ + public ObjectWriteResponse mergeMultipartUpload(String bucketName, String region, String objectName, String uploadId, Part[] parts, Multimap extraHeaders, Multimap extraQueryParams) throws Exception { + return this.completeMultipartUpload(bucketName, region, objectName, uploadId, parts, extraHeaders, extraQueryParams); + } + + /** + * 查询当前上传后的分片信息 + * + * @param bucketName String 桶名称 + * @param region String + * @param objectName String 文件名称 + * @param maxParts Integer 分片数量 + * @param partNumberMarker Integer 分片起始值 + * @param uploadId String 上传的 uploadId + * @param extraHeaders Multimap + * @param extraQueryParams Multimap + * @return ListPartsResponse + */ + public ListPartsResponse listMultipart(String bucketName, String region, String objectName, Integer maxParts, Integer partNumberMarker, String uploadId, Multimap extraHeaders, Multimap extraQueryParams) throws Exception { + return this.listParts(bucketName, region, objectName, maxParts, partNumberMarker, uploadId, extraHeaders, extraQueryParams); + } + + +} + diff --git a/minio-admin/src/main/java/com/mmg/config/MybatisPlusConfig.java b/minio-admin/src/main/java/com/mmg/config/MybatisPlusConfig.java new file mode 100644 index 0000000..652637a --- /dev/null +++ b/minio-admin/src/main/java/com/mmg/config/MybatisPlusConfig.java @@ -0,0 +1,52 @@ +package com.mmg.config; + +import com.baomidou.mybatisplus.annotation.DbType; +import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler; +import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; +import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; +import lombok.extern.slf4j.Slf4j; +import org.apache.ibatis.reflection.MetaObject; +import org.mybatis.spring.annotation.MapperScan; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.time.LocalDateTime; + +/** + * MybatisPlus配置类 + * + */ +@Slf4j +@Configuration +@MapperScan("com.mmg.mapper") +public class MybatisPlusConfig implements MetaObjectHandler { + /** + * 新的分页插件 + * 需要设置 MybatisConfiguration#useDeprecatedExecutor = false + * 避免缓存出现问题(该属性会在旧插件移除后一同移除) + */ + @Bean + public MybatisPlusInterceptor mybatisPlusInterceptor() { + MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); + interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); + return interceptor; + } + + @Override + public void insertFill(MetaObject metaObject) { + log.info("start insert fill ...."); + this.strictInsertFill(metaObject, "createTime", LocalDateTime.class, LocalDateTime.now()); // 起始版本 3.3.0(推荐使用) + this.fillStrategy(metaObject, "createTime", LocalDateTime.now()); // 也可以使用(3.3.0 该方法有bug请升级到之后的版本如`3.3.1.8-SNAPSHOT`) + /* 上面选其一使用,下面的已过时(注意 strictInsertFill 有多个方法,详细查看源码) */ + + } + + @Override + public void updateFill(MetaObject metaObject) { + log.info("start update fill ...."); + this.strictUpdateFill(metaObject, "updateTime", LocalDateTime.class, LocalDateTime.now()); // 起始版本 3.3.0(推荐使用) + this.fillStrategy(metaObject, "updateTime", LocalDateTime.now()); // 也可以使用(3.3.0 该方法有bug请升级到之后的版本如`3.3.1.8-SNAPSHOT`) + /* 上面选其一使用,下面的已过时(注意 strictUpdateFill 有多个方法,详细查看源码) */ + } + +} diff --git a/minio-admin/src/main/java/com/mmg/config/RedisConfig.java b/minio-admin/src/main/java/com/mmg/config/RedisConfig.java new file mode 100644 index 0000000..4c295ab --- /dev/null +++ b/minio-admin/src/main/java/com/mmg/config/RedisConfig.java @@ -0,0 +1,48 @@ +package com.mmg.config; + +import com.fasterxml.jackson.annotation.JsonAutoDetect; +import com.fasterxml.jackson.annotation.PropertyAccessor; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.data.redis.connection.RedisConnectionFactory; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; +import org.springframework.data.redis.serializer.StringRedisSerializer; + +//编写我们自己的RedisTemplate +@Configuration +public class RedisConfig { + //固定redis模板，在工作中，拿去就可以用 + @Bean + @SuppressWarnings("all") + //改成String，Object类型 + public RedisTemplate redisTemplate(RedisConnectionFactory factory) { + //我们为了自己开发方便，一般直接使用 + RedisTemplate template = new RedisTemplate(); + template.setConnectionFactory(factory); + + //Json序列化配置 + Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class); + ObjectMapper om = new ObjectMapper(); + om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); +// om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); + om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL); + jackson2JsonRedisSerializer.setObjectMapper(om); + //String 的序列化 + StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); + + //key采用string的序列化方式 + template.setKeySerializer(stringRedisSerializer); + //value的序列化方式采用jackson + template.setValueSerializer(jackson2JsonRedisSerializer); + //hash的key也采用String的序列化方式 + template.setHashKeySerializer(stringRedisSerializer); + //hash的value序列化方式采用jackson + template.setHashValueSerializer(jackson2JsonRedisSerializer); + template.afterPropertiesSet(); + + return template; + } +} diff --git a/minio-admin/src/main/java/com/mmg/config/WebAppConfigurer.java b/minio-admin/src/main/java/com/mmg/config/WebAppConfigurer.java new file mode 100644 index 0000000..836f451 --- /dev/null +++ b/minio-admin/src/main/java/com/mmg/config/WebAppConfigurer.java @@ -0,0 +1,44 @@ +package com.mmg.config; + + +import com.alibaba.fastjson.serializer.SerializerFeature; +import com.alibaba.fastjson.support.config.FastJsonConfig; +import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter; +import org.springframework.boot.autoconfigure.http.HttpMessageConverters; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.http.converter.HttpMessageConverter; +import org.springframework.web.servlet.config.annotation.CorsRegistry; +import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; + + +/** + * @description Web应用程序配置 + * @author LGY + * @date 2023/03/14 20:09 + * @version 1.0.0 + */ +@Configuration +public class WebAppConfigurer implements WebMvcConfigurer { + + + @Override + public void addCorsMappings(CorsRegistry registry) { + registry.addMapping("/**") + .allowCredentials(true) + .allowedOriginPatterns("*") + .allowedMethods("POST", "GET", "PUT", "OPTIONS", "DELETE") + .allowedHeaders("*"); + } + + //实体类属性为空时不进行序列化返回给前端 + @Bean + public HttpMessageConverters fastJsonHttpMessageConverters() { + FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter(); + FastJsonConfig fastJsonConfig = new FastJsonConfig(); + fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat); + fastConverter.setFastJsonConfig(fastJsonConfig); + HttpMessageConverter converter = fastConverter; + return new HttpMessageConverters(converter); + } +} diff --git a/minio-admin/src/main/java/com/mmg/controller/FileMinioController.java b/minio-admin/src/main/java/com/mmg/controller/FileMinioController.java new file mode 100644 index 0000000..7e55b2f --- /dev/null +++ b/minio-admin/src/main/java/com/mmg/controller/FileMinioController.java @@ -0,0 +1,131 @@ +package com.mmg.controller; + + +import com.mmg.model.vo.FileUploadInfo; +import com.mmg.service.UploadService; +import com.mmg.utils.MinioUtils; +import com.mmg.utils.R; +import com.mmg.utils.RedisUtil; +import com.mmg.utils.RespEnum; +import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; +import org.springframework.util.StringUtils; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; + +/** + * minio上传流程 + *

+ * 1.检查数据库中是否存在上传文件 + *

+ * 2.根据文件信息初始化，获取分片预签名url地址，前端根据url地址上传文件 + *

+ * 3.上传完成后，将分片上传的文件进行合并 + *

+ * 4.保存文件信息到数据库 + */ +@RestController +@Slf4j +@RequestMapping("upload") +public class FileMinioController { + + @Resource + private UploadService uploadService; + + @Resource + private RedisUtil redisUtil; + + @Resource + private MinioUtils minioUtils; + + /** + * @param fileMD5 文件md5 + * @return {@link R } + * @description 获取上传文件 + * @author LGY + * @date 2023/04/26 16:00 + */ + @GetMapping("/getUploadingFile/{fileMD5}") + public R getUploadingFile(@PathVariable String fileMD5) { + try { + if (StringUtils.isEmpty(fileMD5)) { + return R.error(); + } + FileUploadInfo fileUploadInfo = (FileUploadInfo) redisUtil.get(fileMD5); + if (fileUploadInfo != null) { + // 查询上传后的分片数据 + fileUploadInfo.setChunkUploadedList(minioUtils.getChunkByFileMD5(fileUploadInfo.getFileName(), fileUploadInfo.getUploadId(), fileUploadInfo.getFileType())); + return R.ok().setData(fileUploadInfo); + } + return R.error(); + } catch (Exception e) { + return R.error(e.getMessage()); + } + } + + /** + * 校验文件是否存在 + * + * @param md5 String + * @return ResponseResult

上传示例