2

XA トランザクションを使用して、ActiveMQ と Hibernate (Sql Server 2008) の間のアクティビティを調整したい状況です。

私たちは以下を使用しています：

  • 春 3.0.5
  • 休止状態 3.6.2
  • アクティブMQ 5.5.0
  • アトミコス 3.7

トランザクションが開始されていないことに関連するログ ファイルに、次のエラーが生成されていることがわかります。これらは常に JMS に関連しています。

トランザクション '[ID]' は開始されていません。

これらは常にログに生成されています。

同じ JMS キューで動作する 3 つの Web アプリケーションがあり、1 つの Web アプリケーションのみが実行されている場合はエラーが生成されないようであるという点で、問題はより複雑です。

これらは、同じマシンで実行されている Tomcat 7.0.14 の個別のインスタンスにデプロイされます。

2011-05-31 15:04:27,065 [Atomikos:30] WARN  - [com.atomikos.diagnostics.Slf4jConsole] : XA resource 'XAJMS': rollback for XID '3139322E3136382E302E35332E746D30363636333030303031:3139322E3136382E302E35332E746D36363633' raised 0: unknown
javax.transaction.xa.XAException: Transaction 'XID:1096044365:3139322e3136382e302e35332e746d30363636333030303031:3139322e3136382e302e35332e746d36363633' has not been started.
    at org.apache.activemq.TransactionContext.toXAException(TransactionContext.java:732)
    at org.apache.activemq.TransactionContext.rollback(TransactionContext.java:497)
    at com.atomikos.datasource.xa.XAResourceTransaction.rollback(XAResourceTransaction.java:690)
    at com.atomikos.icatch.imp.RollbackMessage.send(RollbackMessage.java:72)
    at com.atomikos.icatch.imp.PropagationMessage.submit(PropagationMessage.java:111)
    at com.atomikos.icatch.imp.Propagator$PropagatorThread.run(Propagator.java:87)
    at com.atomikos.icatch.imp.Propagator.submitPropagationMessage(Propagator.java:66)
    at com.atomikos.icatch.imp.HeurHazardStateHandler.onTimeout(HeurHazardStateHandler.java:124)
    at com.atomikos.icatch.imp.CoordinatorImp.alarm(CoordinatorImp.java:1105)
    at com.atomikos.timing.PooledAlarmTimer.notifyListeners(PooledAlarmTimer.java:112)
    at com.atomikos.timing.PooledAlarmTimer.run(PooledAlarmTimer.java:99)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
Caused by: javax.transaction.xa.XAException: Transaction 'XID:1096044365:3139322e3136382e302e35332e746d30363636333030303031:3139322e3136382e302e35332e746d36363633' has not been started.
    at org.apache.activemq.broker.TransactionBroker.getTransaction(TransactionBroker.java:290)
    at org.apache.activemq.broker.TransactionBroker.rollbackTransaction(TransactionBroker.java:177)
    at org.apache.activemq.broker.MutableBrokerFilter.rollbackTransaction(MutableBrokerFilter.java:131)
    at org.apache.activemq.broker.TransportConnection.processRollbackTransaction(TransportConnection.java:436)
    at org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:104)
    at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
    at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
    at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
    at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
    at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
    at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
    at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
    at java.lang.Thread.run(Unknown Source)

私たちの春の構成:

<Resource name="jms/ConnectionFactory" 
    auth="Container" 
    type="org.apache.activemq.ActiveMQXAConnectionFactory" 
    description="JMS XA Connection Factory"
    factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
    brokerURL="tcp://${activemq.server.name}:${activemq.server.port}" 
    brokerName="LocalActiveMQBroker" />


<bean id="atomikosConnectionFactory"  
      class="com.atomikos.jms.AtomikosConnectionFactoryBean"  
      init-method="init" destroy-method="close"> 
    <property name="uniqueResourceName" value="XAJMS" /> 
    <property name="xaConnectionFactory" ref="jmsConnectionFactory" />
    <property name="maxPoolSize" value="40" />
</bean>

<bean id="getSomeStuffListenerAdapter" 
      class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
    <property name="delegate" ref="targetElement" />
    <property name="defaultListenerMethod" value="doStuff" />
    <property name="messageConverter" ref="myMessageConverter" />
</bean>

<bean id="getSomeStuffListenerContainer" 
      class="org.springframework.jms.listener.DefaultMessageListenerContainer"
      depends-on="txManager">
    <property name="connectionFactory" ref="atomikosConnectionFactory"/>
    <property name="destination" ref="jmsQueue01"/>
    <property name="messageListener" ref="getSomeStuffListenerAdapter" />
    <property name="concurrency" value="5-10" />
    <property name="transactionManager" ref="txManager" />
    <property name="sessionTransacted" value="true" /> 
</bean>

<bean id="atomikosTransactionManager"
      class="com.atomikos.icatch.jta.UserTransactionManager"
      depends-on="dataSource, atomikosConnectionFactory"
      init-method="init" destroy-method="close">
    <property name="forceShutdown" value="false" /> 
</bean>

<bean id="txManager"
      class="org.springframework.transaction.jta.JtaTransactionManager"> 
    <property name="transactionManager" ref="atomikosTransactionManager" />
</bean>
4

1 に答える 1

5

同じActiveMQサーバーを指しているAtomikosを使用して同じマシンで3つのTomcatWebアプリケーションを実行しているときに、この問題が発生しました。

アプリケーションは、個別のAtomikosログファイルを使用して個別のTomcatインスタンスで実行されていました。

問題は、XA XID（トランザクションID）が3つのアプリケーション間で一意ではなく、これがActiveMQを混乱させていたということです。これは、同じマシンで実行されているインスタンスが原因でした。

AtomikosとActiveMQのログをTRACEに設定した場合。次に、同じXIDが2つ以上のアプリケーションによって生成されていることがわかります。

これは、Atomikosプロパティ設定が原因です：com.atomikos.icatch.tm_unique_name

これが設定されていない場合、XIDの生成時にマシンのIPアドレスが使用されます。これは、3つのアプリケーションで同じであり、競合が発生していました。

この問題は、3つのTomcatアプリケーションが互いに非常に接近して起動された場合にのみ発生する可能性がありました。

したがって、com.atomikos.icatch.tm_unique_nameをWebアプリケーションごとに一意になるように設定すると、問題は解決しました。

于 2011-06-13T09:17:35.920 に答える