完成所有文件的所有进程后，如何在 spring 集成中创建自动关闭？我的应用程序使用大量文件作为输入并使用 http 出站网关作为最后一个端点，因此我对每个文件输入都有 http 出站请求，并且我尝试使用来自该端点的最后一个 http 响应作为关闭的触发器（context.close ()) 弹簧集成。我的想法是尝试使用 (System.currentTime()-lastTimeGatewayResponse)>= idleTime 作为触发器。但我没有找到从该网关获取 lastTimeGatewayResponse 的方法。
然后我尝试关注http://forum.spring.io/forum/spring-projects/integration/116366-orderly-shutdown-how-to-know-when-downstream-executor-is-idle。但我认为这不是最好的方法，因为我的应用程序在进程未完成时关闭了。
有人有这方面的经验吗？
谢谢
【问题讨论】：
如果您使用的是 4.2.x（当前版本为 4.2.6），您可以在回复频道拨打channel.getTimeSinceLastSend()。
javadocs 说它以秒为单位，但这是不正确的，它是毫秒。
【讨论】：
嗯，实际上lastTimeGatewayResponse 可能完全等同于该网关上reply-channel 中的timeSinceLastSend。
因此，您可以将 nullChannel 指定为您的 http 出站网关的 output (reply-channel) 并跟踪其 timeSinceLastSend 以执行您的关闭逻辑。
另一方面，尝试使用<aggregator> 完成类似但更稳健的行为。您可以将correlationKey 用作所有文件的静态内容，并作为<aggregator> 的输入操作触发关闭。发布策略可能是你输入文件的数量。
【讨论】：
main，通常它会在上下文刷新后立即停止，因为没有什么可以阻止该主线程。无论如何，您可以访问timeSinceLastSend 属性，从该上下文中获取MessageChannel bean。您应该定期执行此操作或作为每个文件进程的附带事件的问题。只是因为你需要在最后一个之后有idle time。