如何优雅关闭Spring Integration中Kotlin挂起函数实现的服务激活器？

我正在尝试结合使用Spring Integration与Kotlin协程，功能层面运行良好，但在停止应用时，挂起函数会被中途取消。这和Spring Webflux未设置server.shutdown=graceful选项时反应流被中途取消的行为类似——不过如果在挂起函数里加阻塞操作，倒是能实现优雅关闭。

想请教：Spring Integration是否支持响应式场景下的优雅关闭？如果支持，有哪些配置或实现方式？

我已经查阅过GitHub问题和官方文档，只找到“Orderly Shutdown”相关内容。虽然可以通过创建独立协程作用域加关闭钩子等待任务结束来实现优雅关闭，但这种方式会产生重复代码，所以想知道Spring Integration有没有类似Webflux的优雅关闭配置。

测试代码如下：

@Configuration
@IntegrationComponentScan
class TestConfiguration {
    private val log = LoggerFactory.getLogger(TestConfiguration::class.java)

    @Bean
    fun testChannel() = DirectChannel()

    @Bean
    fun router() = coRouter {
        POST("/test", this@TestConfiguration::handle)
    }

    private suspend fun handle(request: ServerRequest): ServerResponse {
        val message = object : Message<String> {
            override fun getPayload(): String {
                return "test"
            }

            override fun getHeaders(): MessageHeaders {
                return MessageHeaders(emptyMap())
            }
        }

        testChannel().send(message)

        return ServerResponse.ok().buildAndAwait()
    }

    @ServiceActivator(inputChannel = "testChannel")
    suspend fun handler1(payload: String) {
        repeat(1000) {
            log.info("delay $it")
            Thread.sleep(100)
        }
    }
}

Spring Integration 支持响应式/协程场景下的优雅关闭，核心依赖其Orderly Shutdown机制，结合Spring Boot的优雅关闭配置即可实现，无需自行编写重复的协程作用域和关闭钩子逻辑。具体实现方式如下：

1. 启用Spring Boot全局优雅关闭 #

在配置文件中开启全局优雅关闭，给所有组件预留任务完成时间：

# application.properties
spring.lifecycle.timeout-per-shutdown-phase=30s
server.shutdown=graceful

该配置会让Spring Boot在触发关闭流程时，等待所有支持优雅关闭的组件完成正在处理的任务，超时后才强制终止。

2. 配置Spring Integration的Orderly Shutdown #

Spring Integration的Orderly Shutdown默认启用，可通过配置调整细节：

• 自定义关闭顺序与超时：通过IntegrationProperties配置类调整Integration组件的关闭优先级和自身超时时间：

@Bean
fun integrationProperties(): IntegrationProperties {
    val props = IntegrationProperties()
    props.shutdown.order = -100 // 让Integration组件优先于其他组件启动关闭流程
    props.shutdown.timeout = Duration.ofSeconds(30) // 设置Integration内部任务的等待超时
    return props
}

• 协程任务自动纳入跟踪：对于coRouter、协程版ServiceActivator这类组件，Spring Integration会自动将正在执行的协程任务纳入Orderly Shutdown的等待队列，确保任务完成后再关闭组件。

3. 关键注意事项 #

• 替换Thread.sleep()为协程友好的delay()：测试代码中的Thread.sleep()会阻塞线程，实际场景建议用delay(100)替代，Spring Integration能更精准地跟踪协程挂起状态，避免任务被误取消。
• 避免自定义未绑定生命周期的协程作用域：如果必须自定义协程作用域，需将其绑定到Spring生命周期（比如实现SmartLifecycle），但借助Orderly Shutdown可省去这部分自定义代码。
• 默认通道调度器已适配：DirectChannel等默认通道的调度器已支持优雅关闭，无需额外配置。

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