8.8. Throttler

throttler 是一个处理器，限制了传入消息的流率。您可以使用此模式来保护目标端点不受过载。在 Apache Camel 中，您可以使用 throttle（） Java DSL 命令实施节流模式。

要将流率限制为每秒 100 个消息，请定义路由，如下所示：

from("seda:a").throttle(100).to("seda:b");

如果需要，您可以使用 timePeriodMillis（） DSL 命令自定义管理流率的时间段。例如，要将流率限制为每 30000 毫秒的 3 个消息，请按如下所示定义路由：

from("seda:a").throttle(3).timePeriodMillis(30000).to("mock:result");

以下示例演示了如何在 XML 中配置前面的路由：

<camelContext id="throttleRoute" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="seda:a"/>
    <!-- throttle 3 messages per 30 sec -->
    <throttle timePeriodMillis="30000">
      <constant>3</constant>
      <to uri="mock:result"/>
    </throttle>
  </route>
</camelContext>

可用的 Camel 2.8 Since 使用 Expression，您可以在运行时调整这个值，例如，为标头提供值。运行时 Camel 评估表达式并将结果转换为 java.lang.Long 类型。在以下示例中，我们使用邮件中的标头来决定每个期间的最大请求。如果缺少标头，则 第 8.8 节 “Throttler” 使用旧值。因此，在要更改值时，只允许提供标头：

<camelContext id="throttleRoute" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="direct:expressionHeader"/>
    <throttle timePeriodMillis="500">
      <!-- use a header to determine how many messages to throttle per 0.5 sec -->
      <header>throttleValue</header>
      <to uri="mock:result"/>
    </throttle>
  </route>
</camelContext>

throttler 可以启用 非阻塞异步延迟，这意味着 Apache Camel 将计划以后要执行的任务。该任务负责处理路由的后方（throttler 后）。这允许调用器线程取消阻塞和服务进一步传入的信息。例如：

from("seda:a").throttle(100).asyncDelayed().to("seda:b");

throttle DSL 命令支持以下选项：