问当readLock=changed时Camel文件组件吞吐量

EN

我使用Apache将文件从输入目录传输到messagebroker。这些文件是通过SFTP编写的。为了避免使用仍在传输中的不完整文件，我设置了readLock=changed和readLockCheckInterval=3000。

举个例子，我的一个测试是这样的：

    <route>
        <from uri="file:inbox?readLock=changed&amp;readLockCheckInterval=3000"/>
        <log message="copying ${file:name}"/>
        <to uri="file:outbox"/>
    </route>

我用(echo line 1; sleep 2; echo line 2) > inbox/test对此进行测试，当readLockCheckInterval=3000时，文件将被忠实地复制。但是，这不会扩展，因为file组件将在处理每个文件之前等待三秒钟。所以当我用

for n in $(seq 1 100); do (echo line 1; sleep 2; echo line 2) > inbox/$n & done

将文件从inbox移动到outbox需要5分钟。

我读过“骆驼在行动”中关于并行处理的章节。但是，这些示例侧重于对单个消耗文件中行的并行处理。我找不到一种方法来并行化消费者本身。

在我的用例中，每秒大约一个文件的吞吐量是可以的。我只是不喜欢为了实现这个目标而被迫冒不完整数据的风险的想法。无论如何，readLock=changed设置似乎是一个黑客，但我们不能告诉客户复制然后移动，因此似乎没有其他选择。

面对网络延迟，我如何在不牺牲完整性的情况下提高吞吐量？