如何将Spring WebClient get Application/Octet-Stream作为主体输入流处理？

Question

我正在下载带有GET请求的文件。其中有些相当大，所以我希望将它们作为一个流来获取，并在能够处理它们时以块的形式读取字节，而不是在内存中读取整个文件。

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 webclient必须支持JSON以外的东西。我只是不知道怎么做。救命？

Answer 1

不是专家，但您可以得到一个flux ，其中每个发布的数组将包含响应体的一个片段），而不是输入流，使用

.get()
.uri(uri)
.accept(MediaType.APPLICATION_OCTET_STREAM)
.retrieve()
.bodyToFlux(byte[].class)

如果愿意，您还可以使用bytebuffer而不是byte[]执行同样的操作。