diff --git a/oss-center/src/main/java/com/jmsoftware/maf/osscenter/read/service/impl/ReadResourceServiceImpl.java b/oss-center/src/main/java/com/jmsoftware/maf/osscenter/read/service/impl/ReadResourceServiceImpl.java index f577e223..80688aee 100644 --- a/oss-center/src/main/java/com/jmsoftware/maf/osscenter/read/service/impl/ReadResourceServiceImpl.java +++ b/oss-center/src/main/java/com/jmsoftware/maf/osscenter/read/service/impl/ReadResourceServiceImpl.java @@ -2,6 +2,7 @@ import cn.hutool.core.collection.CollUtil; import cn.hutool.core.io.IoUtil; +import cn.hutool.core.io.NioUtil; import com.jmsoftware.maf.osscenter.read.entity.SerializableStatObjectResponse; import com.jmsoftware.maf.osscenter.read.service.ReadResourceService; import com.jmsoftware.maf.springcloudstarter.minio.MinioHelper; @@ -49,7 +50,7 @@ public ResponseEntity asyncStreamSingleResource(@NotBlank .contentLength(statObjectResponse.size()) .contentType(MediaType.parseMediaType(statObjectResponse.contentType())) .body(outputStream -> { - IoUtil.copy(getObjectResponse, outputStream); + NioUtil.copyByNIO(getObjectResponse, outputStream, NioUtil.DEFAULT_BUFFER_SIZE, null); IoUtil.close(getObjectResponse); }); } @@ -75,7 +76,7 @@ public ResponseEntity asyncDownloadSingleResource(@NotBla .contentLength(statObjectResponse.size()) .contentType(MediaType.parseMediaType(statObjectResponse.contentType())) .body((outputStream -> { - IoUtil.copy(getObjectResponse, outputStream); + NioUtil.copyByNIO(getObjectResponse, outputStream, NioUtil.DEFAULT_LARGE_BUFFER_SIZE, null); IoUtil.close(getObjectResponse); })); } @@ -102,7 +103,7 @@ private ResponseEntity asyncGetResourceRegion(String buck .contentLength(rangeLength) .contentType(MediaType.parseMediaType(statObjectResponse.contentType())) .body(outputStream -> { - IoUtil.copy(getObjectResponse, outputStream); + NioUtil.copyByNIO(getObjectResponse, outputStream, NioUtil.DEFAULT_LARGE_BUFFER_SIZE, null); IoUtil.close(getObjectResponse); }); }