Spring Integration无XML配置实现流程日志记录的问题

你遇到的问题核心是Bean初始化时机导致的固定值问题：当你在enrichHeaders里直接硬编码startTime的赋值逻辑（比如h.header("startTime", System.currentTimeMillis())），这个值会在Spring容器初始化processFileFlow这个Bean的时候就被计算并固定下来，后续每次执行流程都会复用这个初始化时的固定值，而不是每次流程启动时重新计算。

下面给你几个可行的解决办法：

方法1：使用SpEL表达式动态获取当前时间 #

Spring Integration支持在enrichHeaders中使用SpEL表达式，这样每次执行到这个步骤时都会重新计算表达式的值：

@Bean
public IntegrationFlow processFileFlow() {
    return IntegrationFlows
            .from(FILE_CHANNEL_PROCESSING)
            .transform(fileToStringTransformer())
            .enrichHeaders(h -> h
                    .headerExpression("startTime", "T(System).currentTimeMillis()")
                    // 其他header配置
            )
            // 后续流程步骤
            .get();
}

这里的T(System).currentTimeMillis()会在每次消息经过这个enrich步骤时实时计算当前时间，完美解决固定值问题。

方法2：使用Supplier动态提供值 #

如果你更倾向于Java代码的方式而不是SpEL，可以用Supplier来延迟计算时间，这样每次调用都会获取最新的时间：

@Bean
public IntegrationFlow processFileFlow() {
    return IntegrationFlows
            .from(FILE_CHANNEL_PROCESSING)
            .transform(fileToStringTransformer())
            .enrichHeaders(h -> h
                    .header("startTime", (Supplier<Long>) System::currentTimeMillis)
                    // 其他header配置
            )
            // 后续流程步骤
            .get();
}

Supplier的get()方法会在每次消息处理时被调用，所以每次都会拿到当前的时间戳。

方法3：自定义HeaderEnricher（进阶场景） #

如果你的时间处理逻辑比较复杂（比如需要格式化日期、加入时区等），可以自定义一个HeaderEnricher的实现：

public class DynamicStartTimeEnricher extends HeaderEnricher {
    public DynamicStartTimeEnricher() {
        super(Map.of("startTime", new StaticHeaderValueMessageProcessor<>(
                (Supplier<String>) () -> LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_DATE_TIME)
        )));
    }
}

// 在Flow中使用
@Bean
public IntegrationFlow processFileFlow() {
    return IntegrationFlows
            .from(FILE_CHANNEL_PROCESSING)
            .transform(fileToStringTransformer())
            .enrichHeaders(new DynamicStartTimeEnricher())
            // 后续流程步骤
            .get();
}

这种方式适合需要更复杂逻辑的场景，灵活性更高。

最后提醒一下：如果后续需要计算流程执行耗时，可以在流程的最后一步再获取一次当前时间，和startTime做差值即可，同样要注意用动态方式获取结束时间哦！

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