与Tomcat的WebSphere MQ连接池
Tomcat有一个内置的JDBC连接池，但遗憾的是没有内置的JMS连接池。
我们正在将遗留的Tomcat Web应用程序从WebSphere MQ V6迁移到7.不幸的是，WebSphere MQ 7中的连接池已被删除，如下所述： http ： //www-01.ibm.com/support/docview.wss？uid = swg21665128
现在，如果我们只使用以下代码在Tomcat中配置MQ，我们担心会遇到麻烦：
我们担心的原因是在使用MQ 7时不会使用池化JMS提供程序。有关详细信息，另请参阅http://activemq.apache.org/jmstemplate-gotchas.html
我们看到的替代方案是：
1）Atomikos的使用
Atomikos有一个com.atomikos.jms.AtomikosConnectionFactoryBean，可以代替MQQueueConnectionFactory使用但是当我们不需要XA时，使用XA事务管理器是一个巨大的开销
2）使用Spring的CachingConnectionFactory
看起来是一个很好的解决方案，但不幸的是我们的遗留应用程序不使用Spring。 所以我们假设使用CachingConnectionFactory意味着相当多的努力。
3）使用Apache Commons Pool
看起来很有希望，但为JMS正确实现它需要一些良好的JMS知识
我们的问题：
- 是否有一个JMS提供程序可用于包装MQQueueConnectionFactory，它将汇集连接，会话，生产者和消费者？
- 有没有人成功实施我们上面概述的替代解决方案之一？
正如Umapathy在选项3中提出的那样，我们现在选择了使用Spring的CachingConnectionFactory的方法，它甚至适用于非Spring应用程序。 您需要做的就是将Spring Jars添加到类路径中，并使用CachingConnectionFactory包装MQQueueConnectionFactory。
我们选择创建自己的Tomcat QueueConnectionFactoryFactory，使我们能够完全保持原始应用程序代码不受影响，您只需要使用以下XML定义从Tomcat配置文件（如上面的问题所示）中替换原始MQ连接工厂：
以下是RSFCachingMQQueueConnectionFactoryFactory的（简化）代码（无错误检查）：
public class RSFCachingMQQueueConnectionFactoryFactory implements ObjectFactory{ public Object getObjectInstance (Object obj, Name name, Context nameCtx, Hashtable environment) throws NamingException { Reference ref = (Reference) obj; String beanClassName = ref.getClassName(); Class beanClass = Class.forName(beanClassName); if (CachingConnectionFactory.class.isAssignableFrom(beanClass)){ MQQueueConnectionFactoryFactory cff = new MQQueueConnectionFactoryFactory(); Reference mqReference = new Reference( MQQueueConnectionFactory.class.getName()); Enumeration allAddrs = ref.getAll(); while (allAddrs.hasMoreElements()){ mqReference.add(allAddrs.nextElement()); } MQQueueConnectionFactory cf = (MQQueueConnectionFactory)cff.getObjectInstance(mqReference, name, nameCtx, environment); CachingConnectionFactory ccf = (CachingConnectionFactory)beanClass.newInstance(); ccf.setTargetConnectionFactory(cf); return ccf; } }
我想你已经知道了答案。
选项1：使用Java EE应用程序服务器。 这有内置的JMS池。
选项2：如果这是一个执行单个作业的简单应用程序（比如使用fire和forget类型放置队列），则可以连接到JMS提供程序（qmgr）并在servlet_init方法中创建生产者或使用者。 这意味着遗留代码需要更新。 由于JMS重新连接属性没有启动重新连接（根据我的经验），您还需要在出现故障时处理重新连接。
选项3：当应用程序恰好比选项2中的应用程序复杂时，我已经使用了Spring的CachingConnectionFactory。我有使用JMSTemplate的应用程序，有些则没有。