Spring Jms中的生产者和消费者使用相同的连接工厂？

Question

<!-- Configuration for listener -->
<bean id="mdc.TargetConnectionFactory4Listener" class="com.tibco.tibjms.TibjmsConnectionFactory">  
    <property name="serverUrl" value="tcp://localhost:7222"/>
</bean>

<bean id="mdc.ConnectionFactory4Listener" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">  
    <property name="targetConnectionFactory" ref="mdc.TargetConnectionFactory"/>
    <property name="username" value="admin" />
    <property name="password" value="test" />
</bean>

<bean id="mdc.InputQueue" class="com.tibco.tibjms.TibjmsQueue">  
    <constructor-arg>  
        <value>INPUT_QUEUE</value>  
    </constructor-arg>  
</bean>

<bean id="mdc.JmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
    <property name="connectionFactory" ref="mdc.ConnectionFactory4Listener" />  
    <property name="destination" ref="mdc.InputQueue" />  
    <property name="messageListener" ref="mdc.MessageReceiver" />  
    ......
</bean>

<!-- Configuration for sender -->
<bean id="mdc.TargetConnectionFactory4Sender" class="com.tibco.tibjms.TibjmsQueue">  
    <property name="serverUrl" value="tcp://localhost:7222"/>
</bean>

<bean id="mdc.CachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="mdc.TargetConnectionFactory4Sender" />
    <property name="sessionCacheSize" value="50" />
</bean>

<bean id="mdc.OutputQueue" class="com.tibco.tibjms.TibjmsQueue">  
    <constructor-arg>  
        <value>DISCOVERY_QUEUE</value>  
    </constructor-arg>  
</bean>

<bean id="mdc.JmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="mdc.CachingConnectionFactory" />
</bean>

<bean id="mdc.MessageReceiver" class="net.siemens.discovery.queue.QueueMessageListener">
    <property name="jmsTemplate" ref="mdc.JmsTemplate" />  
    <property name="destination" ref="mdc.OutputQueue" />
    ......
</bean>

这两个队列运行在同一个EMS服务器上。有些人对这种配置有看法：只使用一个ConnectionFactory就可以配置它们，两个实例不是必需的。但是，如果我使用一个ConnectionFactory实例，那么该实例将同时用于DefaultMessageListenerContainer和CachingConnectionFactory（进一步用于JmsTemplate）。我不知道他们是否互相影响。

Answer 1

使用单一连接工厂是再正常不过的；在这种情况下使用2个工厂是很不寻常的。

事实上，如果您希望在容器线程上执行jmstemplate操作，并且希望交互在事务中运行(sessiontransacted=true)，那么您必须使用相同的连接工厂。这允许在出现异常时回滚所有内容。

在侦听器容器中使用缓存连接工厂时，应将连接工厂cacheConsumers设置为false。（有关更多信息，请参阅此答案。