jta分布式事务简单使用

xiaoxiao2022-06-24 212

个人理解总结：

jta分布式事务，其实与普通的spring事务配置没多大区别，最主要的是配置不同的mapper使用不同的的数据源，然后再配atomikos和spring的jta事务管理器进行管理（spring管理atomikos），使用还有就是普通的事务API不能满足需求，需要改为对应的transactionmanager，剩下的就是添加一些简单的配置即可。

代码结构：

1.导入相应的jar包

<properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <commons.beanutils>1.9.3</commons.beanutils> <spring.version>4.3.10.RELEASE</spring.version> <aspectj.version>1.8.6</aspectj.version> <aspectj.weaver>1.8.6</aspectj.weaver> <mybatis.spring.version>1.3.0</mybatis.spring.version> <mybatis.version>3.4.5</mybatis.version> <mysql.version>5.1.32</mysql.version> <junit.version>4.12</junit.version> <commons-fileupload.version>1.3.1</commons-fileupload.version> <commons.io.version>2.2</commons.io.version> <commons.logging.version>1.2</commons.logging.version> <druid.version>1.0.13</druid.version> <solr.solrj.version>5.3.1</solr.solrj.version> <slf4j.jcl.version>1.7.25</slf4j.jcl.version> <slf4j.version>1.7.25</slf4j.version> <jstl.version>1.2</jstl.version> <servlet-api.version>2.4</servlet-api.version> <jsp-api.version>2.0</jsp-api.version> <log4j.version>1.2.17</log4j.version> <log4j.core.version>2.3</log4j.core.version> <commons-lang3.version>3.3.2</commons-lang3.version> <dubbo.version>2.5.8</dubbo.version> <zkclient.version>0.10</zkclient.version> <zookeeper.version>3.4.9</zookeeper.version> <javassist.version>3.18.1-GA</javassist.version> <persistence.api.version>1.0.2</persistence.api.version> <pagehelper.version>3.7.5</pagehelper.version> <mapper.version>2.3.4</mapper.version> <jsqlparser.version>0.9.1</jsqlparser.version> <jackson.version>2.9.2</jackson.version> <fastdfs.version>1.0</fastdfs.version> <jedis.version>2.9.0</jedis.version> <commons.pool2.version>2.5.0</commons.pool2.version> <spring.data.redis.version>1.8.5.RELEASE</spring.data.redis.version> <httpclient.version>4.3.1</httpclient.version> <commons-codec.version>1.9</commons-codec.version> <activemq.spring.version>5.15.2</activemq.spring.version> <activemq.core.version>5.7.0</activemq.core.version> <freemarker.version>2.3.23</freemarker.version> <jta.version>1.1</jta.version> <atomikos.version>4.0.6</atomikos.version> <cglib.nodep.version>3.2.5</cglib.nodep.version> </properties> <dependencies> <dependency> <groupId>javax.transaction</groupId> <artifactId>jta</artifactId> <version>${jta.version}</version> </dependency> <dependency> <groupId>com.atomikos</groupId> <artifactId>atomikos-util</artifactId> <version>${atomikos.version}</version> </dependency> <dependency> <groupId>com.atomikos</groupId> <artifactId>transactions</artifactId> <version>${atomikos.version}</version> </dependency> <dependency> <groupId>com.atomikos</groupId> <artifactId>transactions-jta</artifactId> <version>${atomikos.version}</version> </dependency> <dependency> <groupId>com.atomikos</groupId> <artifactId>transactions-jdbc</artifactId> <version>${atomikos.version}</version> </dependency> <dependency> <groupId>com.atomikos</groupId> <artifactId>transactions-api</artifactId> <version>${atomikos.version}</version> </dependency> <dependency> <groupId>cglib</groupId> <artifactId>cglib-nodep</artifactId> <version>${cglib.nodep.version}</version> </dependency>  <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>${jackson.version}</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <version>${jackson.version}</version> </dependency>  <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>${druid.version}</version> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> <version>${spring.version}</version> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring.version}</version> </dependency>  <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjrt</artifactId> <version>${aspectj.version}</version> </dependency>  <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> <version>${aspectj.weaver}</version> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> </dependency>  <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>${mybatis.spring.version}</version> </dependency>  <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>${mybatis.version}</version> </dependency>  <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>${commons-lang3.version}</version> </dependency>  <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>${mysql.version}</version> </dependency>  <dependency> <groupId>jstl</groupId> <artifactId>jstl</artifactId> <version>${jstl.version}</version> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>servlet-api</artifactId> <version>${servlet-api.version}</version> <scope>provided</scope> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>jsp-api</artifactId> <version>${jsp-api.version}</version> <scope>provided</scope> </dependency>  <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> </dependencies> <build> <defaultGoal>install</defaultGoal> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.6.1</version> <configuration> <source>1.8</source> <target>1.8</target> </configuration> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <version>3.0.2</version> <configuration> <encoding>UTF-8</encoding> </configuration> </plugin> </plugins>  <resources> <resource> <directory>src/main/java</directory> <includes> <include>**/*.xml</include> </includes> </resource> </resources> </build>

2.配置文件

<context:component-scan base-package="cn.test.service.impl"/>  <tx:annotation-driven transaction-manager="txManager" proxy-target-class="true"/>  <context:property-placeholder location="classpath:resource/jdbc.properties"/>  <tx:advice id="txAdvice" transaction-manager="txManager">  <tx:attributes> <tx:method name="add*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.Exception"/> <tx:method name="save*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.Exception"/> <tx:method name="insert*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.Exception"/> <tx:method name="update*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.Exception"/> <tx:method name="modify*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.Exception"/> <tx:method name="delete*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.Exception"/>  <tx:method name="query*" read-only="true"/> <tx:method name="select*" read-only="true"/> <tx:method name="find*" read-only="true"/> </tx:attributes> </tx:advice>  <aop:config> <aop:pointcut expression="execution(* cn.test.service.impl.*.*(..))" id="tranpointcut"/> <aop:advisor advice-ref="txAdvice" pointcut-ref="tranpointcut"/> </aop:config>  <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close"> <property name="forceShutdown" value="false"/> </bean> <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp"> <property name="transactionTimeout" value="300000"/> </bean>  <bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager"> <property name="transactionManager"> <ref bean="atomikosTransactionManager"/> </property> <property name="userTransaction"> <ref bean="atomikosUserTransaction"/> </property> <property name="allowCustomIsolationLevels" value="true"/> </bean>  <bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close" abstract="true"> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/> <property name="poolSize" value="10"/> <property name="minPoolSize" value="10"/> <property name="maxPoolSize" value="30"/> <property name="borrowConnectionTimeout" value="60"/> <property name="reapTimeout" value="20"/> <property name="maxIdleTime" value="60"/> <property name="maintenanceInterval" value="60"/> <property name="testQuery"> <value>SELECT 1</value> </property> </bean>  <bean id="dataSourceOne" parent="abstractXADataSource"> <property name="uniqueResourceName"> <value>dataSourceOne</value> </property> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/> <property name="xaProperties"> <props> <prop key="URL">${jdbc.url}</prop> <prop key="user">${jdbc.username}</prop> <prop key="password">${jdbc.pwd}</prop> </props> </property> </bean>  <bean id="dataSourceLog" parent="abstractXADataSource"> <property name="uniqueResourceName"> <value>dataSourceLog</value> </property> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/> <property name="xaProperties"> <props> <prop key="URL">${jdbc.log.url}</prop> <prop key="user">${jdbc.log.username}</prop> <prop key="password">${jdbc.log.pwd}</prop> </props> </property> </bean>  <bean id="sqlSessionFactoryBeanOne" class="org.mybatis.spring.SqlSessionFactoryBean">  <property name="typeAliasesPackage" value="cn.test.model"/> <property name="configLocation" value="classpath:mybatis/mybatis.xml"/> <property name="mapperLocations"> <array> <value>classpath:cn/test/mapper/*Mapper.xml</value> </array> </property> <property name="dataSource" ref="dataSourceOne"/> </bean>  <bean id="mapperScannerConfigurerOne" class="org.mybatis.spring.mapper.MapperScannerConfigurer">  <property name="basePackage" value="cn.test.mapper"/> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryBeanOne"/> </bean>  <bean id="sqlSessionFactoryBeanLog" class="org.mybatis.spring.SqlSessionFactoryBean">  <property name="typeAliasesPackage" value="cn.test.model"/> <property name="configLocation" value="classpath:mybatis/mybatis.xml"/> <property name="mapperLocations"> <array> <value>classpath:cn/test/logmapper/*Mapper.xml</value> </array> </property> <property name="dataSource" ref="dataSourceLog"/> </bean>  <bean id="mapperScannerConfigurerLog" class="org.mybatis.spring.mapper.MapperScannerConfigurer">  <property name="basePackage" value="cn.test.logmapper"/> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryBeanLog"/> </bean> <bean class="com.fasterxml.jackson.databind.ObjectMapper" id="objectMapper"/>

3.代码测试

专利

最新回复(0)