无法使用Spring Reactive-WebClient将消息作为字符串发送

Question

我无法使用Spring-webflux WebClient向rest服务发送字符串消息。下面是代码片段：

public WebClient getWebClient(String baseUrl)
    {
        HttpClient httpClient = HttpClient.create()
                .tcpConfiguration(client ->
                        client.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
                        .doOnConnected(conn -> conn
                                .addHandlerLast(new ReadTimeoutHandler(10))
                                .addHandlerLast(new WriteTimeoutHandler(10))));
         
        ClientHttpConnector connector = new ReactorClientHttpConnector(httpClient);     
     
        return WebClient.builder()
                .baseUrl(baseUrl)
                .clientConnector(connector)
                //.defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .build();
    }

Mono<String> response = getWebClient(someBaseUrl).post()
                .uri(postUri) //post mapping URI
                .contentType(MediaType.TEXT_HTML)
                .body(Mono.just(payload), String.class) //message to be sent
                .retrieve()
                .bodyToMono(String.class); //type of response to receive

response.subscribe(
                value -> log.info("Response from Web service : "+value), 
                error -> log.error("Response from Web Service : "+error.getMessage()) 
                );

@PostMapping("/test")
    public String test(String message) {
        System.out.println("Received message : "+message);
        return "Success";
    }

Answer 1

您应该使用@RequestBody对字符串消息进行注释。

例如：

@PostMapping("/test")
public String test(@RequestBody String message) {
  System.out.println("Received message : "+message);
  return "Success";
}