如何覆盖任何 HttpHeader 以响应 WebClient？

Question

WebClient.builder().baseUrl("/").filter(contentTypeInterceptor()).build();

我如何修改接收到的响应的 Content-Type（因为我正在从发出错误内容类型的网络服务器接收响应。由于我无法控制外部服务器，我想要更正内容类型以便进一步正确处理（例如使用 jackson 库等）。

private ExchangeFilterFunction contentTypeInterceptor() {
    return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> {
        org.springframework.web.reactive.function.client.ClientResponse.Headers headers = clientResponse.headers();
        //TODO how to headers.setContentType("myval) or headers.set("Content-Type", "myval");   
        //headers.asHttpHeaders(); cannot be used as it is readonly
    });
}

这个问题可以概括地回答如何覆盖任何 http header。

我的根本原因是我收到 text/html，但响应 body 实际上是 application/xml。并且 jackson 拒绝解析该响应，原因是：

org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type 'text/html' not supported for bodyType=MyResponse

Answer 1

也许是这样的？

private ExchangeFilterFunction contentTypeInterceptor() {
    return ExchangeFilterFunction.ofRequestProcessor(clientRequest -> 
        Mono.just(ClientRequest.from(clientRequest)
            .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_XML_VALUE)
            .build()));
}

Answer 2

我有类似的问题，接受的答案对我不起作用。我这样做是为了覆盖我收到的无效内容类型。

/**
     * webclient interceptor that overrides the response headers ...
     * */
    private ExchangeFilterFunction contentTypeInterceptor() {
        return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> 
            Mono.just(
                    ClientResponse
                        .from(clientResponse) //clientResponse  is immutable, so,we create a clone. but from() only clones headers and status code
                        .headers(headers -> headers.remove(HttpHeaders.CONTENT_TYPE)) //override the content type
                        .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_OCTET_STREAM_VALUE) 
                        .body(clientResponse.body(BodyExtractors.toDataBuffers()) ) // copy the body as bytes with no processing
                        .build()));
    }

Answer 3

Ahmed 的回答在技术上是正确的。但是，我相信在我发布这篇文章时，ClientResponse.from() 已被弃用，您应该使用 .mutate() 方法创建一个新的 Builder。

private ExchangeFilterFunction contentTypeInterceptor() {
    return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> 
        Mono.just(clientResponse.mutate()
            .headers(headers -> headers.remove(HttpHeaders.CONTENT_TYPE))
            .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_XML_VALUE)
            .build()));
}

如何覆盖任何 HttpHeader 以响应 WebClient？

How to override any HttpHeader in response of WebClient?

java

spring

webclient

spring-webflux

spring-webclient