Apache Camel：逐行处理文件

Question

我有一个要读取和处理的大文件。我不想将它完全加载到内存中，而是单独读取文件的每一行并对其执行操作。我在工作期间来到了这个实现：

@Override
public void configure() {
    from(fileSftpLocationUrl)
        .routeId("my-route")
        .onException(Exception.class).handled(true).bean(exchangeErrorHandler, "processError").end()
        .split(body().tokenize("\n")).streaming()
        .filter(/*condition for skip first and last line*/)
        .bean(/*my action*/)
        .to(String.format("activemq:%s", myQueue));
}

在开始读取文件之前，我跳过了页眉和页脚.filter(/*condition for skip first and last line*/)，在下一行我尝试开始逐行读取我的文件.split(body().tokenize("\n")).streaming()，但是出了点问题，我从文件中获取了所有信息完整的。在解析该数据并对它们执行操作时，我在 .bean(/*my action*/) 中看到了这个问题。

我认为我的问题在一开始就被隐藏了，因为算法看起来很奇怪，首先我描述了整个文件的条件（跳过页眉和页脚），然后我让 Camel 逐行处理，然后才特定行的操作。

我的问题是，如何更改此实现以便逐行处理文件？

Answer 1

我想我明白了。 默认情况下，拆分结果发送到FIRST下一个端点

from(...)
    .split(body().tokenize("\n")).streaming()
    .to("direct:processLine")

如果要发送到复杂的路由，则必须标记拆分结尾，例如

from(...)
       
     .split(body().tokenize("\n")).streaming()
        .filter(/*condition for skip first and last line*/)
        .bean(/*my action*/)
        .to(String.format("activemq:%s", myQueue))
     .end()
     .log("Split done");

如果省略 end()，则逻辑如下（见缩进）：

from(...)
       
     .split(body().tokenize("\n")).streaming()
        .filter(/*condition for skip first and last line*/)
     .end() // Implicit 
     .bean(/*my action*/)
     .to(String.format("activemq:%s", myQueue))         

-> 在您的尝试中，使用原始消息调用了 bean(...)（在执行拆分之后）

将其视为一种“for-loop”

for (String line: lines) 
filter(line);
bean.run(line);
sendto(...);

根本不一样：

for (String line: lines) {
  filter(line);
  bean.run();
  sendto(...);
}