33

我们在 Tomcat (7.0.41) 中使用 Spring (3.2.4) 和 ActiveMQ (5.8.0)，目前尚不清楚最佳用法。我们想使用 JmsTemplate 来产生和 MessageListenerContainer 来接收消息。

我们应该在接收端使用缓存吗？(相关链接)
CachingConnectionFactory 与 ActiveMQ 和故障转移一起工作吗？(相关链接)
使用 PooledConnectionFactory 时需要设置 useAsyncSend="true" 吗？（相关链接）

4

2 回答 2

54

从这里：

PooledConnectionFactory 和 CachingConnectionFactory 的区别在于实现上的区别。以下是它们之间的一些不同特征：

  • 尽管 PooledConnectionFactory 和 CachingConnectionFactory 都声明它们各自汇集连接、会话和生产者，但 PooledConnectionFactory 实际上并没有创建多个生产者的缓存。它只是使用单例模式在被请求时分发单个缓存的生产者。而 CachingConnectionFactory 实际上创建了一个包含多个生产者的缓存，并在请求一个生产者时从缓存中分发一个生产者。

  • PooledConnectionFactory 构建在 Apache Commons Pool 项目之上，用于池化 JMS 会话。这允许对池进行一些额外的控制，因为 Commons Pool 中的某些功能未被 PooledConnectionFactory 使用。这些附加功能包括增加池大小而不是阻塞、在池耗尽时引发异常等。您可以通过使用自己的自定义设置创建自己的 Commons Pool GenericObjectPool 来利用这些功能，然后将该对象通过setPoolFactory 方法。有关其他信息，请参阅以下内容：http: //commons.apache.org/pool/api-1.4/org/apache/commons/pool/impl/GenericObjectPoolFactory.html

  • CachingConnectionFactory 还能够缓存消费者。使用此功能时只需要小心，以便您知道消费者是根据博客文章中提到的规则进行缓存的。

  • 但最重要的是，CachingConnectionFactory 将与任何符合 JMS 的 MOM 一起使用。它只需要一个 JMS 连接工厂。如果您使用多个 MOM 供应商，这在企业组织中很常见（这主要是由于遗留项目和现有项目），这一点很重要。重要的一点是 CachingConnectionFactory 可以很好地与许多不同的 MOM 实现一起工作，而不仅仅是 ActiveMQ。

从这里：

  • 如果您已集群 ActiveMQ，并使用故障转移传输，则据报道 CachingConnectionFactory 不是正确的选择。

  • 我遇到的问题是，如果一个盒子出现故障，我们应该开始在另一个盒子上发送消息，但它似乎仍在使用旧连接（每次发送超时）。如果我重新启动程序，它将再次连接并且一切正常。资料来源： ActiveMQ 和 CachingConnectionFactory 的自动重新连接问题

  • 问题是到失败的 ActiveMQ 的缓存连接仍在使用中，这给用户带来了问题。现在，这个场景的选择是 PooledConnectionFactory。

  • 如果您现在使用 ActiveMQ，并且将来可能会切换到其他代理（JBoss MQ、WebSphere MQ），请不要使用 PooledConnectionFactory，因为它将您的代码与 ActiveMQ 紧密耦合。

于 2013-10-25T16:25:54.437 回答
1

但是 spring 实现的缺点 - 它不支持 XA 事务。但是 activemq 实现支持它（XAPooledConnectionFactory）。所以，我会说，如果您将 JMS 与其他资源甚至与另一个 jms 代理一起使用并且想要进行交易 - 使用 activemq 实现。当然，PooledConnectionFactory 也适用于任何符合 JMS 的 MOM

于 2020-08-07T14:01:40.817 回答