2.9. 控制路由启动和关闭

默认情况下，当 Apache Camel 应用程序（由 CamelContext 实例表示）启动时，路由会自动启动，并在 Apache Camel 应用程序关闭时自动关闭路由。对于非关键部署，关闭序列的详情通常并不重要。但在生产环境中，现有任务在关机期间应该运行已完成，以避免数据丢失。您通常还需要控制路由关闭的顺序，以便不违反依赖项（这样可防止现有任务运行完成）。

因此，Apache Camel 提供了一组功能来支持应用程序 安全关闭。正常关闭可让您完全控制停止和启动路由，允许您控制路由的关闭顺序并启用当前任务完成。

为您的每个路由分配一个路由 ID 是很好的做法。除了使日志记录消息和管理功能更明确的情况下，使用路由 ID 可让您对停止和启动路由应用更大的控制。

例如，在 Java DSL 中，您可以通过调用 routeId （） 命令，将路由 ID myCustomerRouteId 分配给路由：

from("SourceURI").routeId("myCustomRouteId").process(...).to(TargetURI);

在 XML DSL 中，设置 route 元素的 id 属性，如下所示：

<camelContext id="CamelContextID" xmlns="http://camel.apache.org/schema/spring">
  <route id="myCustomRouteId" >
    <from uri="SourceURI"/>
    <process ref="someProcessorId"/>
    <to uri="TargetURI"/>
  </route>
</camelContext>

默认情况下，CamelContext 在启动时知道的所有路由都将自动启动。但是，如果要手动控制特定路由的启动，您可能需要为该路由禁用自动启动。

要控制 Java DSL 路由是否自动启动，请调用自动启动命令，使用布尔值参数(true 或 false)或 String 参数(true 或 false)。 例如，您可以在 Java DSL 中禁用路由自动启动，如下所示：

from("SourceURI")
  .routeId("nonAuto")
  .autoStartup(false)
  .to(TargetURI);

您可以通过在 route 元素中将 autoStartup 属性设置为 false 来禁用 XML DSL 中 路由的 自动启动，如下所示：

<camelContext id="CamelContextID" xmlns="http://camel.apache.org/schema/spring">
  <route id="nonAuto" autoStartup="false">
    <from uri="SourceURI"/>
    <to uri="TargetURI"/>
  </route>
</camelContext>

您可以通过调用 CamelContext 实例上的 startRoute （） 和 stopRoute （） 方法，随时手动启动或停止路由。例如，要启动路由 ID nonAuto 的路由，请在 CamelContext 实例上调用 startRoute （） 方法，如下所示：

// Java
context.startRoute("nonAuto");

要停止具有路由 ID nonAuto 的路由，请在 CamelContext 实例上调用 stopRoute （） 方法，如下所示：

// Java
context.stopRoute("nonAuto");

默认情况下，Apache Camel 以非确定顺序启动路由。但是，在某些应用程序中，控制启动顺序非常重要。要控制 Java DSL 中的启动顺序，请使用 startupOrder （） 命令，该命令使用正整数值作为其参数。带有最低整数值的路由会首先启动，然后是具有后续启动顺序值的路由。

例如，以下示例中的前两个路由通过 seda:buffer 端点链接在一起。您可以通过分配启动顺序(2 和 1)来确保第一个路由片段在第二个路由段后启动，如下所示：

from("jetty:http://fooserver:8080")
    .routeId("first")
    .startupOrder(2)
    .to("seda:buffer");

from("seda:buffer")
    .routeId("second")
    .startupOrder(1)
    .to("mock:result");

// This route's startup order is unspecified
from("jms:queue:foo").to("jms:queue:bar");

或者在 Spring XML 中，您可以通过设置 route 元素的 startupOrder 属性来实现相同的效果，如下所示：

<route id="first" startupOrder="2">
    <from uri="jetty:http://fooserver:8080"/>
    <to uri="seda:buffer"/>
</route>

<route id="second" startupOrder="1">
    <from uri="seda:buffer"/>
    <to uri="mock:result"/>
</route>

<!-- This route's startup order is unspecified -->
<route>
    <from uri="jms:queue:foo"/>
    <to uri="jms:queue:bar"/>
</route>

每个路由必须 分配唯一的 启动顺序值。您可以选择小于 1000 的任何正整数值。1000 和 over 值是为 Apache Camel 保留的值，它会自动将这些值分配给路由，而无需显式启动值。例如，上例中的最后一个路由将自动分配启动值 1000 （因此在前两个路由后启动）。

当 CamelContext 实例关闭时，Apache Camel 会使用可插拔关闭 策略 控制关闭 序列。默认关闭策略实现以下关闭序列：

路由按照启动顺序的反向关闭。也就是说，当使用 startupOrder （） 命令（在 Java DSL 中）或 startupOrder 属性（在 XML DSL 中）定义启动顺序时，要关闭的第一个路由是具有由启动顺序分配的最高整数值的路由。

例如，在 例 2.5 “Java DSL 中的启动顺序” 中，要关闭的第一个路由片段是 ID 为第一个 的路由，第一个，第二个路由片段是 ID 为 second 的路由。本例演示了一个常规规则，您应该在关闭路由时观察它： 公开外部可访问的消费者端点的路由应首先关闭，因为这有助于通过路由图形的其余部分来节流消息流。

如果路由在关闭启动时仍然处理消息，则关闭策略通常会等待当前活跃的交换完成处理，然后再关闭路由。可以使用 shutdownRunningTask 选项在每个路由上配置此行为，该选项可取以下值之一：

例如，要安全地关闭文件消费者端点，您应该指定 CompleteAllTasks 选项，如以下 Java DSL 片段所示：

// Java
public void configure() throws Exception {
    from("file:target/pending")
        .routeId("first").startupOrder(2)
        .shutdownRunningTask(ShutdownRunningTask.CompleteAllTasks)
        .delay(1000).to("seda:foo");

    from("seda:foo")
        .routeId("second").startupOrder(1)
        .to("mock:bar");
}

相同的路由可以在 XML DSL 中定义，如下所示：

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
    <!-- let this route complete all its pending messages when asked to shut down -->
    <route id="first"
           startupOrder="2"
           shutdownRunningTask="CompleteAllTasks">
        <from uri="file:target/pending"/>
        <delay><constant>1000</constant></delay>
        <to uri="seda:foo"/>
    </route>

    <route id="second" startupOrder="1">
        <from uri="seda:foo"/>
        <to uri="mock:bar"/>
    </route>
</camelContext>

关闭超时的默认值为 300 秒。您可以通过在 shutdown 策略上调用 setTimeout （） 方法来更改超时的值。例如，您可以将超时值改为 600 秒，如下所示：

// Java
// context = CamelContext instance
context.getShutdownStrategy().setTimeout(600);

如果您要实施自定义 Apache Camel 组件（也从 org.apache.camel.Service 接口继承），您可以通过实施 org.apache.camel.spi.ShutdownPrepared 接口来确保自定义代码收到关闭通知。这为组件提供了执行自定义代码以准备关闭的机会。