利用Apache Camel实现多文件的并行处理

Question

1. MaxMesssAgesPerPoll
2. 线程(10)
3. 聚合器

但是我在这里与聚合器没有任何关系，只需要从一个远程位置处理每个文件，处理它，然后将它们放在另一个远程位置。

Answer 1

可以使用下面的代码实现多线程。

public class RouterConfig extends RouteBuilder {
    public void configure() throws Exception {
        from("file:C:\datafiles\input?readLock=changed&readLockTimeout=100&readLockCheckInterval=20&maxMessagesPerPoll=3") 
        .threads(3, 3, "myThread")
        .process(new MyProcessor())
        .to("file:C:\datafiles\output");
    }
}

这里，threads api将创建3个线程。MaxMessageSperpoll=3将在一次轮询中选择3个文件，并将一个文件传递给一个线程，就像这里的情况一样，它选择3个文件(file1、file2、file3)并为一个文件提供3个线程(thread1、thread2、thread3)。

• 因此，“file1”将由“thread1”和
处理
• “文件2”将由“线程2”处理
• “文件3”将由“线程3”处理