java - 使用 camel jms 组件从 activemq 卡住消息消费

Question

我有一个包含两条 Camel 路线的应用程序:

Route 1 (Consumer Route)

读取一个没有的文本文件。记录(行分隔)，根据每一行拆分它们并将每个拆分记录发送到另一个队列(“中间”队列)

Route 2 (Producer Route)

从中间队列读取每条记录，转换它们并将它们发送到输出队列。

我将 ActiveMQ 与 camel JmsComponent (concurrentConsumers=7, maxConcurrentConsumers=10) 一起使用。我猜 camel 在底层使用 Spring DMLC 从队列中读取数据。

配置:

activemq.broker.uri = tcp://0.0.0.0:61616?jms.useAsyncSend=true&jms.prefetchPolicy.queuePrefetch=1

<bean id="cachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="jmsmqConnectionFactory" />
    <property name="reconnectOnException" value="true" />
    <property name="sessionCacheSize" value="7" />
</bean>

<bean id="jmsComponent" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="cachingConnectionFactory" />
    <property name="cacheLevelName" value="CACHE_CONSUMER" />
    <property name="transacted" value="true" />
    <property name="transactionManager" ref="transactionManager" />
</bean>

jmsComponent:queue:INTERMEDIATE?concurrentConsumers=7&maxConcurrentConsumers=10

现在，问题是，如果没有。文件中的记录非常少(10 条或更少)，拆分记录卡在中间队列中。 Producer Route 正在运行，但没有消息消费。在任何日志中都没有发现异常，Consumer Route 也已启动并运行。

但是，通过将 prefetch 限制设置为 0，这个问题就消失了，但会导致另一个问题 - 无法通过 ctrl+C 和 cacheLevel 为 CACHE_CONSUMER。尽管 CACHE_AUTO 工作正常，但性能会下降。

prefetch > 0 和 SpringDMLC 是否存在任何已知问题，或者我是否遗漏了什么？

Answer 1

我知道这个问题很老了，但也许有人会从解决方法中受益。我们遇到了同样的问题，虽然我们没有深入了解它(资源有限且需要及时修复)，但我们至少将 Camel 隔离为问题源。

我们实现的解决方法是简单地使用两个不同的 JMS 组件 - 一个用于消费者，一个用于生产者。如果有许多消费者/生产者对在同一队列中生产/消费，您可以将所有消费者放在一个组件中，将所有生产者放在另一个组件中。引入分离后，我们再也没有遇到过这个特殊问题。