如何延迟Spring Boot应用关闭直至所有Spring Integration通道为空？

以下是适配Spring Integration 6.x的有效配置方案：

1. 全局配置Integration停机超时 #

在application.properties中添加：

# 设置全局Integration组件停机超时时间，单位毫秒
spring.integration.shutdown.timeout=60000

该配置会让Spring Integration在停机时，等待所有活跃的消息处理任务完成，超时后才强制终止。

2. 给异步ServiceActivator配置带等待逻辑的线程池 #

之前的线程池配置未生效，大概率是因为未绑定到ServiceActivator上。按以下步骤配置：

首先定义线程池Bean：

@Bean
public ThreadPoolTaskExecutor integrationTaskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(10);
    executor.setMaxPoolSize(10);
    executor.setQueueCapacity(40);
    // 关闭时等待所有任务完成
    executor.setWaitForTasksToCompleteOnShutdown(true);
    // 等待终止的超时时间（秒）
    executor.setAwaitTerminationSeconds(60);
    // 必须手动初始化，否则Spring无法正确处理线程池生命周期
    executor.initialize();
    return executor;
}

然后将该线程池绑定到ServiceActivator，两种方式任选：

方式一：使用@Async注解

@ServiceActivator(inputChannel = "inputChannel", poller = @Poller(fixedDelay = "100"))
@Async("integrationTaskExecutor")
public void processFileMessage(File message) {
    // 你的文件处理逻辑
}

方式二：在IntegrationFlow中指定

@Bean
public IntegrationFlow fileProcessingFlow() {
    return IntegrationFlow.from("inputChannel")
            .handle(this::processFileMessage, config -> config
                    .async(true)
                    .taskExecutor(integrationTaskExecutor()))
            .get();
}

3. 关键验证点 #

• 确保server.shutdown=graceful已在application.properties中配置，这是Spring Boot优雅停机的基础。
• 停止应用时，查看日志，应能看到线程池等待任务完成、Integration组件等待处理完成的相关日志。
• 测试时可向队列推送一批消息，触发停机后检查所有消息是否都被处理完毕。

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