Spring在tomcat下使用JTA事务

今天药忘吃喽~ 2022-06-15 07:56 205阅读 0赞

# **Spring在tomcat下使用JTA事务** #

涉及到多个库的事务问题时，常常要使用到JTA事务，tomcat本身不支持JTA事务，需要借助于Atomikos来使用JTA事务。以下内容结合mybatis，在项目中配置JTA事务。

1，引入依赖

<table> 
 <tbody> 
 <tr> 
 <td> &lt;dependency&gt; &lt;groupId&gt;javax.transaction&lt;/groupId&gt; &lt;artifactId&gt;jta&lt;/artifactId&gt; &lt;version&gt;1.1&lt;/version&gt; &lt;/dependency&gt; &lt;dependency&gt; &lt;groupId&gt;com.atomikos&lt;/groupId&gt; &lt;artifactId&gt;transactions-jdbc&lt;/artifactId&gt; &lt;version&gt;4.0.4&lt;/version&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

2，引入properties配置，配置数据源

<table> 
 <tbody> 
 <tr> 
 <td> &lt;bean&nbsp;id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"&gt; &lt;property&nbsp;name="locations"&gt; &lt;list&gt; &lt;value&gt;classpath:config.properties&lt;/value&gt; &lt;/list&gt; &lt;/property&gt; &lt;/bean&gt; </td> 
 </tr> 
 </tbody> 
</table>

配置数据源

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean&nbsp;id="storeDS"&nbsp;class="com.atomikos.jdbc.AtomikosDataSourceBean"&nbsp;destroy-method="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="uniqueResourceName"&nbsp;value="storeDS"/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="xaDataSourceClassName"&nbsp;value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="xaProperties"&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;props&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop&nbsp;key="url"&gt;${store_db.url}&lt;/prop&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop&nbsp;key="user"&gt;${store_db.username}&lt;/prop&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop&nbsp;key="password"&gt;${store_db.password}&lt;/prop&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/props&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &lt;/property&gt; &nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="minPoolSize"&nbsp;value="5"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="maxPoolSize"&nbsp;value="20"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- 锁表时间 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="borrowConnectionTimeout"&nbsp;value="120"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="testQuery"&nbsp;value="select 1"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="maintenanceInterval"&nbsp;value="60"&nbsp;/&gt;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean&nbsp;id="hanjudbDS"&nbsp;class="com.atomikos.jdbc.AtomikosDataSourceBean"&nbsp;destroy-method="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="uniqueResourceName"&nbsp;value="hanjudbDS"/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="xaDataSourceClassName"&nbsp;value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="xaProperties"&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;props&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop&nbsp;key="url"&gt;${url}&lt;/prop&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop&nbsp;key="user"&gt;${username}&lt;/prop&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop&nbsp;key="password"&gt;${password}&lt;/prop&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/props&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &lt;/property&gt; &nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="minPoolSize"&nbsp;value="10"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="maxPoolSize"&nbsp;value="40"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- 锁表时间 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="borrowConnectionTimeout"&nbsp;value="120"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="testQuery"&nbsp;value="select 1"&nbsp;/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="maintenanceInterval"&nbsp;value="60"&nbsp;/&gt;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean&gt; </td> 
 </tr> 
 </tbody> 
</table>

3，配置连接池，使用mybatis连接池

4，配置mybatis

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp;&nbsp;&lt;bean&nbsp;class="org.mybatis.spring.mapper.MapperScannerConfigurer"&gt; &lt;property&nbsp;name="sqlSessionFactoryBeanName"&nbsp;value="sqlSessionFactory"/&gt; &lt;property&nbsp;name="basePackage"&nbsp;value="com.hanju.server.dal.**.dao"&nbsp;/&gt; &nbsp;&nbsp;&lt;/bean&gt; &nbsp;&nbsp;&lt;bean&nbsp;class="org.mybatis.spring.mapper.MapperScannerConfigurer"&gt; &lt;property&nbsp;name="sqlSessionFactoryBeanName"&nbsp;value="storeSqlSessionFactory"/&gt; &lt;property&nbsp;name="basePackage"&nbsp;value="com.hanju.server.dal.**.storedao"&nbsp;/&gt; &nbsp;&nbsp;&lt;/bean&gt; </td> 
 </tr> 
 </tbody> 
</table>

5，配置事务

<table> 
 <tbody> 
 <tr> 
 <td> &lt;!-- 引入spring注解事务 --&gt; &nbsp;&nbsp;&lt;tx:annotation-driven&nbsp;/&gt; &nbsp;&nbsp; &nbsp;&nbsp;&lt;bean&nbsp;id="transactionManager"&nbsp;class="org.springframework.transaction.jta.JtaTransactionManager"&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="transactionManager"&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean&nbsp;class="com.atomikos.icatch.jta.UserTransactionManager"&nbsp;init-method="init"&nbsp;destroy-method="close"&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property&nbsp;name="forceShutdown"&nbsp;value="true"/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &lt;/property&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &lt;property&nbsp;name="userTransaction"&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;bean&nbsp;class="com.atomikos.icatch.jta.UserTransactionImp"/&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt;&nbsp;&nbsp; &nbsp;&nbsp;&lt;/bean&gt; &nbsp;&nbsp; &nbsp;&nbsp;&lt;tx:advice&nbsp;id="txAdvice"&nbsp;transaction-manager="transactionManager"&gt; &lt;tx:attributes&gt; &lt;tx:method&nbsp;name="get*"&nbsp;propagation="SUPPORTS"&nbsp;read-only="true"&nbsp;/&gt; &lt;tx:method&nbsp;name="find*"&nbsp;propagation="SUPPORTS"&nbsp;read-only="true"&nbsp;/&gt; &lt;tx:method&nbsp;name="check*"&nbsp;propagation="SUPPORTS"&nbsp;read-only="true"&nbsp;/&gt; &lt;tx:method&nbsp;name="is*"&nbsp;propagation="SUPPORTS"&nbsp;read-only="true"&nbsp;/&gt; &lt;tx:method&nbsp;name="search*"&nbsp;propagation="SUPPORTS"&nbsp;read-only="true"&nbsp;/&gt; &lt;tx:method&nbsp;name="select*"&nbsp;propagation="SUPPORTS"&nbsp;read-only="true"&nbsp;/&gt; &lt;tx:method&nbsp;name="*"&nbsp;propagation="REQUIRED"&nbsp;read-only="false" timeout="120"&nbsp;rollback-for="java.lang.Exception"&nbsp;/&gt; &lt;/tx:attributes&gt; &nbsp;&nbsp;&lt;/tx:advice&gt; &nbsp; &nbsp;&nbsp;&lt;aop:config&gt; &lt;aop:pointcut expression="execution(* com.ttt.server..*Service.*(..)) and !@annotation(com.ttt.server.common.annotation.TTTNoTransaction)" id="txTransactionPC"&nbsp;/&gt; &lt;aop:advisor&nbsp;advice-ref="txAdvice"&nbsp;pointcut-ref="txTransactionPC"&nbsp;/&gt; &nbsp;&nbsp;&lt;/aop:config&gt; </td> 
 </tr> 
 </tbody> 
</table>

6，classpath下增加jta.properties文件

<table> 
 <tbody> 
 <tr> 
 <td> com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory&nbsp;&nbsp;&nbsp; com.atomikos.icatch.console_file_name=tm.out&nbsp;&nbsp;&nbsp; com.atomikos.icatch.log_base_name=tmlog&nbsp;&nbsp;&nbsp; com.atomikos.icatch.tm_unique_name =com.atomikos.spring.jdbc.tm&nbsp;&nbsp;&nbsp; com.atomikos.icatch.console_log_level=INFO&nbsp; com.atomikos.icatch.max_actives=200 </td> 
 </tr> 
 </tbody> 
</table>