问Apache Camel迭代列表

EN

下面是一个拆分聚合和转换列表消息的完整示例。

1. camel拆分器提供了一个内置聚合器，用于聚合原始交换中的所有拆分消息。因此，拆分器只是聚合每个列表(Exchange)发送的“直接:开始”中的消息。您必须提供一个自定义聚合策略，因为在我的示例InOrder中，默认策略将使用原始交换。聚合策略是拆分定义的第二个参数。
2. 类型转换器使我们有机会在DSL中使用convertBodyTo。您还可以使用bean、处理器或执行自定义聚合策略中的所有转换来实现这一点。 包装；进口org.apache.camel.*；进口org.apache.camel.processor.aggregate.GroupedExchangeAggregationStrategy；；进口org.apache.camel.component.mock.MockEndpoint；进口org.apache.camel.processor.aggregate.GroupedExchangeAggregationStrategy；导入org.junit.Test；导入java.util.ArrayList；导入java.util.List；公共类CamelSplitAggregateConvertTest扩展CamelTestSupport {@ ProducerTemplate模板；@EndpointInject(uri =“java.util.List:out”)私有MockEndpoint模拟；@Test (){ InOrder inOrder1 =新InOrder()；inOrder1.setId("1")；InOrder inOrder2 =新InOrder()；inOrder2.setId("2")；列表inOrderList =新的ArrayList()；inOrderList.add(inOrder1)；inOrderList.add(inOrder2)；template.sendBody(“直接启动”，inOrderList)；mock.expectedMessageCount(1)；Exchange = mock.getReceivedExchanges().get(0)；List outOrderList = outList.getIn().getBody(List.class)；assertEquals(1，outOrderList.get(0).getBody())；context.getTypeConverterRegistry().addTypeConverter(OutOrder.class，(2，outOrderList.get(1).getId()；}@outOrderList.get受保护的RouteBuilder createRouteBuilder()抛出异常{返回新的RouteBuilder() {@覆盖公共虚配置()抛出异常{outOrderList.get InOrder.class，新MyOrderTypeConverter())；从(“直接:开始”) .split(body()，新AggregationStrategy() ){@覆盖公共交换聚合( Exchange oldExchange，Exchange newExchange) { if (oldExchange == null) { List orders =新ArrayList()；OutOrder newOrder = newExchange.getIn().getBody(OutOrder.class)；orders.add(newOrder)；newExchange.getIn().setBody(orders)；返回newExchange；} List orders = oldExchange.getIn().getBody(List.class)；OutOrder newOutOrder = newExchange.getIn().getBody(OutOrder.class)；orders.add(newOutOrder)；oldExchange.getIn().setBody(orders)；return；}) .convertBodyTo(OutOrder.class) .end() //拆分器在此结束，交换主体现在为List .to(“.end:out”)；}；}私有静态类MyOrderTypeConverter扩展了TypeConverterSupport { @SuppressWarnings("unchecked")公共T convertTo(类类型、交换、对象值){ //转换器，从convertTo到inorder order =新的OutOrder()；order.setId(Integer.parseInt(InOrder)值).getId())；返回(T)顺序；}}私有静态类OutOrder {私有int id；公共setId(int id) { this.id = id；}公共int getId() {返回id；}私有静态类InOrder {私有字符串id；公共空setId(字符串id) { this.id = id；}公共字符串getId() {返回id；}

对于将来的参考，可以迭代列表的另一种方法是使用Java的loop构造。下面是一个例子：

from("direct:myDirect")
.loop(header("LIST_LENGTH")) // You will set this header in the processor before with the list lenght.
.process(new Processor(){

      @Override
      public void proocess(Exchange arg0){
          MyObj currentElement = (MyObj) arg0.getIn().getBody(List.class).get(LOOP_INDEX);
          // Do your processing here.
      }
})
.end()
.end();

LOOP_INDEX属性将包含当前迭代，从0开始到LIST_LENGHT头值，因此您可以使用它从列表中获取当前元素。

注意双end()方法调用:一个用于结束循环，另一个用于结束路由。

文档：http://camel.apache.org/loop.html

拆分器和聚合器是正确的，来自http://camel.apache.org/splitter.html的“拆分聚合请求/回复示例”显示了您所需要的。

您需要在拆分器之后的“转换”对象列表吗？如果是的话，http://camel.apache.org/aggregator2.html中的“在http://camel.apache.org/aggregator2.html中使用列表”这一点看上去很适合您的需要。

好心的问候，土工