8.16. loop

loop

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

默认情况下,循环在循环过程中使用相同的交换。上一个迭代的结果用于下一个(请参阅 第 5.4 节 “pipes 和 Filters”)。您可以从 上的 Camel 2.8 来启用复制模式。详情请查看 options 表。

Exchange 属性

在每个循环迭代中,会设置两个交换属性,可选择性地读取循环中包含的任何处理器。

属性描述

CamelLoopSize

Apache Camel 2.0: 总数

CamelLoopIndex

Apache Camel 2.0:当前迭代的索引(基于 0)

Java DSL 示例

以下示例演示了如何从 direct:x 端点获取请求,然后重复将消息发送到 模拟结果。循环迭代数量被指定为 loop() 的参数,或者通过评估表达式在运行时评估表达式,其中表达式 必须 评估到 int (或者其它 运行时操作Exception 被抛出)。

以下示例将循环计数作为恒定进行传递:

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");

XML 配置示例

您可以在 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>

使用复制模式

现在假定我们发送一条消息以包括字母 A。处理此路由的输出将是该路由,每个 模拟: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");

但是,如果没有 启用复制模式,那么 loop 将接收 ABB、ABB 消息。

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 命令支持以下选项:

名称

默认值

描述

复制

false

Camel 2.8: 是否使用复制模式。若为 false,则在循环过程中都会使用相同的 Exchange。因此,下一个迭代的结果会显示。相反,您可以启用复制模式,然后每个迭代都会使用输入 “交换”一节 的新副本 重启

Dole Loop

您可以执行循环,直到在 loop 使用一个条件满足条件。该条件可以是 true 或 false。

在 DSL 中,命令为 Loop DoWhile。以下示例将执行循环,直到邮件正文长度为 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>