10

我们对 AMQ 使用以下配置

<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="${brokerURL1}"/>
</bean>
<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
    <property name="maxConnections" value="10"/>
    <property name="maximumActive" value="100"/>
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory"/>
    <property name="transacted" value="false"/>
    <property name="concurrentConsumers" value="5"/>
    <property name="maxConcurrentConsumers" value="10"/>
</bean>

<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="configuration" ref="jmsConfig"/>
</bean>

定期我有奇怪的问题 - 松散的消息。实际上 AMQ 说一切正常，消息已出列，但应用程序上没有消息...

我已经读过缓存消费者可能会出现问题，而应该在配置之后使用 JmsConfiguration

<bean id="jmsConfig" class="org.apache.activemq.camel.component.ActiveMQConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory"/>
    <property name="transacted" value="false"/>
    <property name="concurrentConsumers" value="5"/>
    <property name="maxConcurrentConsumers" value="10"/>
    <property name="cacheLevelName" value="CACHE_CONSUMER"/>
</bean>

有人知道如何正确配置activemq吗？应设置哪些值以获得最佳性能和良好的可靠性？

<property name="maxConnections" value="?"/>
<property name="maximumActive" value="?"/>
<property name="concurrentConsumers" value="?"/>
<property name="maxConcurrentConsumers" value="?"/>

我应该使用org.apache.activemq.pool.PooledConnectionFactory还是有更好的方法？

4

1 回答 1

7

似乎您更多的是询问如何配置 Apache Camel 如何使用 ActiveMQ。

有很多方法可以配置池等。很大程度上取决于您在设置中看到的使用/负载模式以及您的要求。您引用的那些设置 maxConcurrentConsumers 等将取决于您的骆驼路线以及您在那里设置的消费者数量。

简单地说，有两个场景需要优化： 发送和接收消息（请求/回复也会浮现在脑海中，但那是另一回事）。

如果您在应用程序中收到大量消息，那么您通常会设置消息侦听器，并且池化并没有太大帮助，因为您不会创建/拆除大量连接/会话。只要确保您配置了足够的并发消费者 - 多少取决于您的硬件（# CPU 内核等）和每条消息的大小。您必须测量您的特定设置以获得最佳性能。

当您发送消息时，Camel建议您使用 ActiveMQ 的 PooledConnectionFactory。链接到的文档还为您要求的设置建议了一些默认值。

  <property name="maxConnections" value="8" />
  <property name="maximumActive" value="500" />
   <property name="transacted" value="false"/>

为了获得最大的可靠性，您应该使用事务处理会话并在安全处理后提交收到的消息。

奇怪的是你说你丢失了消息，你的设置中没有任何特定的东西会让你丢失消息。您需要进一步跟踪这一点或提供有关应用程序实施的一些信息。

于 2012-07-18T20:11:37.650 回答