Spring Integration中如何按文件名过滤并路由至对应通道？

多过滤器入站适配器是否为常规方案？ #

这种为每个文件类型单独配置带过滤器的入站通道适配器的方案并非常规最优选择。它会带来配置冗余，新增文件类型时需要重复编写适配器逻辑，维护成本高，也不符合Spring Integration“单一入口+路由分发”的设计思路。

当前方案的评价 #

你当前通过自定义Transformer标记路由头、再用HeaderValueRouter分发的方案是可行的，但存在可优化点：

• 硬编码的contains判断无法满足正则匹配需求，灵活性不足
• 分支判断逻辑冗余，新增文件类型时需要修改Transformer代码

更优解决方案 #

方案1：自定义基于文件名正则的MessageRouter #

直接继承AbstractMessageRouter，一步完成文件名匹配与路由，省去中间Transformer环节：

@Component
public class FileNameRegexRouter extends AbstractMessageRouter {

    private final Map<Pattern, MessageChannel> channelMappings;

    // 通过构造器注入正则表达式与目标通道的映射
    public FileNameRegexRouter(Map<Pattern, MessageChannel> channelMappings) {
        this.channelMappings = channelMappings;
    }

    @Override
    protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {
        String fileName = message.getHeaders().get("file_remoteFile", String.class);
        // 遍历正则映射，匹配成功则返回对应通道
        for (Map.Entry<Pattern, MessageChannel> entry : channelMappings.entrySet()) {
            if (entry.getKey().matcher(fileName).matches()) {
                return Collections.singleton(entry.getValue());
            }
        }
        // 处理未匹配的文件，可返回默认通道或抛出异常
        return Collections.singleton(getDefaultOutputChannel());
    }
}

配置接入通道：

@Bean
@ServiceActivator(inputChannel = CHANNEL_STREAMED_DATA)
public FileNameRegexRouter fileNameRegexRouter(
        @Qualifier("channelA") MessageChannel channelA,
        @Qualifier("channelB") MessageChannel channelB,
        @Qualifier("channelC") MessageChannel channelC,
        @Qualifier("channelD") MessageChannel channelD,
        @Qualifier("channelUnmatched") MessageChannel channelUnmatched) {
    Map<Pattern, MessageChannel> mappings = new HashMap<>();
    mappings.put(Pattern.compile("^A\\.csv$"), channelA);
    mappings.put(Pattern.compile("^B\\.csv$"), channelB);
    mappings.put(Pattern.compile("^C\\.csv$"), channelC);
    mappings.put(Pattern.compile("^D\\.csv$"), channelD);
    
    FileNameRegexRouter router = new FileNameRegexRouter(mappings);
    router.setDefaultOutputChannel(channelUnmatched); // 可选：配置未匹配文件的 fallback 通道
    return router;
}

方案2：用SpEL简化HeaderValueRouter #

无需自定义Transformer，直接通过SpEL从文件名头生成路由键，简化流程：

@Bean
@ServiceActivator(inputChannel = CHANNEL_STREAMED_DATA)
public HeaderValueRouter router(
        @Qualifier("channelA") MessageChannel channelA,
        @Qualifier("channelB") MessageChannel channelB,
        @Qualifier("channelC") MessageChannel channelC,
        @Qualifier("channelD") MessageChannel channelD) {
    // 用SpEL提取文件名前缀（如A.csv取A）作为路由键
    HeaderValueRouter router = new HeaderValueRouter(
        "T(org.springframework.util.StringUtils).getFilenameWithoutExtension(headers['file_remoteFile'])"
    );
    router.setChannelMapping("A", channelA);
    router.setChannelMapping("B", channelB);
    router.setChannelMapping("C", channelC);
    router.setChannelMapping("D", channelD);
    return router;
}

如果需要正则匹配，可在SpEL中直接使用matches语法：

HeaderValueRouter router = new HeaderValueRouter(
        "headers['file_remoteFile'] matches '^A\\.csv$' ? 'channelA' : " +
        "headers['file_remoteFile'] matches '^B\\.csv$' ? 'channelB' : " +
        "headers['file_remoteFile'] matches '^C\\.csv$' ? 'channelC' : " +
        "headers['file_remoteFile'] matches '^D\\.csv$' ? 'channelD' : 'defaultChannel'"
);

方案3：使用内置RegexRouter #

Spring Integration提供了RegexRouter，可直接基于消息头的正则匹配完成路由，配置更简洁：

@Bean
@ServiceActivator(inputChannel = CHANNEL_STREAMED_DATA)
public RegexRouter regexRouter(
        @Qualifier("channelA") MessageChannel channelA,
        @Qualifier("channelB") MessageChannel channelB,
        @Qualifier("channelC") MessageChannel channelC,
        @Qualifier("channelD") MessageChannel channelD) {
    // 指定匹配的表达式为file_remoteFile头的值
    RegexRouter router = new RegexRouter("headers['file_remoteFile']");
    router.setChannelMapping("^A\\.csv$", channelA);
    router.setChannelMapping("^B\\.csv$", channelB);
    router.setChannelMapping("^C\\.csv$", channelC);
    router.setChannelMapping("^D\\.csv$", channelD);
    return router;
}

总结 #

• 不推荐使用多过滤器入站适配器，冗余且维护成本高
• 自定义Router、SpEL增强的HeaderValueRouter或内置RegexRouter都是更优选择，支持正则匹配，新增文件类型只需修改映射配置，无需改动核心逻辑

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