Spring Integration文件拆分示例入站适配器无响应问题排查

1. 入站文件适配器无法拾取文件的原因 #

测试类中的@SpringIntegrationTest(noAutoStartup = "fileInboundChannelAdapter")明确禁用了入站通道适配器的自动启动逻辑，这直接导致tmp/in目录的文件不会被扫描和拾取。如果你的测试需要完整走通文件处理流程，要么移除这个注解，要么在测试代码里手动启动适配器：

@Autowired
private SourcePollingChannelAdapter fileInboundChannelAdapter;

@Test
void testFileProcessing() {
    fileInboundChannelAdapter.start();
    // 后续断言逻辑
}

2. SpEL表达式错误的修复逻辑 #

移除禁用注解后出现EL1008E: Property or field 'tmp' cannot be found，是因为SpEL会把未加单引号的tmp/out当作上下文变量解析，但你的Spring环境里并没有名为tmp的变量。给路径字符串加上单引号（比如'tmp/out'），SpEL就会将其视为字面量字符串处理，而非变量引用，这就是修改后流程恢复正常的原因。

3. Transformer中表达式写法的解释 #

你写的'tmp/out/.*\\.txt'是一个SpEL字符串字面量，这里需要注意几个点：

• 单引号包裹是为了告诉SpEL这是固定字符串，不是动态表达式
• .*\\.txt是正则写法，但因为是Java字符串，所以用双反斜杠转义了点号（正则里.是通配符，转义后才表示字面量的.）
• 如果你的目标是生成每个文件的输出路径，这个写法其实不符合需求——它会把所有输出都指向同一个固定字符串，正确的做法应该结合原文件名动态生成，比如'tmp/out/' + #root.filename；如果是过滤文件，应该在入站适配器的filter属性里配置，而非transformer中。

4. 添加日志监控消息流程 #

要清晰查看消息基础设施的运行情况，推荐两种方式：

方式一：启用框架内置日志 #

在配置文件（如application.properties）中添加日志级别配置：

logging.level.org.springframework.integration=DEBUG
logging.level.org.springframework.messaging=DEBUG

这会打印消息发送、接收、通道流转、适配器调度等全链路的详细日志。

方式二：自定义通道拦截器或Wire Tap #

• 通道拦截器：给消息通道添加拦截器，自定义日志逻辑：

@Bean
public MessageChannel fileInputChannel() {
    DirectChannel channel = new DirectChannel();
    channel.addInterceptor(new ChannelInterceptor() {
        @Override
        public Message<?> preSend(Message<?> message, MessageChannel channel) {
            log.info("消息即将进入通道[{}]，负载内容: {}", channel.getBeanName(), message.getPayload());
            return message;
        }
    });
    return channel;
}

• Wire Tap：通过Wire Tap分流通道消息到日志处理器，不影响主流程：

@Bean
public IntegrationFlow fileProcessingFlow() {
    return IntegrationFlows.from(fileInboundChannelAdapter())
            .wireTap(flow -> flow.handle(msg -> log.debug("Wire Tap 捕获消息: {}", msg)))
            .transform(...)
            .handle(fileOut())
            .get();
}

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