Apache Camel，将文件移动到的重排序器。骆驼

Question

我正在尝试重新排序在Apache Camel之上编写的应用程序摄取文件的顺序。文件需要按设定的顺序处理，如果应用程序没有按顺序处理文件，则文件中数据的各种聚合和其他处理将失败。为了保护应用程序，我尝试使用重新排序器EIP来确保文件按顺序处理。但是我发现重新排序器似乎会导致文件在下游组件通过交换之前被移动到. camel目录中。

我写了一个简单的例子来说明这个问题：

import java.io.File;
import java.io.IOException;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;

public class CamelFileResequencerTest extends CamelTestSupport {

    @Test
    public void test() throws IOException, InterruptedException {
        File file1 = new File("target/input/1.txt");
        FileUtils.write(file1, "Hello Camel");
        FileUtils.write(new File("target/input/2.txt"), "Hello Camel");
        FileUtils.write(new File("target/input/3.txt"), "Hello Camel");
        Thread.sleep(100l);
        assertTrue(file1.exists());
        FileUtils.write(new File("target/input/4.txt"), "Hello Camel");
        FileUtils.write(new File("target/input/5.txt"), "Hello Camel");
        Thread.sleep(5000l);
        assertTrue(new File("target/output/1.txt").exists());
    }

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {

            @Override
            public void configure() throws Exception {
                from("file://target/input")
                    .resequence(header(Exchange.FILE_NAME_ONLY)).batch().size(3)
                    .to("file://target/output/");
            }
        };
    }
}

当测试尝试写入输出文件时，会引发异常，因为输入文件不再在输入目录中，而是已移动到 /target/input/.camel目录。

现在，我可以通过在重排序器之后添加处理bean来解决这个问题，从而将文件路径更改为中的路径。骆驼目录，但这对我来说似乎有点混乱。另一个选项是对文件名而不是文件重新排序（即，mesage的主体是作为字符串的文件名，而不是一般文件）。

是否有人在文件上使用了重排程序并可以提供建议？

Answer 1

停止将文件移动到。camel您可以在route builder的configure方法中将noop参数添加到文件使用者。如果使用Camel 1，您可以在此处阅读相关内容。x或此处（如果使用驼峰2.0以后的版本）

from("file://target/input?noop=true")

将文件移动到中的原因。camel目录与重排程序无关，而是camel中的实际文件生成器，如文档中所述：

默认情况下，Camel会将已使用的文件移动到子文件夹。相对于文件的使用位置的驼峰。

之后将跳过这些文件，因为Camel会忽略任何以点开头的文件。

希望这有帮助。