Клиентские потоки Weblogic JMS зависли при обновлении соединения - PullRequest
Новая
       6

Клиентские потоки Weblogic JMS зависли при обновлении соединения

1 голос
/ 18 января 2011

Привет,

Мы используем Spring для интеграции с сервером Weblogic JMS с помощью wlfullclient.jar. Время от времени, jmsListenerthreads застревают. Мы наблюдали, что это происходит при обновлении соединения.

Используемые версии: wlfullClient.jar: 10.0.1 Весна: 3.0.3

Трассировка стека для пары застрявших нитей: 

    Name: jmsListenerContainer-1770
State: WAITING on weblogic.jms.client.JMSSession@35c0fb37
Total blocked: 3,681  Total waited: 3,664

Stack trace: 
java.lang.Object.wait(Native Method)
java.lang.Object.wait(Object.java:485)
weblogic.jms.client.JMSSession.waitForState(JMSSession.java:4239)
weblogic.jms.client.JMSSession.close(JMSSession.java:1259)
weblogic.jms.client.JMSConnection.closeSessions(JMSConnection.java:1076)
weblogic.jms.client.JMSConnection.mergedCloseAndOnException(JMSConnection.java:950)
   - locked weblogic.jms.client.JMSConnection@3263f76c
weblogic.jms.client.JMSConnection.close(JMSConnection.java:763)
weblogic.jms.client.ReconnectController.close(ReconnectController.java:426)
org.springframework.jms.connection.ConnectionFactoryUtils.releaseConnection(ConnectionFactoryUtils.java:80)
org.springframework.jms.listener.AbstractJmsListeningContainer.refreshSharedConnection(AbstractJmsListeningContainer.java:385)
   - locked java.lang.Object@51ce8880
org.springframework.jms.listener.DefaultMessageListenerContainer.refreshConnectionUntilSuccessful(DefaultMessageListenerContainer.java:856)
org.springframework.jms.listener.DefaultMessageListenerContainer.recoverAfterListenerSetupFailure(DefaultMessageListenerContainer.java:838)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:969)
   - locked java.lang.Object@c2330fa
java.lang.Thread.run(Thread.java:619)

Name: jmsListenerContainer-1755
State: TIMED_WAITING on java.lang.Object@b5c4560
Total blocked: 3,588  Total waited: 3,605

Stack trace: 
java.lang.Object.wait(Native Method)
weblogic.jms.client.ReconnectController.waitForStateInternal(ReconnectController.java:309)
weblogic.jms.client.ReconnectController.analyzeExceptionAndReconnect(ReconnectController.java:525)
weblogic.jms.client.ReconnectController.computeJMSConsumer(ReconnectController.java:652)
weblogic.jms.client.WLConsumerImpl.receive(WLConsumerImpl.java:166)
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:405)
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:308)
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:261)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1056)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1048)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
java.lang.Thread.run(Thread.java:619)

Name: jmsListenerContainer-1732
State: BLOCKED on java.lang.Object@51ce8880 owned by: jmsListenerContainer-1770
Total blocked: 3,586  Total waited: 3,584

Stack trace: 
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.clearResources(DefaultMessageListenerContainer.java:1096)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
java.lang.Thread.run(Thread.java:619)

Пружинные конфигурации: 

<bean id="messageListener"
  class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
  <constructor-arg>
   <bean class="com.eharmony.matching.mnssender.jms.DefaultDtoDelegate" />
  </constructor-arg>
  <property name="defaultListenerMethod" value="receive" />
  <property name="messageConverter">
   <bean class="com.eharmony.matching.mnssender.jms.Converter" />
  </property>
 </bean>

 <bean id="jmsListenerContainer"
  class="org.springframework.jms.listener.DefaultMessageListenerContainer">
  <property name="concurrentConsumers" value="${MNSClient.jms.concurrent.consumers}" />
  <property name="connectionFactory" ref="jmsQueueConnectionFactory" />
  <property name="destination" ref="queue" />
  <property name="sessionTransacted" value="true" />
  <property name="messageListener" ref="messageListener" />
 </bean>

 <bean id="jmsQueueConnectionFactory"
  class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
  <property name="targetConnectionFactory">
   <ref bean="internalJmsQueueConnectionFactory" />
  </property>
  <property name="username">
   <value>${MNSClient.receive.jms.user}</value>
  </property>
  <property name="password">
   <value>${MNSClient.receive.jms.password}</value>
  </property>
 </bean>

 <bean id="internalJmsQueueConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
  <property name="jndiTemplate">
   <ref bean="jndiTemplate" />
  </property>
  <property name="jndiName">
   <value>${MNSClient.receive.jms.connectionFactoryName}</value>
  </property>
 </bean>

 <!-- RECEIVING JMS MESSAGE -->
 <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
  <property name="environment">
   <props>
    <prop key="java.naming.factory.initial">${MNSClient.receive.jms.initialFactoryName}</prop>
    <prop key="java.naming.provider.url">${MNSClient.receive.jms.providerUrl}</prop>
   </props>
  </property>
 </bean>
 <bean id="queue" class="org.springframework.jndi.JndiObjectFactoryBean">
  <property name="jndiTemplate">
   <ref bean="jndiTemplate" />
  </property>
  <property name="jndiName">
   <value>${MNSClient.receive.jms.queueName}</value>
  </property>
 </bean>

Любые указатели будут высоко оценены!

Привет.

Ответы [ 2 ]

0 голосов
/ 20 января 2011

Хорошо, немного погуглив, я нашел ответ.Мы столкнулись с ошибкой интеграции с Spring JMS: https://jira.springframework.org/browse/SPR-7366?page=com.atlassian.jira.plugin.system.issuetabpanels%3Aall-tabpanel#issue-tabs

Это было исправлено, и мы бы обновились до последней версии Spring.

0 голосов
/ 18 января 2011

Оба эти потока вызывают методы в одном и том же сеансе (или получатель / производитель получен из одного и того же сеанса)?Сеанс и все производные от него (Producer, Consumer и т. Д.) Не являются поточно-ориентированными, поэтому необходимо защищать их от одновременной работы нескольких потоков.Либо путем сериализации доступа через вашу собственную блокировку, либо путем создания разных сеансов для каждого производителя / потребителя.

Не забывайте неявный поток, участвующий в обработке асинхронных сообщений (использование onMessage ()) при подсчете, обращаетесь ли вы к нему.сеанс из нескольких потоков.

Если вы нарушаете это правило, ожидайте плохих вещей (например, тупиков).

...