对于最新的稳定版本,请使用 Spring Integration 6.3.4spring-doc.cn

对于最新的稳定版本,请使用 Spring Integration 6.3.4spring-doc.cn

如“MBean 导出器”中所述,MBean 导出器提供了一个名为 的 JMX 操作,该操作用于有序地停止应用程序。 该操作只有一个参数。 该参数指示操作等待多长时间(以毫秒为单位)以允许正在进行的消息完成。 该操作的工作原理如下:stopActiveComponentsLongspring-doc.cn

  1. 调用所有实现 .beforeShutdown()OrderlyShutdownCapablespring-doc.cn

    这样做可以让此类组件为关闭做好准备。 实现此接口的组件示例以及它们对此调用执行的操作包括:停止其侦听器容器的 JMS 和 AMQP 消息驱动适配器、停止接受新连接(同时保持现有连接打开)的 TCP 服务器连接工厂、丢弃(记录)收到的任何新消息的 TCP 入站终端节点,以及为任何新请求返回的 HTTP 入站终端节点。503 - Service Unavailablespring-doc.cn

  2. 停止任何活动通道,例如 JMS 或 AMQP 支持的通道。spring-doc.cn

  3. 停止所有实例。MessageSourcespring-doc.cn

  4. 停止所有入站 s(不是 )。MessageProducerOrderlyShutdownCapablespring-doc.cn

  5. 等待剩余的任何时间,如传递给操作的参数值所定义。Longspring-doc.cn

    这样做可以让任何正在进行的消息完成其旅程。 因此,在调用此操作时,选择适当的超时非常重要。spring-doc.cn

  6. 调用所有组件。afterShutdown()OrderlyShutdownCapablespring-doc.cn

    这样做可以让这些组件执行最终的关闭任务(例如,关闭所有打开的套接字)。spring-doc.cn

Orderly Shutdown Managed Operation 中所述,可以使用 JMX 调用此操作。 如果您希望以编程方式调用该方法,则需要注入或以其他方式获取对 . 如果定义上未提供任何属性,则 Bean 具有生成的名称。 如果同一个 JVM() 中存在多个 Spring 集成上下文,则此名称包含一个随机组件,以避免冲突。IntegrationMBeanExporterid<int-jmx:mbean-export/>ObjectNameMBeanServerspring-doc.cn

因此,如果您希望以编程方式调用该方法,我们建议您为 exporter 提供一个属性,以便您可以在应用程序上下文中轻松访问它。idspring-doc.cn

最后,可以使用 element 调用该操作。 有关详细信息,请参阅监视 Spring 集成示例应用程序<control-bus>spring-doc.cn

前面描述的算法在版本 4.1 中得到了改进。 以前,所有任务执行程序和计划程序都已停止。 这可能会导致实例中的中间流消息保留。 现在关闭使 poller 保持运行状态,以便排空和处理这些消息。QueueChannel
前面描述的算法在版本 4.1 中得到了改进。 以前,所有任务执行程序和计划程序都已停止。 这可能会导致实例中的中间流消息保留。 现在关闭使 poller 保持运行状态,以便排空和处理这些消息。QueueChannel