缺少使用WebClient发送POST请求的内容长度标头（SpringBoot 2.0.2.RELEASE）

Question

我使用WebClient（SpringBoot 2.0.2.RELEASE）发送带有SOAP请求的帖子，但它缺少遗留API所需的“内容长度”头。

是否可以将WebClient配置为包含“内容长度”标题？SpringBoot 2.0.1中为EncoderHttpMessageWriter解决并引入了一个Spring框架问题，但它似乎不适用于JAXB。

我试着使用车身插入器：

webClient.post().body(BodyInserters.fromObject(request)).exchange();

和syncBody：

webClient.post().syncBody(request).exchange();

他们都没有为WebClient工作。不过，当使用restemplate时，就会设置内容长度，API会成功响应

Answer 1

WebClient是一个流客户端，在流完成之前很难设置内容长度。到那时，标题早就不见了。如果您使用遗留版本，您可以重用单声道（单声道/通量可以重用，Java流不能重用）并检查长度。

    public void post() {

    Mono<String> mono = Mono.just("HELLO WORLDZ");

    final String response = WebClient.create("http://httpbin.org")
            .post()
            .uri("/post")
            .header(HttpHeaders.CONTENT_LENGTH,
                    mono.map(s -> String.valueOf(s.getBytes(StandardCharsets.UTF_8).length)).block())
            .body(BodyInserters.fromPublisher(mono, String.class))
            .retrieve()
            .bodyToMono(String.class)
            .block();

    System.out.println(response);

}

一个同事（干得好Max！）我想出了更干净的解决方案，我添加了一些包装代码，以便可以测试：

    Mono<String> my = Mono.just("HELLO WORLDZZ")
            .flatMap(body -> WebClient.create("http://httpbin.org")
                    .post()
                    .uri("/post")
                    .header(HttpHeaders.CONTENT_LENGTH,
                            String.valueOf(body.getBytes(StandardCharsets.UTF_8).length))
                    .syncBody(body)
                    .retrieve()
                    .bodyToMono(String.class));

    System.out.println(my.block());

Answer 2

如果你像我们一样应用斯文的同事（Max）解决方案，你也可以将其应用于像你的身体是定制obj这样的情况，但你必须将其序列化一次：

String req = objectMapper.writeValueAsString(requestObject)

然后把它传给了

webClient.syncBody(req)

请记住，使用SpringBoot 2.0.3。释放，如果您将一个字符串作为请求传递给webClient，它将作为ContentType标头MediaType。TEXT_PLAIN，这使得我们与其他服务的集成失败。我们通过如下设置特定的内容类型头来解决这个问题：

httpHeaders.setContentType(MediaType.APPLICATION_JSON);

Answer 3

我也在努力解决同样的问题，因为我正在手动序列化请求（在我的例子中是JSON）并设置长度（Kotlin代码）：

open class PostRetrieverWith411ErrorFix(
    private val objectMapper: ObjectMapper
) {

protected fun <T : Any> post(webClient: WebClient, body: Any, responseClass: Class<T>): Mono<T> {
    val bodyJson = objectMapper.writeValueAsString(body)

    return webClient.post()
        .contentType(MediaType.APPLICATION_JSON_UTF8)
        .contentLength(bodyJson.toByteArray(Charset.forName("UTF-8")).size.toLong())
        .syncBody(bodyJson)
        .retrieve()
        .bodyToMono(responseClass)
    }
}