spring3.0 分布式事務 jta atomikos

1.使用如下jar包

atomikos-util.3.7.0.jar

cglib-nodep-2.2.2.jar

transactions-3.7.0.jar

transactions-api-3.7.0.jar

transactions-jdbc-3.7.0.jar

transactions-jta-3.7.0.jar

2.spring配置文件如下:

1. <?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jee="http://www.springframework.org/schema/jee"
4. xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
5. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"
6. default-lazy-init="true">
9. <context:component-scan base-package="com.atom.jta.test" />
11. <!-- atomikos事務管理器 -->
12. <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
13. init-method="init" destroy-method="close">
14. <description>UserTransactionManager</description>
15. <property name="forceShutdown">
16. <value>true</value>
17. </property>
18. </bean>
20. <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
21. <property name="transactionTimeout" value="300" />
22. </bean>
24. <!-- spring 事務管理器 -->
25. <bean id="springTransactionManager"
26. class="org.springframework.transaction.jta.JtaTransactionManager">
27. <property name="transactionManager">
28. <ref bean="atomikosTransactionManager" />
29. </property>
30. <property name="userTransaction">
31. <ref bean="atomikosUserTransaction" />
32. </property>
33. <property name="allowCustomIsolationLevels" value="true">
34. </property>
35. </bean>
37. <!-- 事務攔截器 -->
38. <bean id="transactionInterceptor"
39. class="org.springframework.transaction.interceptor.TransactionInterceptor">
40. <!-- 配置事務管理器 -->
41. <property name="transactionManager" ref="springTransactionManager" />
42. <!-- 方法名：要求的事務屬性 -->
43. <property name="transactionAttributes">
44. <props>
45. <prop key="insertTest">PROPAGATION_REQUIRED,ISOLATION_REPEATABLE_READ,-Throwable
46. </prop>
47. </props>
48. </property>
49. </bean>
51. <bean
52. class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
53. <property name="beanNames">
54. <list>
55. <value>atomTransactionServiceImpl</value>
56. </list>
57. </property>
58. <property name="interceptorNames">
59. <list>
60. <value>transactionInterceptor</value>
61. </list>
62. </property>
63. </bean>
64. </beans>

2.數據源:

datasource1:

1. package com.atom.jta.test;
3. import java.util.Properties;
5. import org.springframework.stereotype.Repository;
7. import com.atomikos.jdbc.AtomikosDataSourceBean;
8. @Repository
9. public class MasterAtomDatasource extends AtomikosDataSourceBean {
11. private static final long serialVersionUID = -2471230875536339311L;
13. public MasterAtomDatasource(){
14. Properties prop = new Properties();
15. prop.put("user", "root");
16. prop.put("password", "");
17. prop.put("URL", "jdbc:mysql://127.0.0.1:3306/test?autoReconnect=true");
18. setXaDataSourceClassName("com.mysql.jdbc.jdbc2.optional.MysqlXADataSource");
19. setUniqueResourceName("mysql_ds1");
20. setPoolSize(5);
21. setXaProperties(prop);
22. }
24. }

datasource2:

1. package com.atom.jta.test;
3. import java.util.Properties;
5. import org.springframework.stereotype.Repository;
7. import com.atomikos.jdbc.AtomikosDataSourceBean;
8. @Repository
9. public class SlaveAtomDataSource extends AtomikosDataSourceBean {
11. private static final long serialVersionUID = -6210394799199416765L;
12. public SlaveAtomDataSource(){
13. Properties prop = new Properties();
14. prop.put("user", "root");
15. prop.put("password", "");
16. prop.put("URL", "jdbc:mysql://127.0.0.1:3306/test1?autoReconnect=true");
17. setXaDataSourceClassName("com.mysql.jdbc.jdbc2.optional.MysqlXADataSource");
18. setUniqueResourceName("mysql_ds2");
19. setPoolSize(5);
20. setXaProperties(prop);
21. }
24. }

3.BaseDao:

1. package com.atom.jta.test;
3. import javax.annotation.Resource;
4. import javax.sql.DataSource;
6. import org.springframework.jdbc.core.JdbcTemplate;
7. import org.springframework.stereotype.Repository;
8. @Repository
9. public class AtomBaseDao {
10. private JdbcTemplate mastTemplate;
11. private JdbcTemplate slaveTemplate;
13. public JdbcTemplate getMastTemplate() {
14. return mastTemplate;
15. }
16. @Resource(name="masterAtomDatasource")
17. public void setMastTemplate(DataSource source) {
18. this.mastTemplate = new JdbcTemplate(source);
19. }
20. public JdbcTemplate getSlaveTemplate() {
21. return slaveTemplate;
22. }
23. @Resource(name="slaveAtomDataSource")
24. public void setSlaveTemplate(DataSource source) {
25. this.slaveTemplate = new JdbcTemplate(source);
26. }
29. }

4.測試service

1. package com.atom.jta.test;
3. import org.springframework.context.ApplicationContext;
5. public interface AtomTransactionService {
6. public void insertTest(ApplicationContext ctx) throws Exception;
7. }

1. package com.atom.jta.test;
3. import org.springframework.context.ApplicationContext;
4. import org.springframework.stereotype.Service;
5. @Service
6. public class AtomTransactionServiceImpl implements AtomTransactionService {
7. public void insertTest(ApplicationContext ctx) throws Exception {
8. AtomBaseDao baseDao = ctx.getBean(AtomBaseDao.class);
9. String str = "xxxx";
10. String masterSql = "insert into demo (name) values "+"(‘"+str+"‘)";
11. String slaveSql = "insert into test (name) values "+"(‘"+str+"‘)";
12. baseDao.getMastTemplate().execute(masterSql);
13. baseDao.getSlaveTemplate().execute(slaveSql);
14. throw new Exception();
15. }
17. }

5.事務測試

1. package com.atom.jta.test;
3. import org.springframework.context.ApplicationContext;
4. import org.springframework.context.support.ClassPathXmlApplicationContext;
6. public class AtomTest {
7. public AtomTest(){
8. ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext-atomikos.xml");
9. AtomTransactionService service = ctx.getBean(AtomTransactionService.class);
10. try {
11. service.insertTest(ctx);
12. } catch (Exception e) {
13. e.printStackTrace();
14. }
15. }
17. public static void main(String[] args) {
18. AtomTest test = new AtomTest();
19. System.out.println("done.....");
20. }
22. }

JTA分布式事務實戰