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 的 os，您可以在运行时调整这个值，例如，您可以提供一个带有值的标头。运行时 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 计划在以后要执行的任务。该任务负责处理路由的后者部分（在节流后）。这允许调用者线程取消阻塞和服务进一步传入的消息。例如：

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

throttle DSL 命令支持以下选项：