spring 事物控制---多資料來源與 atomikos 分散式事務配置(接之前未完成的部分)
阿新 • • 發佈：2019-01-23
接上一篇
說明：解決了多個數據源的資料同步問題（例如：在一個事物裡add操作A庫的a表,同時add操作B庫b表，如果B庫連線中斷或者因為別的異常造成b表寫入失敗，希望a表回滾）需要引入相關jar包。
1.pom.xml(需要新的jar包，就不一一列舉了)
<!-- https://mvnrepository.com/artifact/com.atomikos/transactions-jdbc -->
<dependency>
<groupId>com.atomikos</groupId>
<artifactId 2.spring-mybatis.xml改動（主要是資料來源和事物部分的改動）
mysql
name=”xaDataSourceClassName” value=”com.mysql.jdbc.jdbc2.optional.MysqlXADataSource”
oracle資料庫
name=”xaDataSourceClassName” value=”com.sybase.jdbc3.jdbc.SybXADataSource”
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.1.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">
<!-- 自動掃描 -->
<context:component-scan base-package="com" />
<!-- 引入配置檔案 -->
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:jdbc.properties" />
</bean>
<!-- test -->
<!-- <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="${driver}" />
<property name="url" value="${url}" />
<property name="username" value="${username}" />
<property name="password" value="${password}" />
初始化連線大小
<property name="initialSize" value="${initialSize}"></property>
連線池最大數量
<property name="maxActive" value="${maxActive}"></property>
連線池最大空閒
<property name="maxIdle" value="${maxIdle}"></property>
連線池最小空閒
<property name="minIdle" value="${minIdle}"></property>
獲取連線最大等待時間
<property name="maxWait" value="${maxWait}"></property>
</bean> -->
<!-- XA方式 test-->
<bean id="dataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean">
<property name="uniqueResourceName" value="test"/>
<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
<property name="xaProperties">
<props>
<prop key="url">${url}</prop>
<prop key="user">${username}</prop>
<prop key="password">${password}</prop>
</props>
</property>
<property name="minPoolSize" value="10" />
<property name="maxPoolSize" value="100" />
<property name="borrowConnectionTimeout" value="30" />
<property name="testQuery" value="select 1" />
<property name="maintenanceInterval" value="60" />
</bean>
<!-- soringmvc -->
<!-- <bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="${driver}" />
<property name="url" value="${url2}" />
<property name="username" value="${username2}" />
<property name="password" value="${password2}" />
初始化連線大小
<property name="initialSize" value="${initialSize}"></property>
連線池最大數量
<property name="maxActive" value="${maxActive}"></property>
連線池最大空閒
<property name="maxIdle" value="${maxIdle}"></property>
連線池最小空閒
<property name="minIdle" value="${minIdle}"></property>
獲取連線最大等待時間
<property name="maxWait" value="${maxWait}"></property>
</bean> -->
<!-- XA方式 soringmvc-->
<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean">
<property name="uniqueResourceName" value="soringmvc"/>
<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
<property name="xaProperties">
<props>
<prop key="url">${url2}</prop>
<prop key="user">${username2}</prop>
<prop key="password">${password2}</prop>
</props>
</property>
<property name="minPoolSize" value="10" />
<property name="maxPoolSize" value="100" />
<property name="borrowConnectionTimeout" value="30" />
<property name="testQuery" value="select 1" />
<property name="maintenanceInterval" value="60" />
</bean>
<!--============== test 資料來源1(ok)============== -->
<!-- spring和MyBatis完美整合，不需要mybatis的配置對映檔案 -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="configLocation" value="classpath:jdbcyw1-mybatis-config.xml"></property>
<!-- 自動掃描mapping.xml檔案 -->
<!-- <property name="mapperLocations" value="classpath:com/jdbcyw1/*/*.xml"></property> -->
</bean>
<!-- DAO介面所在包名，Spring會自動查詢其下的類 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.jdbcyw1.dao" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
</bean>
<!--============== srpingmvc 資料來源2(ok)============== -->
<!-- spring和MyBatis完美整合，不需要mybatis的配置對映檔案 -->
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource2" />
<!-- 自動掃描mapping.xml檔案 -->
<property name="mapperLocations" value="classpath:com/jdbcbase/*/*.xml"></property>
</bean>
<!-- DAO介面所在包名，Spring會自動查詢其下的類 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.jdbcbase.dao" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2"></property>
</bean>
<!--======事務(ok)====== -->
<!-- 申明式食物配置 -->
<!-- test庫(事務管理)transaction manager, use JtaTransactionManager for global tx -->
<!-- <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
srpingmvc 庫
<bean id="transactionManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource2" />
</bean>
註解方式配置事物
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" />
註解方式配置事物
<tx:annotation-driven transaction-manager="transactionManager2" proxy-target-class="true" /> -->
<!-- 分散式事務 -->
<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" >
<property name="forceShutdown" value="true"/>
</bean>
<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
<property name="transactionTimeout" value="300"/>
</bean>
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager" ref="atomikosTransactionManager"/>
<property name="userTransaction" ref="atomikosUserTransaction"/>
</bean>
<!-- <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager">
<bean class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
<property name="forceShutdown" value="true"/>
</bean>
</property>
<property name="userTransaction">
<bean class="com.atomikos.icatch.jta.UserTransactionImp"/>
</property>
</bean> -->
<tx:annotation-driven transaction-manager="transactionManager"/>
<!-- =====AOP方式3human(存在問題測試中)===== -->
<!-- 定義了bean被初始化之前和之後要執行的方法 -->
<bean class="com.InitBean" />
<!--避免IE執行AJAX時，返回JSON出現下載檔案 -->
<bean id="mappingJacksonHttpMessageConverter"
class="org.springframework.http.converter.json.MappingJacksonHttpMessageConverter">
<property name="supportedMediaTypes">
<list>
<value>text/html;charset=UTF-8</value>
</list>
</property>
</bean>
<!-- 啟動SpringMVC的註解功能，完成請求和註解POJO的對映 -->
<bean
class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
<property name="messageConverters">
<list>
<ref bean="mappingJacksonHttpMessageConverter" /> <!-- JSON轉換器 -->
</list>
</property>
</bean>
<!--配置攔截器, 多個攔截器,順序執行 -->
<mvc:interceptors>
<mvc:interceptor>
<!-- 匹配的是url路徑， 如果不配置或/**,將攔截所有的Controller -->
<mvc:mapping path="/" />
<mvc:mapping path="/user/**" />
<mvc:mapping path="/menu/getMenuList*" />
<bean class="com.cn.interceptor.CommonInterceptor"></bean>
</mvc:interceptor>
<!-- 當設定多個攔截器時，先按順序呼叫preHandle方法，然後逆序呼叫每個攔截器的postHandle和afterCompletion方法 -->
</mvc:interceptors>
<!-- 新增異常預設跳轉頁 -->
<bean class="org.springframework.web.servlet.handler.SimpleMappingExceptionResolver">
<property name="exceptionMappings">
<props>
<prop key="com.exception.SpringException">
ExceptionPage
</prop>
</props>
</property>
<property name="defaultErrorView" value="error"/>
</bean>
</beans>3.新新增一個jta.propertis配置檔案，與log4j配置檔案同路徑
com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory
com.atomikos.icatch.log_base_name = jdbc
com.atomikos.icatch.tm_unique_name = com.atomikos.spring.jdbc.tm
com.atomikos.icatch.serializable_logging=false
改造完成，測試
1.在MenuController.java新增一個方法,完成多資料來源資料add
@RequestMapping("/addUserAndMenu")
@ResponseBody
public int addUserAndMenu(){
User user = new User();
user.setName("test");
user.setPwd("pwd的都");
Menu menu = new Menu();
menu.setMenuId("11111111111");
menu.setMenuName("tests是");
return menuService.addUserAndMenu(user,menu);
}2.對應MenuServiceImpl.java（注入另一個數據源的dao）
@Resource
private MenuDao menuDao;
@Resource
private UserDao userDao;
@Override
@Transactional
public int addUserAndMenu(User user,Menu menu){
//ApplicationContext ack2 = new ClassPathXmlApplicationContext("spring-mybatis.xml");
//SqlSessionFactory sqlSessionFactory= (SqlSessionFactory) ack2.getBean("sqlSessionFactory");
//SqlSession ss = sqlSessionFactory.openSession();
//List<User> list = ss.selectList("queryUser");
//ss.insert("addUser", user);
//ss.commit();
//ss.rollback();
//上面程式碼可以把資料add到資料庫，但是無法回滾，樓主也不明白，求大神解釋
System.out.println("atttttttttt");
int flag = 0;
flag += this.userDao.addUser(user);
flag += this.menuDao.addMenu(menu);
System.out.println(1/0);//模擬異常使資料回滾
return flag;
}3.測試(成功，資料庫無髒資料，控制檯也看到了回滾記錄)
