修改:大文件分片上传接口超时设置优化,合并动作设置成同步

This commit is contained in:
2026-03-24 18:33:22 +08:00
parent 174006db72
commit 0a5b002ff4
6 changed files with 67 additions and 4 deletions

View File

@@ -2047,11 +2047,29 @@ public class MinioFileIDataFileServiceImpl implements IDataFileService {
log.info("saveChunkFileToLocal 合并本地文件finalLocalFilePath:{},localTempDirPath:{},getChunkTotal:{}结果:{}", log.info("saveChunkFileToLocal 合并本地文件finalLocalFilePath:{},localTempDirPath:{},getChunkTotal:{}结果:{}",
finalLocalFilePath,localTempDirPath,req.getChunkTotal(),localMergeSuccess); finalLocalFilePath,localTempDirPath,req.getChunkTotal(),localMergeSuccess);
} }
// 分片文件已经上传完成,提前返回,异步合并数据
CompletableFuture.runAsync(() -> {
asyncMerge(req.getObjectKey(),chunkBucket,tempDirPath,req.getBusinessId());
});
// 同步调用
try {
Boolean merge = minioService.merge(chunkBucket, tempDirPath, chunkBucket, req.getObjectKey());
if(!merge){
// 删除分片临时数据
deleteTempFileAfterFailed(tempDirPath,chunkBucket);
log.error("合并分片失败:{}",tempDirPath);
return buildFailedResponse(resp,"文件合并失败",req);
}
// 4. 合并完成后删除临时目录
deleteTempFileAfterFailed(tempDirPath,chunkBucket);
} catch (Exception e) {
log.error("合并分片 error:{}",e.getMessage());
}finally {
// 删除分片上传的处理中状态
commonStatusUtil.end(CommonStatusUtil.CHUNK_UPLOAD_FILE+req.getBusinessId());
}
asyncMerge(req.getObjectKey(),chunkBucket,tempDirPath,req.getBusinessId());
// 分片文件已经上传完成,提前返回,异步合并数据
// CompletableFuture.runAsync(() -> {
// asyncMerge(req.getObjectKey(),chunkBucket,tempDirPath,req.getBusinessId());
// });
return buildSuccessResponse(resp,req,tempDirPath); return buildSuccessResponse(resp,req,tempDirPath);
} }

View File

@@ -33,6 +33,15 @@ spring:
- Path=/simulation/capability/** - Path=/simulation/capability/**
filters: filters:
- StripPrefix=2 - StripPrefix=2
- id: data-service-chunk-upload
uri: lb://data
predicates:
- Path=/simulation/data/data/chunkUploadToMinio
filters:
- StripPrefix=2
metadata:
response-timeout: 60000
connect-timeout: 10000
- id: data-service - id: data-service
uri: lb://data uri: lb://data
predicates: predicates:

View File

@@ -33,6 +33,15 @@ spring:
- Path=/simulation/capability/** - Path=/simulation/capability/**
filters: filters:
- StripPrefix=2 - StripPrefix=2
- id: data-service-chunk-upload
uri: lb://data
predicates:
- Path=/simulation/data/data/chunkUploadToMinio
filters:
- StripPrefix=2
metadata:
response-timeout: 60000
connect-timeout: 10000
- id: data-service - id: data-service
uri: lb://data uri: lb://data
predicates: predicates:

View File

@@ -33,6 +33,15 @@ spring:
- Path=/simulation/capability/** - Path=/simulation/capability/**
filters: filters:
- StripPrefix=2 - StripPrefix=2
- id: data-service-chunk-upload
uri: lb://data
predicates:
- Path=/simulation/data/data/chunkUploadToMinio
filters:
- StripPrefix=2
metadata:
response-timeout: 60000
connect-timeout: 10000
- id: data-service - id: data-service
uri: lb://data uri: lb://data
predicates: predicates:

View File

@@ -33,6 +33,15 @@ spring:
- Path=/simulation/capability/** - Path=/simulation/capability/**
filters: filters:
- StripPrefix=2 - StripPrefix=2
- id: data-service-chunk-upload
uri: lb://data
predicates:
- Path=/simulation/data/data/chunkUploadToMinio
filters:
- StripPrefix=2
metadata:
response-timeout: 60000
connect-timeout: 10000
- id: data-service - id: data-service
uri: lb://data uri: lb://data
predicates: predicates:

View File

@@ -33,6 +33,15 @@ spring:
- Path=/simulation/capability/** - Path=/simulation/capability/**
filters: filters:
- StripPrefix=2 - StripPrefix=2
- id: data-service-chunk-upload
uri: lb://data
predicates:
- Path=/simulation/data/data/chunkUploadToMinio
filters:
- StripPrefix=2
metadata:
response-timeout: 60000
connect-timeout: 10000
- id: data-service - id: data-service
uri: lb://data uri: lb://data
predicates: predicates: