Apache Camel拆分器、Threadpool和JMS

Question

我在spring xml中定义了以下路由，以拆分文本文件中的行，并将每一行发送到JMS队列

<bean id="myPool" class="java.util.concurrent.Executors" factory-method="newCachedThreadPool"/>

<camelContext id="concurrent-route-context" xmlns="http://camel.apache.org/schema/spring" trace="true">
    <route id="inbox-threadpool-split-route">
        <from uri="{{inbox.uri}}" />
            <log message="Starting to process file: ${header.CamelFileName}" />
            <split streaming="true" executorServiceRef="myPool">
                <tokenize token="\n" />
                <to uri="{{inventory.queue.uri}}" />    
            </split>
            <log message="Done processing file: ${header.CamelFileName}" />
    </route>
</camelContext>

如果我将“to”uri替换为“direct”endpoint，那么无论拆分器中是否使用threadpool都可以传递拆分消息

为了使JmsComponent与Splitter+ThreadPool一起工作，JmsComponent中是否需要任何特殊设置？或者我错过的任何其他配置？

=========20150731编辑=========

2015-07-31 11:02:07,210 [main           ] INFO  SpringCamelContext             - Apache Camel 2.15.0 (CamelContext: concurrent-route-context) started in 1.301 seconds
2015-07-31 11:02:07,220 [main           ] INFO  MainSupport                    - Apache Camel 2.15.0 starting
2015-07-31 11:02:17,250 [://target/inbox] INFO  inbox-threadpool-split-route   - Done processing file: smallfile.csv

此外，从JMS侦听器日志来看，它能够在同一秒钟内接收所有10条消息。似乎拆分器将读取并拆分整个文件，为所有十行“准备”10条JMS消息，然后将所有消息交付到队列，但不是“拆分1行并立即交付1条JMS消息”...

是否有任何选项或配置可以改变拆分器行为并提高拆分性能？

Answer 1

我在使用带标记的拆分器处理14G文件时也遇到了类似的问题。正如Claus关于用Apache Camel解析大文件的文章所指出的那样，我能够通过使用聚合器克服性能问题

在对批处理消息进行聚合之后，我使用producer模板将这些消息路由到消息传递系统。希望能有所帮助。