如何为每个Spring Integration流程配置独立日志文件？

针对你这种每个集成流程用独立ApplicationContext加载、需要单独日志文件的场景，我给你几个实操性很强的方案，刚好适配Spring Integration的日志体系：

方案一：利用日志框架的MDC+分流Appender实现（推荐） #

这是最通用的方案，适配Logback、Log4j2等主流日志框架，核心思路是给每个ApplicationContext打上唯一标识，通过MDC传递到日志框架，再按标识分流到不同文件。

步骤1：给每个ApplicationContext设置唯一标识并注入MDC #

在每个流程的spring-context.xml中，添加一个上下文初始化器，把当前上下文的ID（确保每个上下文ID唯一）放到MDC中：

public class ContextIdMdcInitializer implements ApplicationContextInitializer<ConfigurableApplicationContext> {
    @Override
    public void initialize(ConfigurableApplicationContext applicationContext) {
        String contextId = applicationContext.getId();
        // 把上下文ID放入MDC，后续日志会携带这个标识
        MDC.put("integrationFlowId", contextId);
        // 上下文关闭时清理MDC
        applicationContext.registerShutdownHook();
        applicationContext.addApplicationListener(event -> {
            if (event instanceof ContextClosedEvent) {
                MDC.remove("integrationFlowId");
            }
        });
    }
}

然后在对应的spring-context.xml中注册这个初始化器：

<context:property-placeholder/>
<bean class="com.yourpackage.ContextIdMdcInitializer"/>

步骤2：配置日志框架的分流Appender #

以Logback为例，使用SiftingAppender根据MDC中的integrationFlowId拆分日志文件：

<appender name="FLOW_SIFTER" class="ch.qos.logback.classic.sift.SiftingAppender">
    <discriminator>
        <key>integrationFlowId</key>
        <defaultValue>default-flow</defaultValue>
    </discriminator>
    <sift>
        <appender name="FLOW-${integrationFlowId}" class="ch.qos.logback.core.FileAppender">
            <file>logs/integration-${integrationFlowId}.log</file>
            <encoder>
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
            </encoder>
        </appender>
    </sift>
</appender>

<!-- 给Spring Integration的日志指定这个Appender -->
<logger name="org.springframework.integration" level="INFO" additivity="false">
    <appender-ref ref="FLOW_SIFTER"/>
</logger>

这样每条来自不同ApplicationContext的日志，都会自动写入对应integration-{flowId}.log文件中。

方案二：为每个ApplicationContext加载独立日志配置文件 #

如果每个流程的日志格式、级别差异较大，可以给每个ApplicationContext指定独立的日志配置文件。

实现方式 #

在加载每个ApplicationContext前，临时设置日志框架的配置文件路径，加载完成后恢复原配置（用ThreadLocal避免多线程冲突）：

// 加载流程1的上下文
ThreadLocal<String> originalLogConfig = ThreadLocal.withInitial(() -> System.getProperty("logback.configurationFile"));
try {
    System.setProperty("logback.configurationFile", "classpath:logback-flow1.xml");
    ApplicationContext flow1Context = new ClassPathXmlApplicationContext("flow1-context.xml");
} finally {
    String original = originalLogConfig.get();
    if (original != null) {
        System.setProperty("logback.configurationFile", original);
    } else {
        System.clearProperty("logback.configurationFile");
    }
    originalLogConfig.remove();
}

每个logback-flowX.xml中配置独立的FileAppender，比如：

<appender name="FLOW_FILE" class="ch.qos.logback.core.FileAppender">
    <file>logs/integration-flow1.log</file>
    <!-- 自定义格式、级别等 -->
</appender>
<root level="INFO">
    <appender-ref ref="FLOW_FILE"/>
</root>

方案三：扩展Spring Integration的日志Handler自定义输出 #

如果需要更细粒度的控制，可以扩展Spring Integration的MessageHistoryLoggingHandler，让它根据当前上下文定向到对应Logger。

自定义Handler #

public class ContextAwareMessageHistoryHandler extends MessageHistoryLoggingHandler {
    @Autowired
    private ApplicationContext applicationContext;

    @Override
    protected void logMessage(Message<?> message) {
        // 用上下文ID作为Logger的名称
        Logger flowLogger = LoggerFactory.getLogger("integration.flow." + applicationContext.getId());
        String logMessage = this.createLogMessage(message);
        flowLogger.info(logMessage);
    }
}

然后在每个流程的spring-context.xml中替换默认的<int:message-history/>：

<int:channel id="messageHistoryChannel"/>
<bean id="contextAwareHistoryHandler" class="com.yourpackage.ContextAwareMessageHistoryHandler">
    <property name="loggerName" value="ignored"/> <!-- 这里用自定义Logger，所以忽略默认值 -->
</bean>
<int:logging-channel-adapter channel="messageHistoryChannel" handler="contextAwareHistoryHandler"/>
<!-- 配置消息历史拦截器，把消息发送到上面的通道 -->
<int:message-history/>
<int:channel-interceptor pattern="*" order="1">
    <bean class="org.springframework.integration.history.MessageHistoryInterceptor">
        <property name="historyChannel" ref="messageHistoryChannel"/>
    </bean>
</int:channel-interceptor>

最后在日志配置中给每个integration.flow.{flowId}配置独立的Appender即可。

注意事项 #

• 确保每个ApplicationContext的id唯一，这是日志隔离的核心标识；
• 若使用线程池处理消息，需要维护MDC上下文传递，可使用Spring Integration的MDCPropagationChannelInterceptor；
• Log4j2的分流配置可使用RoutingAppender，逻辑和Logback的SiftingAppender一致。

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