如何在Spring Integration中向自定义Transformer传递配置属性？

好的，针对你想要给Spring Integration的Transformer传递自定义配置属性/执行指令的需求，我整理了几种非常实用的可行方案，你可以根据自己的场景选择：

方案1：利用消息头传递配置（最推荐，原生支持无需额外开发） #

Spring Integration本身就支持通过消息头（Message Headers）传递元数据，你可以先用header-enricher把你的配置属性注入到消息头里，然后自定义Transformer从消息头读取这些配置来执行对应逻辑。

配置示例（XML） #

<int:chain input-channel="AAA" output-channel="BBB">
    <!-- 先给消息添加配置型的头部信息 -->
    <int:header-enricher>
        <int:header name="transform_config_a" value="b+3"/>
    </int:header-enricher>
    <!-- 调用你的自定义Transformer -->
    <int:transformer ref="transformerBean"/>
</int:chain>

自定义Transformer代码 #

@Component("transformerBean")
public class CustomTransformer implements GenericTransformer<Message<?>, Object> {
    @Override
    public Object transform(Message<?> message) {
        // 从消息头里取出配置
        String configA = message.getHeaders().get("transform_config_a", String.class);
        
        // 这里根据你的配置逻辑处理消息payload
        Object originalPayload = message.getPayload();
        // 比如解析"b+3"做计算、调整转换规则等
        Object transformedPayload = doTransformation(originalPayload, configA);
        
        return transformedPayload;
    }
    
    private Object doTransformation(Object payload, String config) {
        // 实现你的具体转换逻辑
        return payload;
    }
}

这个方案的优势是完全基于Spring Integration原生能力，不需要任何扩展开发，而且可以动态给不同的消息传递不同的配置，灵活度拉满。

方案2：自定义XML命名空间（实现你设想的标签） #

如果你特别希望用你设想的<attribute>标签来配置，那可以通过自定义Spring XML命名空间来实现。这个需要一点扩展开发，但能完全匹配你想要的配置风格。

步骤1：自定义Transformer类（接收配置属性） #

@Component("transformerBean")
public class CustomTransformer implements GenericTransformer<Object, Object> {
    // 用来存储配置属性的Map
    private Map<String, String> configAttributes = new HashMap<>();

    // 提供setter方法，让Spring注入配置
    public void setConfigAttributes(Map<String, String> configAttributes) {
        this.configAttributes.putAll(configAttributes);
    }

    @Override
    public Object transform(Object payload) {
        // 读取配置并执行对应逻辑
        String configA = configAttributes.get("a");
        return doTransformation(payload, configA);
    }
    
    private Object doTransformation(Object payload, String config) {
        // 实现你的具体转换逻辑
        return payload;
    }
}

步骤2：编写XML扩展解析逻辑 #

你需要定义自己的XSD schema，然后实现NamespaceHandler和BeanDefinitionParser，把<attribute>标签里的key-value收集成Map，注入到transformerBean的configAttributes属性中。配置完成后，你就能像这样使用：

<integration:transformer input-channel="AAA" output-channel="BBB" ref="transformerBean">
    <my:attribute key="a" value="b+3"/>
</integration:transformer>

这个方案的优势是配置语义化极强，完全符合你的设想，但需要额外的XML扩展开发，适合需要在多个地方复用这种配置风格的场景。

方案3：直接通过Spring依赖注入配置（适合固定配置场景） #

如果你的配置是相对固定的，不需要动态调整，那可以直接通过Spring的依赖注入把配置传递给Transformer，不需要额外的消息处理。

代码示例 #

@Component("transformerBean")
public class CustomTransformer implements GenericTransformer<Object, Object> {
    // 直接注入配置，可以用@Value读取配置文件，或者注入配置类
    @Value("${transformer.config.a:default_b+3}")
    private String configA;

    @Override
    public Object transform(Object payload) {
        // 使用注入的配置执行转换逻辑
        return doTransformation(payload, configA);
    }
    
    private Object doTransformation(Object payload, String config) {
        // 实现你的具体转换逻辑
        return payload;
    }
}

XML配置 #

<int:transformer input-channel="AAA" output-channel="BBB" ref="transformerBean"/>

这个方案的优势是代码简洁，不需要额外的消息头或XML扩展，适合配置不需要动态变化的场景。

总结一下，如果你需要动态传递不同的配置，方案1是最优选择；如果追求配置的语义化和自定义风格，方案2可以满足你的设想；如果配置固定，方案3最省心。

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