Spring Integration WebFlux：int-webflux:inbound-gateway的message-converters等价配置问题

WebFlux版本的int-webflux:inbound-gateway完全支持返回体转换，只是它没有MVC版本那样直接的message-converters属性，而是基于WebFlux的响应式编解码机制做配置，等价配置方式如下：

1. 全局配置编解码器（推荐） #

WebFlux的消息转换依赖ServerCodecConfigurer，你可以定义这个Bean并自定义编解码规则，所有int-webflux:inbound-gateway都会自动复用这个全局配置：

Java配置示例 #

@Bean
public ServerCodecConfigurer serverCodecConfigurer() {
    ServerCodecConfigurer configurer = ServerCodecConfigurer.create();
    // 注册自定义编解码器
    configurer.customCodecs().register(new MyCustomCodec());
    
    // 配置Jackson编解码器（以JSON处理为例）
    ObjectMapper objectMapper = new ObjectMapper();
    objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
    configurer.defaultCodecs().jackson2JsonDecoder(new Jackson2JsonDecoder(objectMapper));
    configurer.defaultCodecs().jackson2JsonEncoder(new Jackson2JsonEncoder(objectMapper));
    
    return configurer;
}

XML配置示例 #

<!-- 定义自定义的ServerCodecConfigurer -->
<bean id="customCodecConfigurer" class="org.springframework.http.codec.ServerCodecConfigurer" factory-method="create">
    <!-- 可通过自定义BeanPostProcessor或直接配置内部属性修改编解码器 -->
</bean>

<!-- 引用到网关 -->
<int-webflux:inbound-gateway id="webfluxGateway"
                             request-channel="requestChannel"
                             reply-channel="replyChannel"
                             codec-configurer="customCodecConfigurer"/>

2. 单个网关单独配置 #

如果只想给特定网关配置转换规则，可以直接指定encoder和decoder属性，绑定对应的编解码器Bean：

XML配置示例 #

<int-webflux:inbound-gateway id="specificWebfluxGateway"
                             request-channel="specificRequestChannel"
                             reply-channel="specificReplyChannel"
                             encoder="customJsonEncoder"
                             decoder="customJsonDecoder"/>

<!-- 自定义JSON编码器 -->
<bean id="customJsonEncoder" class="org.springframework.http.codec.json.Jackson2JsonEncoder">
    <constructor-arg>
        <bean class="com.fasterxml.jackson.databind.ObjectMapper">
            <property name="dateFormat">
                <bean class="java.text.SimpleDateFormat">
                    <constructor-arg value="yyyy-MM-dd HH:mm:ss"/>
                </bean>
            </property>
        </bean>
    </constructor-arg>
</bean>

<!-- 自定义JSON解码器 -->
<bean id="customJsonDecoder" class="org.springframework.http.codec.json.Jackson2JsonDecoder">
    <constructor-arg>
        <bean class="com.fasterxml.jackson.databind.ObjectMapper">
            <property name="dateFormat">
                <bean class="java.text.SimpleDateFormat">
                    <constructor-arg value="yyyy-MM-dd HH:mm:ss"/>
                </bean>
            </property>
        </bean>
    </constructor-arg>
</bean>

补充说明 #

MVC版本用HttpMessageConverter处理消息转换，而WebFlux基于响应式流设计，用HttpMessageReader（对应decoder）和HttpMessageWriter（对应encoder）替代，两者功能等价，只是API适配了响应式场景。

内容的提问来源于stack exchange，提问作者al.truisme