apache-camel - 如何在 Camel 中将列表拆分为更小的列表？

Question

我的流程是从文件中读取数据，转换为 CSV，然后将每一行转换为对象。所以我最终得到了一个列表。现在我想把它分成更小的列表，并并行处理每个列表。我可以使用 split() 来获取单个条目，但我使用聚合的所有尝试都没有产生列表，只有单个项目。

from("file://")
  .unmarshal(csvDataFormat)
  .to("bean:personReader")
  .split(body())
  .aggregate( ??? )
  .to("bean:send")

Answer 1

您是在谈论组合消息处理器 eip 模式:http://camel.apache.org/composed-message-processor.html在哪里可以进行 fork/join 处理？

如果是这样，请查看上面的链接，并查看带有 splitter only 的示例，因为 Camel 中的拆分器 eip 已内置聚合，因此您可以将所有拆分的消息连接到一个单一的再次留言。