如何从SpringWebClient的ClientResponse中获取最佳字节数组？

我正在尝试WebClient使用反应式编程的代码库中的Spring 5(5.0.0.RC2)中的新内容,并且我已成功将JSON响应从端点映射到我的应用程序中的DTO,这非常好用:

WebClient client = WebClient.create(baseURI);
Mono dto = client.get()
        .uri(uri)
        .accept(MediaType.APPLICATION_JSON)
        .exchange()
        .flatMap(response -> response.bodyToMono(DTO.class));

但是,现在我正在尝试使用协议缓冲区(二进制数据作为application/octet-stream)的端点的响应体,所以我想从响应中获取原始字节,然后我将自己映射到一个对象.

我Bytes从Google Guava 那里得到了这样的工作方式:

Mono bytes = client.get()
        .uri(uri)
        .accept(MediaType.APPLICATION_OCTET_STREAM)
        .exchange()
        .flatMapMany(response -> response.body(BodyExtractors.toDataBuffers()))
        .map(dataBuffer -> {
            ByteBuffer byteBuffer = dataBuffer.asByteBuffer();
            byte[] byteArray = new byte[byteBuffer.remaining()];
            byteBuffer.get(byteArray, 0, bytes.length);
            return byteArray;
        })
        .reduce(Bytes::concat)

这有效,但是有更简单,更优雅的方式来获取这些字节吗？

ClientResponse.bodyToMono()最后使用一些org.springframework.core.codec.Decoder声称支持指定类的.

所以我们应该检查类的层次结构Decoder,特别是decodeToMono()方法的实现位置和方式.

有一个StringDecoder支持解码String,一堆杰克逊相关的解码器(在您的DTO示例中使用),还有一个ResourceDecoder特别感兴趣的解码器.

ResourceDecoder支持org.springframework.core.io.InputStreamResource和org.springframework.core.io.ByteArrayResource.ByteArrayResource本质上是一个包装器byte[],因此以下代码将提供对作为字节数组的响应主体的访问:

Mono mOno= client.get()
            ...
            .exchange()
            .flatMap(response -> response.bodyToMono(ByteArrayResource.class))
            .map(ByteArrayResource::getByteArray);