如何使用spring JMS在ActiveMQ中创建多个侦听器

Question

我有一个用例，我想在一个应用程序中创建多个监听器（6）。我想订阅多个目的地（6个主题）。所有订阅都是持久的。我为每个监听器使用单独的默认消息监听器容器（DMLC），并使用不同的客户端id，但我对如何使用连接工厂感到困惑。

我是否应该使用单个 ActiveMQ 池连接工厂，最大连接数指定为 6。或者我应该为每个侦听器使用不同的池连接工厂吗？
使用具有最大连接池连接工厂对于持久用户有什么危害吗？

源代码：
连接工厂：

<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
<value>${jms.broker.url}</value>
</property>
</bean>
</property>
<property name="maxConnections" value="6" />

我的监听器使用它：（我有6个类似的监听者，使用不同的目的地和客户端ID）

<bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer"

      <property name="connectionFactory" ref="jmsFactory" />
      <property name="destination" ref="topic_pnlCompleteTopic" />
      <property name="durableSubscriptionName" value="FAGCompletion" />
      <property name="pubSubDomain" value="true" />
      <property name="subscriptionDurable" value="${jms.fagsListener.durable}" />
      <property name="clientId" value="${jms.fagsListener.clientId}" />
      <property name="messageListener" ref="pnlMessageListener" />
      <property name="messageSelector" value="JMSType = 'FAG Completion'" />
 </bean>

Answer 1

由于您使用的是主题，您的侦听器通常每个只使用一个会话。没有理由指定池的限制或使用多个池。您通常会为您的应用程序使用一个池连接工厂，除非您看到限制或将其拆分为不同池的真正原因。

Answer 2

这对我来说听起来都很好，只要你不把这个连接工厂用于其他事情。没有理由将连接数限制为6，如果需要，可以放置一个更大的数字，并且仅在必要时才使用。连接工厂通常是你为整个应用共享的内容。将其视为一种用于 JMS 访问的数据源