JOTM分布式事務管理(多數據源)配置

項目接近尾聲，老大讓我們幾個研究一些新技術，以便為將來項目的擴展做打算，我被分配到JOTM這一塊。說實話，自己對分布式事務也不了解，至於JTA，只是了解概念。

至於什么是JOTM、JOTM有什么用，大家可以訪問官網http://jotm.objectweb.org/index.html或者百度、google。趁着周末閑，於是搞了個DEMO。這個demo是用spring和jotm實現，數據庫采用的oracle.本文只做簡單的配置介紹，以及實現基本的同步回滾、提交效果。

首先，下載jar包，我的項目用的jar包如下：

基本上就是spring、JOTM以及oracle驅動jar包。

其次：引入carol.properties log4j.properties兩個配置文件，這些文件可以再下載的JOTM的conf目錄里找到。同時，新建一個spring的配置文件，用來初始化數據源之類的。

這是我的文件內容：

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd"> <bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean" /> <bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager"> <property name="userTransaction" ref="jotm" /> </bean> <bean id="topicDS" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown"> <property name="dataSource"> <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown"> <property name="transactionManager" ref="jotm" /> <property name="driverName" value="oracle.jdbc.driver.OracleDriver" /> <property name="url" value="jdbc:oracle:thin:@192.168.7.223:1521:ORCL" /> </bean> </property> <property name="user" value="crmg1" /> <property name="password" value="crmg" /> </bean> <bean id="postDS" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown"> <property name="dataSource"> <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown"> <property name="transactionManager" ref="jotm" /> <property name="driverName" value="oracle.jdbc.driver.OracleDriver" /> <property name="url" value="jdbc:oracle:thin:@192.168.7.223:1521:ORCL" /> </bean> </property> <property name="user" value="crm20120224" /> <property name="password" value="crm" /> </bean> <bean id="topicTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="topicDS" /> </bean> <bean id="postTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="postDS" /> </bean> <bean id="topicDao" class="com.test.Dao1ServiceImpl"> <property name="jdbcTemplate" ref="topicTemplate" /> <property name="dao2Service" ref="postDao" /> </bean> <bean id="postDao" class="com.test.Dao2ServiceImpl"> <property name="jdbcTemplate" ref="postTemplate" /> </bean> <tx:annotation-driven transaction-manager="txManager" /> </beans>

我配置了兩個oracle的數據源。兩個數據源都交給JOTM來管理。同時有兩個service:Dao1ServiceImpl\Dao2ServiceImpl分別操作兩個數據源的表。為這兩個service添加事務

兩個service實現如下：

package com.test; import org.springframework.jdbc.core.JdbcTemplate; public class Dao1ServiceImpl implements IDao1Service { private JdbcTemplate jdbcTemplate; private IDao2Service dao2Service; public IDao2Service getDao2Service() { return dao2Service; } public void setDao2Service(IDao2Service dao2Service) { this.dao2Service = dao2Service; } public JdbcTemplate getJdbcTemplate() { return jdbcTemplate; } public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } public void add() { String str = "insert into t_staff(PK_ID,NAME,STAFF_TYPE,IS_DISABLE) values(2,'wyb','客服','0')"; jdbcTemplate.update(str); int i=5/0; dao2Service.add(); } }

 

package com.test; import org.springframework.jdbc.core.JdbcTemplate; public class Dao2ServiceImpl implements IDao2Service { private JdbcTemplate jdbcTemplate; public JdbcTemplate getJdbcTemplate() { return jdbcTemplate; } public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } public void add() { String str = "insert into t_user values(200,'wyb','123','0',null,null,null,null)"; jdbcTemplate.update(str); } }

把service1的add方法和service2的add方法在service1中調用service2的方法，同時讓service1出現異常，這樣在分布式事務的情況下會得到結果：兩條數據都米有插入成功，同時回滾。

測試類：

public class TestJOTM { public static void main(String[] args) { ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext-jta.xml", TestJOTM.class); IDao1Service d1 = (IDao1Service)ctx.getBean("topicDao"); try{ d1.add(); }catch (Exception e) { // TODO: handle exception } } }

記錄下配置的步驟，給自己留個備份。

剛開始的時候是用MySQL進行測試的，一直不行。搜了很多，原來MySQL不支持事務管理，暈。

demo我已經上傳到我的CSDN資源里面了，大家可以去下載（免下載積分）http://download.csdn.net/detail/wangyinbin/4246381。PS:CSDN下載專區，為啥剛剛上傳的資源自己看不到咯？