我正在使用 switchyard,它是 apache camel 的包装器。我的文件使用者从写入大量文件(有时 2,000,000)的目录中消费。我的消费者的理想消费速度是每秒 1000+ 个文件,但是当写入超过 50000 个文件时,我的消费者会变慢,消费速度会降低 5 倍。
我禁用了 sortBy 选项,甚至启用了 shuffle 选项。但没有运气。这是我的文件绑定细节。
<file:binding.file name="XXXXXXXXXXXX">
<file:additionalUriParameters>
<file:parameter name="antInclude" value="*.xml"/>
<file:parameter name="consumer.bridgeErrorHandler" value="true"/>
<file:parameter name="shuffle" value="true"/>
</file:additionalUriParameters>
<file:directory>directory path</file:directory>
<file:autoCreate>false</file:autoCreate>
<file:consume>
<file:delay>100</file:delay>
<file:maxMessagesPerPoll>20</file:maxMessagesPerPoll>
<file:delete>true</file:delete>
<file:moveFailed>directory path</file:moveFailed>
<file:readLock>markerFile</file:readLock>
</file:consume>
</file:binding.file>
即使入站目录中有大量文件,如何让我的消费者保持 1000 个文件/秒的相同消费速度?