8.16. loop

loop 模式允许您多次处理消息。它主要用于测试。

默认情况下，循环在整个循环中使用相同的交换。上一个迭代的结果用于下一个（请参阅 第 5.4 节 “管道和过滤器”）。在 上，您可以从 Camel 2.8 中启用复制模式。详情请查看 options 表。

在每个循环迭代中，设置了两个交换属性，它们可以选择由循环中包含的任何处理器读取。

以下示例演示了如何从 direct:x 端点获取请求，然后重复向 mock:result 发送消息。循环迭代的数量被指定为 loop （） 的参数，或者在运行时评估表达式，其中表达式 必须 评估 int （或其他 RuntimeCamelException 被抛出）。

以下示例将循环计数作为常数传递：

from("direct:a").loop(8).to("mock:result");

以下示例评估一个简单的表达式来确定循环计数：

from("direct:b").loop(header("loop")).to("mock:result");

以下示例评估 XPath 表达式来确定循环计数：

from("direct:c").loop().xpath("/hello/@times").to("mock:result");

您可以在 Spring XML 中配置相同的路由。

以下示例将循环计数作为常数传递：

<route>
  <from uri="direct:a"/>
  <loop>
    <constant>8</constant>
    <to uri="mock:result"/>
  </loop>
</route>

以下示例评估一个简单的表达式来确定循环计数：

<route>
  <from uri="direct:b"/>
  <loop>
    <header>loop</header>
    <to uri="mock:result"/>
  </loop>
</route>

现在，假设我们向 direct:start 端点发送一条包含字母 A 的消息。处理此路由的输出将是这样，每个 mock:loop 端点都将接收 AB 作为消息。

from("direct:start")
     // instruct loop to use copy mode, which mean it will use a copy of the input exchange
     // for each loop iteration, instead of keep using the same exchange all over
     .loop(3).copy()
         .transform(body().append("B"))
         .to("mock:loop")
     .end()
     .to("mock:result");

但是，如果没有 启用复制模式，则 mock:loop 将接收 AB, ABB, ABBB 消息。

from("direct:start")
     // by default loop will keep using the same exchange so on the 2nd and 3rd iteration its
     // the same exchange that was previous used that are being looped all over
     .loop(3)
         .transform(body().append("B"))
         .to("mock:loop")
     .end()
     .to("mock:result");

复制模式中 XML DSL 中等效的示例如下：

<route>
   <from uri="direct:start"/>
   <!-- enable copy mode for loop eip -->
   <loop copy="true">
     <constant>3</constant>
     <transform>
       <simple>${body}B</simple>
     </transform>
     <to uri="mock:loop"/>
   </loop>
   <to uri="mock:result"/>
 </route>

loop DSL 命令支持以下选项：

您可以执行循环，直到使用 when loop 时 满足条件为止。条件为 true 或 false。

在 DSL 中，命令是 LoopDoWhile。以下示例将执行循环，直到消息正文长度为 5 个字符或更少：

from("direct:start")
    .loopDoWhile(simple("${body.length} <= 5"))
        .to("mock:loop")
        .transform(body().append("A"))
    .end()
    .to("mock:result");

在 XML 中，命令是 loop doWhile。以下示例还执行循环，直到消息正文长度为 5 个字符或更少：

<route>
  <from uri="direct:start"/>
  <loop doWhile="true">
    <simple>${body.length} <= 5</simple>
    <to uri="mock:loop"/>
    <transform>
      <simple>A${body}</simple>
    </transform>
  </loop>
  <to uri="mock:result"/>
</route>