分布式事物的spring的实现

淡淡的烟草味﹌ 2022-08-01 12:18 170阅读 0赞

分布式事务是指操作多个数据库之间的事务，spring的org.springframework.transaction.jta.JtaTransactionManager，提供了分布式事务支持。如果使用WAS的JTA支持，把它的属性改为WebSphere对应的TransactionManager。   
    在tomcat下，是没有分布式事务的，不过可以借助于第三方软件jotm（Java Open Transaction Manager ）和AtomikosTransactionsEssentials实现，在spring中分布式事务是通过jta（jotm，atomikos）来进行实现。   
1、http://jotm.objectweb.org/   
2、http://www.atomikos.com/Main/TransactionsEssentials   
  
一、使用JOTM例子    
(1)、Dao及实现

Java代码   ![收藏代码][icon_star.png]

1.  **public** **interface** GenericDao \{  
2.    
3.      **public** **int** save(String ds, String sql, Object\[\] obj) **throws** Exception;  
4.        
5.      **public** **int** findRowCount(String ds, String sql);  
6.        
7.  \}

Java代码   ![收藏代码][icon_star.png]

1.  **public** **class** GenericDaoImpl **implements** GenericDao\{  
2.    
3.      **private**  JdbcTemplate jdbcTemplateA;  
4.      **private**  JdbcTemplate jdbcTemplateB;  
5.    
6.      **public** **void** setJdbcTemplateA(JdbcTemplate jdbcTemplate) \{  
7.          **this**.jdbcTemplateA = jdbcTemplate;  
8.      \}  
9.    
10.     **public** **void** setJdbcTemplateB(JdbcTemplate jdbcTemplate) \{  
11.         **this**.jdbcTemplateB = jdbcTemplate;  
12.     \}  
13.       
14.     **public** **int** save(String ds, String sql, Object\[\] obj) **throws** Exception\{  
15.         **if**(**null** == ds || "".equals(ds)) **return** -1;  
16.         **try**\{  
17.             **if**(ds.equals("A"))\{  
18.                 **return** **this**.jdbcTemplateA.update(sql, obj);  
19.             \}**else**\{  
20.                 **return** **this**.jdbcTemplateB.update(sql, obj);  
21.             \}  
22.         \}**catch**(Exception e)\{  
23.             e.printStackTrace();  
24.             **throw** **new** Exception("执行" + ds + "数据库时失败！");  
25.         \}  
26.     \}  
27.   
28.     **public** **int** findRowCount(String ds, String sql) \{  
29.         **if**(**null** == ds || "".equals(ds)) **return** -1;  
30.           
31.         **if**(ds.equals("A"))\{  
32.             **return** **this**.jdbcTemplateA.queryForInt(sql);  
33.         \}**else**\{  
34.             **return** **this**.jdbcTemplateB.queryForInt(sql);  
35.         \}  
36.     \}  
37.   
38. \}

(2)、Service及实现

Java代码   ![收藏代码][icon_star.png]

1.  **public** **interface** UserService \{  
2.        
3.      **public** **void** saveUser() **throws** Exception;  
4.        
5.  \}

Java代码   ![收藏代码][icon_star.png]

1.  **public** **class** UserServiceImpl **implements** UserService\{  
2.    
3.      **private** GenericDao genericDao;  
4.        
5.      **public** **void** setGenericDao(GenericDao genericDao) \{  
6.          **this**.genericDao = genericDao;  
7.      \}  
8.    
9.      **public** **void** saveUser() **throws** Exception \{  
10.         String userName = "user\_" + Math.round(Math.random()\*10000);  
11.         System.out.println(userName);  
12.           
13.         StringBuilder sql = **new** StringBuilder();  
14.         sql.append(" insert into t\_user(username, gender) values(?,?); ");  
15.         Object\[\] objs = **new** Object\[\]\{userName,"1"\};  
16.           
17.         genericDao.save("A", sql.toString(), objs);  
18.           
19.         sql.delete(0, sql.length());  
20.         sql.append(" insert into t\_user(name, sex) values(?,?); ");  
21.         objs = **new** Object\[\]\{userName,"男的"\};//值超出范围  
22.         genericDao.save("B", sql.toString(), objs);  
23.     \}  
24.   
25. \}

(3)、applicationContext-jotm.xml

Xml代码   ![收藏代码][icon_star.png]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.    
3.  **<****beans** xmlns="http://www.springframework.org/schema/beans"   
4.      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   
5.      xmlns:context="http://www.springframework.org/schema/context"   
6.      xmlns:aop="http://www.springframework.org/schema/aop"   
7.      xmlns:tx="http://www.springframework.org/schema/tx"   
8.      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd   
9.      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd   
10.     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd   
11.     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd"**>**  
12.   
13.     **<****description****>**springJTA**</****description****>**  
14.   
15.        
16.     **<****bean** id="propertyConfig"   
17.             class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"**>**   
18.         **<****property** name="locations"**>**   
19.             **<****list****>**   
20.                 **<****value****>**classpath:jdbc.properties**</****value****>**   
21.             **</****list****>**   
22.         **</****property****>**   
23.     **</****bean****>**   
24.       
25.       
26.     **<****bean** id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean"**>**  
27.           **<****property** name="defaultTimeout" value="500000"**/>**  
28.     **</****bean****>**  
29.   
30.       
31.     **<****bean** id="jtaTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"**>**     
32.         **<****property** name="userTransaction" ref="jotm" **/>**     
33.     **</****bean****>**  
34.   
35.        
36.     **<****bean** id="dataSourceA" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown"**>**   
37.        **<****property** name="dataSource"**>**   
38.            **<****bean** class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown"**>**   
39.                **<****property** name="transactionManager" ref="jotm"**/>**   
40.                **<****property** name="driverName" value="$\{jdbc.driver\}"**/>**   
41.                **<****property** name="url" value="$\{jdbc.url\}"**/>**   
42.            **</****bean****>**   
43.        **</****property****>**   
44.        **<****property** name="user" value="$\{jdbc.username\}"**/>**   
45.        **<****property** name="password" value="$\{jdbc.password\}"**/>**   
46.     **</****bean****>**   
47.   
48.        
49.     **<****bean** id="dataSourceB" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown"**>**   
50.        **<****property** name="dataSource"**>**   
51.            **<****bean** class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown"**>**   
52.                **<****property** name="transactionManager" ref="jotm"**/>**   
53.                **<****property** name="driverName" value="$\{jdbc2.driver\}"**/>**   
54.                **<****property** name="url" value="$\{jdbc2.url\}"**/>**   
55.            **</****bean****>**   
56.        **</****property****>**   
57.        **<****property** name="user" value="$\{jdbc2.username\}"**/>**   
58.        **<****property** name="password" value="$\{jdbc2.password\}"**/>**   
59.     **</****bean****>**   
60.   
61.     **<****bean** id = "jdbcTemplateA"   
62.          class = "org.springframework.jdbc.core.JdbcTemplate"**>**   
63.          **<****property** name = "dataSource" ref="dataSourceA"**/>**   
64.     **</****bean****>**  
65.       
66.     **<****bean** id = "jdbcTemplateB"   
67.          class = "org.springframework.jdbc.core.JdbcTemplate"**>**   
68.          **<****property** name = "dataSource" ref="dataSourceB"**/>**   
69.     **</****bean****>**      
70.   
71.        
72.     **<****aop:config****>**   
73.         **<****aop:pointcut** id="pointCut"  
74.                 expression="execution(\* com.logcd.service..\*.\*(..))"**/>**  
75.         **<****aop:advisor** pointcut-ref="pointCut" advice-ref="txAdvice"**/>**   
76.           
77.         **<****aop:advisor** pointcut="execution(\* \*..common.service..\*.\*(..))" advice-ref="txAdvice"**/>**  
78.     **</****aop:config****>**   
79.   
80.        
81.     **<****tx:advice** id="txAdvice" transaction-manager="jtaTransactionManager"**>**   
82.        **<****tx:attributes****>**   
83.           **<****tx:method** name="delete\*" rollback-for="Exception"**/>**   
84.           **<****tx:method** name="save\*" rollback-for="Exception"**/>**   
85.           **<****tx:method** name="update\*" rollback-for="Exception"**/>**   
86.           **<****tx:method** name="find\*" read-only="true" rollback-for="Exception"**/>**   
87.        **</****tx:attributes****>**   
88.     **</****tx:advice****>**   
89.   
90.     **<****bean** id="genericDao"   
91.             class="com.logcd.dao.impl.GenericDaoImpl" autowire="byName"**>**  
92.     **</****bean****>**  
93.   
94.     **<****bean** id="userService"   
95.             class="com.logcd.service.impl.UserServiceImpl" autowire="byName"**>**  
96.     **</****bean****>**  
97.   
98. **</****beans****>**

(4)、测试

Java代码   ![收藏代码][icon_star.png]

1.  **public** **class** TestUserService\{  
2.    
3.      **private** **static** UserService userService;  
4.        
5.      @BeforeClass  
6.      **public** **static** **void** init()\{  
7.          ApplicationContext app = **new** ClassPathXmlApplicationContext("applicationContext-jotm.xml");  
8.          userService = (UserService)app.getBean("userService");  
9.      \}  
10.       
11.     @Test  
12.     **public** **void** save()\{  
13.         System.out.println("begin...");  
14.         **try**\{  
15.             userService.saveUser();  
16.         \}**catch**(Exception e)\{  
17.             System.out.println(e.getMessage());  
18.         \}  
19.         System.out.println("finish...");  
20.     \}  
21.       
22. \}

二、关于使用atomikos实现    
(1)、数据源配置

Xml代码   ![收藏代码][icon_star.png]

1.  **<****bean** id="dataSourceA" class="com.atomikos.jdbc.SimpleDataSourceBean" init-method="init" destroy-method="close"**>**  
2.      **<****property** name="uniqueResourceName"**>**  
3.          **<****value****>**$\{datasource.uniqueResourceName\}**</****value****>**  
4.      **</****property****>**  
5.      **<****property** name="xaDataSourceClassName"**>**   
6.          **<****value****>**$\{database.driver\_class\}**</****value****>**   
7.      **</****property****>**   
8.      **<****property** name="xaDataSourceProperties"**>**  
9.          **<****value****>**URL=$\{database.url\};user=$\{database.username\};password=$\{database.password\}**</****value****>**   
10.     **</****property****>**   
11.     **<****property** name="exclusiveConnectionMode"**>**   
12.         **<****value****>**$\{connection.exclusive.mode\}**</****value****>**   
13.     **</****property****>**  
14.     **<****property** name="connectionPoolSize"**>**   
15.         **<****value****>**$\{connection.pool.size\}**</****value****>**  
16.     **</****property****>**  
17.     **<****property** name="connectionTimeout"**>**  
18.         **<****value****>**$\{connection.timeout\}**</****value****>**  
19.     **</****property****>**  
20.     **<****property** name="validatingQuery"**>**   
21.         **<****value****>**SELECT 1**</****value****>**   
22.     **</****property****>**   
23. **</****bean****>**

(2)、事务配置

Xml代码   ![收藏代码][icon_star.png]

1.  **<****bean** id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"   
2.      init-method="init" destroy-method="close"**>**   
3.      **<****property** name="forceShutdown" value="true"**/>**   
4.  **</****bean****>**   
5.    
6.  **<****bean** id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp"**>**   
7.      **<****property** name="transactionTimeout" value="$\{transaction.timeout\}"**/>**   
8.  **</****bean****>**  
9.    
10.    
11. **<****bean** id="springTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"**>**   
12.     **<****property** name="transactionManager" ref="atomikosTransactionManager"**/>**   
13.     **<****property** name="userTransaction" ref="atomikosUserTransaction"**/>**   
14. **</****bean****>**  
15.   
16.    
17. **<****aop:config****>**   
18.     **<****aop:pointcut** id="serviceOperation"  expression="execution(\* \*..service\*..\*(..))"**/>**   
19.     **<****aop:advisor** pointcut-ref="serviceOperation" advice-ref="txAdvice"**/>**   
20. **</****aop:config****>**  
21.   
22.   
23. **<****tx:advice** id="txAdvice" transaction-manager="springTransactionManager"**>**   
24.     **<****tx:attributes****>**  
25.         **<****tx:method** name="\*" rollback-for="Exception"**/>**   
26.     **</****tx:attributes****>**   
27. **</****tx:advice****>**

[icon_star.png]: /images/20220731/e44952cf014f4a3b850694cad59994cd.png