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 的可用 os 使用 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 命令支持以下选项：