Spring Integration自定义Header转换器Java DSL实现求助

是否必须实现HeaderMapper？ #

不需要完全从头实现HeaderMapper接口。你可以基于Spring提供的DefaultHttpHeaderMapper，通过两种方式实现需求：要么给它的ConversionService注册自定义转换器，要么继承它重写特定Header的处理逻辑。

方案1：注册自定义Converter到ConversionService #

这种方式更通用，适合全局处理特定类型的Header值转换。

步骤1：实现Converter #

创建转换器，将MessageChannel类型（errorChannel/replyChannel通常为此类型）转换为空字符串：

import org.springframework.core.convert.converter.Converter;
import org.springframework.messaging.MessageChannel;

public class MessageChannelToStringConverter implements Converter<MessageChannel, String> {
    @Override
    public String convert(MessageChannel source) {
        return "";
    }
}

步骤2：关联到DefaultHttpHeaderMapper #

配置ConversionService并绑定到HeaderMapper实例：

import org.springframework.context.support.ConversionServiceFactoryBean;
import org.springframework.integration.http.support.DefaultHttpHeaderMapper;
import java.util.Collections;

// 构建包含自定义转换器的ConversionService
ConversionServiceFactoryBean conversionServiceFactory = new ConversionServiceFactoryBean();
conversionServiceFactory.setConverters(Collections.singleton(new MessageChannelToStringConverter()));
conversionServiceFactory.afterPropertiesSet();

// 配置HeaderMapper
DefaultHttpHeaderMapper headerMapper = DefaultHttpHeaderMapper.outboundMapper();
headerMapper.setConversionService(conversionServiceFactory.getObject());

// 绑定到你的customOutbound
customOutbound.setHeaderMapper(headerMapper);
customOutbound.setMappedRequestHeaders("*");

方案2：继承DefaultHttpHeaderMapper重写处理逻辑 #

如果仅需针对errorChannel和replyChannel做特殊处理，继承DefaultHttpHeaderMapper重写映射逻辑更直接：

import org.springframework.integration.http.support.DefaultHttpHeaderMapper;
import org.springframework.http.HttpHeaders;

public class CustomHttpHeaderMapper extends DefaultHttpHeaderMapper {

    private static final String ERROR_CHANNEL = "errorChannel";
    private static final String REPLY_CHANNEL = "replyChannel";

    @Override
    protected void mapHeader(String headerName, Object headerValue, HttpHeaders httpHeaders) {
        if (ERROR_CHANNEL.equals(headerName) || REPLY_CHANNEL.equals(headerName)) {
            httpHeaders.set(headerName, "");
        } else {
            super.mapHeader(headerName, headerValue, httpHeaders);
        }
    }
}

然后配置使用自定义Mapper：

CustomHttpHeaderMapper customHeaderMapper = new CustomHttpHeaderMapper();
customHeaderMapper.setOutboundHeaderNames("*");

customOutbound.setHeaderMapper(customHeaderMapper);
customOutbound.setMappedRequestHeaders("*");

注意事项 #

• 若使用Spring Boot，可通过@Bean注册ConversionService或自定义HeaderMapper，确保被容器管理。
• 若errorChannel/replyChannel的实际类型不是MessageChannel，需调整Converter的源类型。

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