【发布时间】:2017-01-27 13:15:41
【问题描述】:
我们的一个应用程序有问题。该应用程序是一个自行编写的 Java 应用程序,它通过 JMS 连接到 50 多个不同的消息队列并使用这些队列中的消息。
从功能的角度来看,处理来自不同队列的所有消息都可以正常工作。然而,在测试过程中,我们发现不同消息的处理速度非常慢。我们每分钟只能处理每个队列的几条消息。
为了更好地理解发生了什么,我使用 JMC 进行了一次飞行记录,发现每个线程消耗消息队列中的消息都有很多阻塞时间:
除此图外,我还在飞行记录中看到,花费大量时间访问特定的 WeakHashMap 以关闭和获取 XAResource。
我所做的下一步是分析 JMS bitronix 配置的外观。以下是相关部分:
在 Tomcat 服务器级别,我有由 bitronix 加载的 resource.properties 文件:
resource.cf1.className=com.ibm.mq.jms.MQXAQueueConnectionFactory
resource.cf1.uniqueName=jms/cf
resource.cf1.minPoolSize=1
resource.cf1.maxPoolSize=60
resource.cf1.driverProperties.hostName=genadev0059.mycompnany.com
resource.cf1.driverProperties.port=1515
resource.cf1.driverProperties.channel=APPL_CHL
resource.cf1.driverProperties.transportType=1
resource.cf1.driverProperties.queueManager=DEV
在 Spring 应用程序 XML 内部,我有以下 bean 定义来建立连接:
<jee:jndi-lookup id="connectionFactory" jndi-name="jms/cf" resource-ref="true" proxy-interface="javax.jms.ConnectionFactory"/>
<bean id="userCredentialsConnectionFactory" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter" p:targetConnectionFactory-ref="connectionFactory" p:username="$jms{jmsuser}" p:password="$jms{jmspwd}"/>
<bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory" p:sessionCacheSize="$fwk{jms.connectionFactory.sessionCacheSize}" p:targetConnectionFactory-ref="userCredentialsConnectionFactory"/>
<bean id="parentJmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer" abstract="true" p:connectionFactory-ref="cachedConnectionFactory" p:sessionTransacted="true" p:transactionManager-ref="transactionManager"
p:autoStartup="$fwk{jms.listener.start}"/>
除此之外,我为每个消息队列和处理来自该队列的消息的自己的类:
<bean id="messageQueueThread1" parent="parentJmsContainer">
<property name="destinationName" value="queue1" />
<property name="messageListener">
<bean class="com.mycompany.service.jms.Queue1Listener" />
</property>
</bean>
我认为错误与连接的配置方式有关。我尝试了不同的其他方法,但阻塞线程的结果总是相同的。
非常欢迎任何意见或建议。
【问题讨论】:
标签: jms tomcat7 ibm-mq jmc bitronix