一、概念

分布式事務(wù)
分布式事務(wù)是指事務(wù)的參與者、支持事務(wù)的服務(wù)器、資源服務(wù)器以及事務(wù)管理器分別位于不同的分布式系統(tǒng)的不同節(jié)點之上。簡言之，同時操作多個數(shù)據(jù)庫保持事務(wù)的統(tǒng)一，達(dá)到跨庫事務(wù)的效果。

JTA
JTA，即Java Transaction API，JTA允許應(yīng)用程序執(zhí)行分布式事務(wù)處理———在兩個或多個網(wǎng)絡(luò)計算機(jī)資源上訪問并且更新數(shù)據(jù)。JDBC驅(qū)動程序的JTA支持極大地增強(qiáng)了數(shù)據(jù)訪問能力。

JTA和JTS

Java事務(wù)API（JTA：Java Transaction API）和它的同胞Java事務(wù)服務(wù)（JTS：Java Transaction Service），為J2EE平臺提供了分布式事務(wù)服務(wù)（distributed transaction）。
一個分布式事務(wù)（distributed transaction）包括一個事務(wù)管理器（transaction manager）和一個或多個資源管理器(resource manager）。
一個資源管理器（resource manager）是任意類型的持久化數(shù)據(jù)存儲。
事務(wù)管理器（transaction manager）承擔(dān)著所有事務(wù)參與單元者的相互通訊的責(zé)任。

JTA與JDBC

JTA事務(wù)比JDBC事務(wù)更強(qiáng)大。一個JTA事務(wù)可以有多個參與者，而一個JDBC事務(wù)則被限定在一個單一的數(shù)據(jù)庫連接。下列任一個Java平臺的組件都可以參與到一個JTA事務(wù)中：JDBC連接、JDO PersistenceManager 對象、JMS 隊列、JMS 主題、企業(yè)JavaBeans（EJB）、一個用J2EE Connector Architecture 規(guī)范編譯的資源分配器。

JOTM
JOTM (Java Open Transaction Manager)是一個開源獨立的事務(wù)管理器，支持分布式事務(wù)，Spring3.X已經(jīng)不再支持JOTM。

Atomikos
Atomikos TransactionsEssentials是一個為Java平臺提供增值服務(wù)的并且開源類事務(wù)管理器，支持分布式事務(wù)，本文所采用的技術(shù)。

Atomikos是目前在分布式事務(wù)管理中做得相當(dāng)不錯的開源軟件。有10年以上的經(jīng)驗，Atomikos保障您的關(guān)鍵事務(wù)和防止昂貴的數(shù)據(jù)丟失在發(fā)生系統(tǒng)故障或事故中．Atomikos支持XA(全局事務(wù))和NON-XA(非全局事務(wù))，NON-XA效率高于XA。本文主要是講XA事件，因為要在不同的數(shù)據(jù)庫中操作多張表。

接下來說一下spring.x+hibernate中集成Atomikos構(gòu)建JTA的分布式事務(wù)

二、Spring.x+Hibernate+Atomikos集成
Spring.x+Hibernate怎么集成此處省略不說，主要講解Spring.x+Atomikos的集成，操作步驟如下：

1、下載Atomikos，需要以下這些包

atomikos-util-1.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、配置
在applicationContext.xml文件當(dāng)中作如下配置

<?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:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xmlns:jaxws="http://cxf.apache.org/jaxws"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.5.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-2.5.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-2.5.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsdhttp://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"><context:annotation-config /><!-- 通過注解方式自動掃描需交給sping管理的Bean --><context:component-scan base-package="com.ljq" /><!-- spring atomikos配置 --><!-- bpm數(shù)據(jù)源 --><bean id="bpmDataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"><!-- Set unique name for this DataSource --> <property name="uniqueResourceName"><value>bpm</value></property><!-- Set XADatasource class name--> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" /><property name="xaProperties"><props><prop key="user">root</prop><prop key="password">parami2013</prop><prop key="url">jdbc:mysql://192.168.1.254:3306/parami_bpm</prop></props></property><!-- set properties for datasource connection pool --> <property name="poolSize" value="3" /><!-- 管理 Connection 被占用的時間 --><!-- 如果不設(shè)置這個值，Atomikos使用默認(rèn)的300秒(即5分鐘)，那么在處理大批量數(shù)據(jù)讀取的時候，一旦超過5分鐘，就會拋出類似 Resultset is close 的錯誤 --><property name="reapTimeout"><value>20000</value></property> </bean><!-- center數(shù)據(jù)源 --><bean id="centerDataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"><property name="uniqueResourceName"><value>center</value></property><property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" /><property name="xaProperties"><props><prop key="user">root</prop><prop key="password">parami2013</prop><prop key="url">jdbc:mysql://192.168.1.254:3306/parami_center</prop></props></property><!-- 連接池里面連接的個數(shù) --><property name="poolSize" value="3" /><!-- 管理 Connection 被占用的時間 --><!-- 如果不設(shè)置這個值，Atomikos使用默認(rèn)的300秒(即5分鐘)，那么在處理大批量數(shù)據(jù)讀取的時候，一旦超過5分鐘，就會拋出類似 Resultset is close 的錯誤 --><property name="reapTimeout"><value>20000</value></property> </bean><!-- 將hibernate數(shù)據(jù)源注入sessionFactory --><bean id="bpmSessionFactory"class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"><property name="dataSource" ref="bpmDataSource" /><property name="packagesToScan"><list><value>com.ljq.pojo</value></list></property><property name="hibernateProperties"><props><prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop><prop key="hibernate.show_sql">true</prop><!-- 慎重(推薦禁止) 固定為update --><prop key="hibernate.hbm2ddl.auto">update</prop><prop key="hibernate.cache.provider_class">org.hibernate.cache.HashtableCacheProvider</prop></props></property></bean><!-- 將hibernate數(shù)據(jù)源注入sessionFactory --><bean id="centerSessionFactory"class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"><property name="dataSource" ref="centerDataSource" /><property name="packagesToScan"><list><value>com.ljq.pojo</value></list></property><property name="hibernateProperties"><props><prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop><prop key="hibernate.show_sql">true</prop><!-- 慎重(推薦禁止) 固定為update --><prop key="hibernate.hbm2ddl.auto">update</prop><prop key="hibernate.cache.provider_class">org.hibernate.cache.HashtableCacheProvider</prop></props></property></bean> <!-- atomikos事務(wù)管理器 --><bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close"><property name="forceShutdown"><value>true</value></property></bean><bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp"><property name="transactionTimeout" value="300" /></bean><!-- spring 事務(wù)管理器 --><bean id="springTransactionManager"class="org.springframework.transaction.jta.JtaTransactionManager"><property name="transactionManager" ref="atomikosTransactionManager"/><property name="userTransaction" ref="atomikosUserTransaction" /><property name="allowCustomIsolationLevels" value="true"/> </bean><!-- 使用annotation定義事務(wù)，對于要加入事物的類，只需對該類加 @Transactional --><tx:annotation-driven transaction-manager="springTransactionManager" /><!-- hibernate Dao層模板 --><bean id="bpmHibernateTemplate"class="org.springframework.orm.hibernate3.HibernateTemplate"><property name="sessionFactory" ref="bpmSessionFactory"></property></bean><bean id="centerHibernateTemplate"class="org.springframework.orm.hibernate3.HibernateTemplate"><property name="sessionFactory" ref="centerSessionFactory"></property></bean></beans>

3、在src文件夾下面加入一個transactions.properties文件

# SAMPLE PROPERTIES FILE FOR THE TRANSACTION SERVICE # THIS FILE ILLUSTRATES THE DIFFERENT SETTINGS FOR THE TRANSACTION MANAGER # UNCOMMENT THE ASSIGNMENTS TO OVERRIDE DEFAULT VALUES;# Required: factory implementation class of the transaction core. # NOTE: there is no default for this, so it MUST be specified! # com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory# Set base name of file where messages are output # (also known as the 'console file'). # # com.atomikos.icatch.console_file_name = tm.out# Size limit (in bytes) for the console file; # negative means unlimited. # # com.atomikos.icatch.console_file_limit=-1# For size-limited console files, this option # specifies a number of rotating files to # maintain. # # com.atomikos.icatch.console_file_count=1# Set the number of log writes between checkpoints # # com.atomikos.icatch.checkpoint_interval=500# Set output directory where console file and other files are to be put # make sure this directory exists! # # com.atomikos.icatch.output_dir = ./# Set directory of log files; make sure this directory exists! # # com.atomikos.icatch.log_base_dir = ./# Set base name of log file # this name will be used as the first part of # the system-generated log file name # # com.atomikos.icatch.log_base_name = tmlog# Set the max number of active local transactions # or -1 for unlimited. # # com.atomikos.icatch.max_actives = 50# Set the default timeout (in milliseconds) for local transactions # # com.atomikos.icatch.default_jta_timeout = 10000# Set the max timeout (in milliseconds) for local transactions # # com.atomikos.icatch.max_timeout = 300000# The globally unique name of this transaction manager process # override this value with a globally unique name # # com.atomikos.icatch.tm_unique_name = tm# Do we want to use parallel subtransactions? JTA's default # is NO for J2EE compatibility # # com.atomikos.icatch.serial_jta_transactions=true# If you want to do explicit resource registration then # you need to set this value to false. # # com.atomikos.icatch.automatic_resource_registration=true # Set this to WARN, INFO or DEBUG to control the granularity # of output to the console file. # # com.atomikos.icatch.console_log_level=WARN# Do you want transaction logging to be enabled or not? # If set to false, then no logging overhead will be done # at the risk of losing data after restart or crash. # # com.atomikos.icatch.enable_logging=true# Should two-phase commit be done in (multi-)threaded mode or not? # Set this to false if you want commits to be ordered according # to the order in which resources are added to the transaction. # # NOTE: threads are reused on JDK 1.5 or higher. # For JDK 1.4, thread reuse is enabled as soon as the # concurrent backport is in the classpath - see # http://mirrors.ibiblio.org/pub/mirrors/maven2/backport-util-concurrent/backport-util-concurrent/ # # com.atomikos.icatch.threaded_2pc=false# Should shutdown of the VM trigger shutdown of the transaction core too? # # com.atomikos.icatch.force_shutdown_on_vm_exit=false

4、注入HibernateTemplate模板
a、為bpm庫注入HibernateTemplate模板

public abstract class BpmDaoSupport<T> extends DaoSupport<T> {protected HibernateTemplate bpmHibernateTemplate;/*** HibernateTemplate注入* * @param bpmHibernateTemplate*/@Resourcepublic void setBpmHibernateTemplate(HibernateTemplate bpmHibernateTemplate) {this.bpmHibernateTemplate = bpmHibernateTemplate;setHibernateTemplate(bpmHibernateTemplate);}}

b、為center庫注入HibernateTemplate模板

public abstract class CenterDaoSupport<T> extends DaoSupport<T> {protected HibernateTemplate centerHibernateTemplate;/*** HibernateTemplate注入* * @param centerHibernateTemplate*/@Resourcepublic void setCenterHibernateTemplate(HibernateTemplate centerHibernateTemplate) {this.centerHibernateTemplate = centerHibernateTemplate;setHibernateTemplate(centerHibernateTemplate);} }

5、編寫業(yè)務(wù)邏輯代碼

@Service(value="userServiceBean") @Transactional public class UserServiceBean implements UserService {@Resource(name="userDaoBean") private UserDao userDao;@Resource(name="userRoleDaoBean") private UserRoleDao userRoleDao;public List<User> queryUser() {return userDao.queryUser();}public void save(User user, UserRole ur) {userDao.save(user); //a處//此處報異常System.out.println(1/0); //b處 ur.setUserId(user.getUid());userRoleDao.save(ur); //c處 } }

在執(zhí)行save()方法時會報java.lang.ArithmeticException: / by zero異常，b處的“1/0”有問題，因為除數(shù)不能為0；
如果事務(wù)生效，save()方法會回滾掉，即a處、c處不做save操作，保持事務(wù)的原子性；
如果事務(wù)不起作用，那么a處會執(zhí)行成功，往數(shù)據(jù)庫添加一條記錄；b處拋出異常終止向下執(zhí)行；c處這條代碼不執(zhí)行，導(dǎo)致臟數(shù)據(jù)的出現(xiàn)。

Atomikos的集成到此就結(jié)束了，親！是不是很簡單。

注意
MySQL的驅(qū)動需要5.1.10版本以上，低版本會出現(xiàn)如下錯誤：
java.lang.IllegalArgumentException: null source

總結(jié)

以上是生活随笔為你收集整理的Spring+Hibernate+Atomikos集成构建JTA的分布式事务--解决多数据源跨库事务的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。