我正在下载带有GET请求的文件。它们中的一些很大,因此我想将它们作为流获取,并按块读取字节,因为我可以对其进行处理,而从不读取内存中的整个文件。
org.springframework.web.reactive.function.client.WebClient看起来很合适,但是我遇到了“ UnsupportedMediaTypeException:不支持内容类型'application / octet-stream'。
这是一些简短的示例代码。
@Autowired WebClient.Builder webClientBuilder;
....
ClientResponse clientResponse = webClientBuilder.clientConnector(this.connector)
.build()
.get()
.uri(uri)
.accept(MediaType.APPLICATION_OCTET_STREAM)
.exhange()
.block(Duration.of(1, ChronoUnit.MINUTES));
// blows up here, inside of the body call
InputStream responseInputStream = clientResponse.body(BodyExtractors.toMono(InputStream.class)).block(Duration.of(1, ChronoUnit.MINUTES));
这是堆栈跟踪的一部分。
org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type 'application/octet-stream' not supported
at org.springframework.web.reactive.function.BodyExtractors.lambda$readWithMessageReaders$20(BodyExtractors.java:254)
at java.util.Optional.orElseGet(Optional.java:267)
at org.springframework.web.reactive.function.BodyExtractors.readWithMessageReaders(BodyExtractors.java:250)
at org.springframework.web.reactive.function.BodyExtractors.lambda$toMono$2(BodyExtractors.java:92)
......
我正在使用spring-webflux 5.0.7。
我确信spring webclient必须支持JSON以外的东西。我只是不知道该怎么做。救命?
不是专家,而是代替InputStream,可以使用以下命令获取一个Flux<byte[]>
位置:每个已发布的数组将包含响应正文的一部分)
.get()
.uri(uri)
.accept(MediaType.APPLICATION_OCTET_STREAM)
.retrieve()
.bodyToFlux(byte[].class)
如果您愿意,也可以使用ByteBuffer
代替byte[]
。
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句