Spring Integration中Reactive Outbound Adapter带请求体的POST使用方法

核心逻辑：利用消息Payload自动作为请求体 #

WebFluxRequestExecutingMessageHandler 本身已封装WebClient的请求构建逻辑，当你设置HttpMethod.POST后，它会自动将输入消息的Payload作为POST请求体发送，无需手动调用WebClient的body()方法（这也是你之前直接调用WebClient会立即执行请求的原因——绕过了handler的消息驱动逻辑）。

基础配置示例 #

修改你的handler配置，添加内容类型设置，确保请求体正确序列化：

@Bean
@ServiceActivator(inputChannel = "reactiveHttpOutRequest")
public WebFluxRequestExecutingMessageHandler reactiveOutbound(WebClient client) {
    WebFluxRequestExecutingMessageHandler handler =
            new WebFluxRequestExecutingMessageHandler("http://localhost:8080/foo", client);
    handler.setHttpMethod(HttpMethod.POST);
    // 设置请求内容类型，确保Payload被正确序列化（比如JSON）
    handler.setContentType(MediaType.APPLICATION_JSON_VALUE);
    handler.setExpectedResponseType(String.class);
    return handler;
}

当你向reactiveHttpOutRequest通道发送消息时，比如：

Message<MyPojo> message = MessageBuilder.withPayload(new MyPojo("test"))
        .build();
reactiveHttpOutRequest.send(message);

handler会自动将MyPojo实例序列化为JSON，作为POST请求体发送到目标地址。

自定义请求体（不使用默认Payload） #

如果需要从消息的其他部分（比如Header）生成请求体，可以通过setRequestBodyExpression方法用SpEL表达式指定：

handler.setRequestBodyExpression(new SpelExpressionParser().parseExpression("headers['requestBody']"));

这样handler会从消息Header的requestBody字段中读取内容作为请求体。

关于你之前的WebClient使用误区 #

直接调用WebClient.post().body(...)会立即触发请求，这是WebClient的原生调用方式；而WebFluxRequestExecutingMessageHandler是基于消息驱动的，只有当有消息进入输入通道时才会触发WebClient请求，且内部已处理请求体的绑定逻辑，无需手动干预WebClient的请求构建。

内容的提问来源于stack exchange，提问作者user521990