我目前正在使用Spring WebFlux工作。
我正在尝试使用Spring WebFlux上传大文件(70mo)。
我的控制器
我的收藏家
最后,我通过以下方式检索完整的输入流:
然后,我使用此对象发送到S3存储桶。
但在发送到S3之前,我必须将其转换为文件(使用Apache工具),但我遇到了一个stackoverflow异常。
它对小文件(7兆字节)工作正常。
请问您有解决我的问题的想法吗?
我的控制器
@RequestMapping(method = RequestMethod.POST, consumes = MediaType.MULTIPART_FORM_DATA_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
public Flux<String> uploadHandler(@RequestBody Flux<Part> fluxParts, @RequestParam(value = "categoryType") String categoryType, @PathVariable(value = "traceabilityReportUuid") String traceabilityUuid) {
return documentHandler.upload(fluxParts, UUID.fromString(traceabilityUuid), categoryType);
}
我的服务
public Flux<String> upload(Flux<Part> fluxParts, UUID traceabilityUuid, String categoryType) {
return fluxParts
.filter(part -> part instanceof FilePart)
.ofType(FilePart.class)
.flatMap(p -> this.upload(p, traceabilityUuid, categoryType));
}
private Mono<String> upload(FilePart filePart, UUID traceabilityUuid, String categoryType) {
return filePart.content().collect(InputStreamCollector::new, (t, dataBuffer) -> t.collectInputStream(dataBuffer.asInputStream()))
.flatMap(inputStreamCollector -> {
upload(traceabilityUuid, inputStreamCollector.getInputStream(), filePart.filename(), categoryType);
return Mono.just("OK");
});
}
我的收藏家
public class InputStreamCollector {
private InputStream is;
public void collectInputStream(InputStream is) {
if (this.is == null) this.is = is;
this.is = new SequenceInputStream(this.is, is);
}
public InputStream getInputStream() {
return this.is;
}
}
最后,我通过以下方式检索完整的输入流:
inputStreamCollector.getInputStream()
并将其传递给我的对象。然后,我使用此对象发送到S3存储桶。
但在发送到S3之前,我必须将其转换为文件(使用Apache工具),但我遇到了一个stackoverflow异常。
java.lang.StackOverflowError: null
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
at java.base/java.io.SequenceInputStream.read(SequenceInputStream.java:156)
它对小文件(7兆字节)工作正常。
请问您有解决我的问题的想法吗?