如何在Spring 5.3 WebFlux中将ClientACK主体作为DataBuffer？

Question

在弃用WebClient之前。交换我用来获取ClientResponse body作为Flux的方法

在Spring 5.3中，exchange（）方法被弃用，我希望按照建议更改实现：

@自5.3以来已弃用，因为可能会泄漏内存和/或连接；请使用{@link#exchange eToMono（Function）}、{@link#exchange eToFlux（Function）}；还考虑使用{@link#检索（）}...

试图在传递给exchangeToMono的lambda中执行相同的调用，但客户端响应。bodyToFlux（DataBuffer：：class.java）始终返回空流量；其他实验（即将身体作为单音字符串）也不能帮助获得身体。

在Spring 5.3中获取客户响应体的标准方法是什么？

我正在寻找一种低级的主体表示：类似于“数据缓冲区”、“字节数组”或“输入流”；避免任何类型的解析/反序列化。

Spring5.3之前：

webClient
    .method(GET)
    .uri("http://somewhere.com")
    .exchange()
    .flatMap { clientResponse ->
       val bodyRaw: Flux<DataBuffer> = clientResponse.bodyToFlux(DataBuffer::class.java) 
       // ^ body as expected
           
       // other operations
    }

Spring后5.3

webClient
    .method(GET)
    .uri("http://somewhere.com")
    .exchangeToMono { clientResponse ->
       val bodyRaw: Flux<DataBuffer> = clientResponse.bodyToFlux(DataBuffer::class.java)
       // ^ always empty flux
           
       // other operations
    }

Answer 1

新的exchangeToMono和exchangeToFlux方法期望在回调内部对主体进行解码。有关详细信息，请查看此GitHub问题。

看看您的示例，您可能可以使用更安全的替代方法，即使用bodyToFlux

webClient
        .method(GET)
        .uri("http://somewhere.com")
        .retrieve()
        .bodyToFlux(DataBuffer.class)

或者toEntityFlux如果您需要访问响应详细信息，例如标头和状态

webClient
        .method(GET)
        .uri("http://somewhere.com")
        .retrieve()
        .toEntityFlux(DataBuffer.class)

处理错误

选项1。使用OneErrorResume和句柄WebClient响应异常

webClient
        .method(GET)
        .uri("http://somewhere.com")
        .retrieve()
        .bodyToFlux(DataBuffer.class)
        .onErrorResume(WebClientResponseException.class, ex -> {
            if (ex.getStatusCode().equals(HttpStatus.NOT_FOUND)) {
                // ignore 404 and return empty
                return Mono.empty();
            }

            return Mono.error(ex);
        });

选项2。使用方便的方法访问响应。

webClient
        .method(GET)
        .uri("http://somewhere.com")
        .retrieve()
        .onStatus(status -> status.equals(HttpStatus.NOT_FOUND), res -> {
            // ignore 404 and return empty
            return Mono.empty();
        })
        .bodyToFlux(DataBuffer.class)

这两种方法都可以用于反序列化错误响应，在Spring WebClient出现错误的情况下获取响应主体