Camel文件组件无法使用多个线程并行使用

Question

我有一个目录，文件正被一条骆驼路由推送到其中。从同一个目录，我需要多个线程来使用文件并处理它们。

<route id="processMessagesFromDirectory">
    <from uri="file:/directory?readLock=changed" />
        <threads poolSize="8"></threads>
        <doTry>
            <log message="process Initiated for ${body}" />
            <doCatch>
                <exception>java.lang.Exception</exception>
            </doCatch>
        </doTry>
    <log message="Processed ${body}" />
</route>

我知道使用1个线程，readlock=changed将引入至少1000ms的延迟。使用多个线程时，发生了同样的事情，一个线程等待1000ms拾取一个文件并进行处理，然后另一个线程拾取另一个文件并进行处理，等等。使用readlock=changed选项到底发生了什么？我怎样才能引入并行性呢？

通过不使用readlock=markerfile选项，我能够并行地处理它们，但我不想处理部分消息，也不想多次处理消息。我怎么能那样做？

Answer 1

如果需要使用readlock，可以将其值设置为markerfile。这将允许异步处理文件。

<routes xmlns="http://camel.apache.org/schema/spring">
    <route id="processMessagesFromDirectory">
        <from uri="file:/directory?readLock=markerFile" />
        <threads poolSize="8" />
            <doTry>
                <log message="process Initiated for ${body}" />
                <doCatch>
                    <exception>java.lang.Exception</exception>
                </doCatch>
            </doTry>
        <log message="Processed ${body}" />
    </route>
</routes>