Spring框架支持事务管理的核心是事务管理器抽象,对于不同的数据访问框架(如Hibernate)通过实现策略接口PlatformTransactionManager,从而能支持各种数据访问框架的事务管理,PlatformTransactionManager接口定义如下:
public interface PlatformTransactionManager { TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; void commit(TransactionStatus status) throws TransactionException; void rollback(TransactionStatus status) throws TransactionException; }
TransactionDefinition 接口定义如下:
public interface TransactionDefinition { int getPropagationBehavior(); int getIsolationLevel(); int getTimeout(); boolean isReadOnly(); String getName(); }
TransactionStatus 接口定义如下:
public interface TransactionStatus extends SavepointManager { boolean isNewTransaction(); boolean hasSavepoint(); void setRollbackOnly(); boolean isRollbackOnly(); void flush(); boolean isCompleted(); }
Spring提供了许多内置事务管理器实现:
Spring不仅提供这些事务管理器,还提供对如JMS事务管理的管理器等,Spring提供一致的事务抽象如图9-1所示。
图9-1 Spring事务管理器
接下来让我们学习一下如何在Spring配置文件中定义事务管理器:
一、 声明对本地事务的支持:
a) JDBC 及iBATIS 、MyBatis 框架事务管理器
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean>
通过dataSource属性指定需要事务管理的单个javax.sql.DataSource对象。
b) Jdo 事务管理器
<bean id="txManager" class="org.springframework.orm.jdo.JdoTransactionManager"> <property name="persistenceManagerFactory" ref="persistenceManagerFactory"/> </bean>
通过persistenceManagerFactory属性指定需要事务管理的javax.jdo.PersistenceManagerFactory对象。
c) Jpa 事务管理器
<bean id="txManager" class="org.springframework.orm.jpa.JpaTransactionManager"> <property name="entityManagerFactory" ref="entityManagerFactory"/> </bean>
通过entityManagerFactory属性指定需要事务管理的javax.persistence.EntityManagerFactory对象。
还需要为entityManagerFactory对象指定jpaDialect属性,该属性所对应的对象指定了如何获取连接对象、开启事务、关闭事务等事务管理相关的行为。
<bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> …… <property name="jpaDialect" ref="jpaDialect"/> </bean> <bean id="jpaDialect" class="org.springframework.orm.jpa.vendor.HibernateJpaDialect"/>
d) Hibernate 事务管理器
<bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"> <property name="sessionFactory" ref="sessionFactory"/> </bean>
通过entityManagerFactory属性指定需要事务管理的org.hibernate.SessionFactory对象。
二、 Spring 对全局事务的支持:
a) Jta 事务管理器
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jee="http://www.springframework.org/schema/jee" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd"> <jee:jndi-lookup id="dataSource" jndi-name="jdbc/test"/> <bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager"> <property name="transactionManagerName" value=" java:comp/TransactionManager"/> </bean> </beans>
“dataSource”Bean表示从JNDI中获取的数据源,而txManager是JTA事务管理器,其中属性transactionManagerName指定了JTA事务管理器的JNDI名字,从而将事务管理委托给该事务管理器。
这只是最简单的配置方式,更复杂的形式请参考Spring Javadoc。
在此我们再介绍两个不依赖于应用服务器的开源JTA事务实现:JOTM和Atomikos Transactions Essentials。
对于以上JTA事务管理器使用,本文作者只是做演示使用,如果在实际项目中需要不依赖于应用服务器的JTA事务支持,需详细测试并选择合适的。
在本文中将使用Atomikos Transactions Essentials来进行演示JTA事务使用,由于Atomikos对hsqldb分布式支持不是很好,在Atomikos官网中列出如下兼容的数据库:Oracle、Informix、FirstSQL、DB2、MySQL、SQLServer、Sybase,这不代表其他数据库不支持,而是Atomikos团队没完全测试,在此作者决定使用derby内存数据库来演示JTA分布式事务。
1 、首先准备 jar 包:
1.1 、准备 derby 数据 jar 包, 到下载的spring-framework-3.0.5.RELEASE-dependencies.zip中拷贝如下jar包:
com.springsource.org.apache.derby-10.5.1000001.764942.jar
1.2 、准备 Atomikos Transactions Essentials 对 JTA 事务支持的 JTA 包, 此处使用AtomikosTransactionsEssentials3.5.5版本,到官网下载AtomikosTransactionsEssentials-3.5.5.zip,拷贝如下jar包到类路径:
atomikos-util.jar
transactions-api.jar
transactions-essentials-all.jar
transactions-jdbc.jar
transactions-jta.jar
transactions.jar
将如上jar包放在lib/atomikos目录下,并添加到类路径中。
2 、接下来看一下在 Spring 中如何配置 AtomikosTransactionsEssentials JTA 事务:
2.1 、配置分布式数据源:
<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"> <property name="uniqueResourceName" value="jdbc/test1"/> <property name="xaDataSourceClassName" value="org.apache.derby.jdbc.EmbeddedXADataSource"/> <property name="poolSize" value="5"/> <property name="xaProperties"> <props> <prop key="databaseName">test1</prop> <prop key="createDatabase">create</prop> </props> </property> </bean> <bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"> …… </bean>
在此我们配置两个分布式数据源:使用com.atomikos.jdbc.AtomikosDataSourceBean来配置AtomikosTransactionsEssentials分布式数据源:
在此我们还有定义了一个“dataSource2”Bean,其属性和“DataSource1”除以下不一样其他完全一样:
<bean id="atomikosTransactionManager" class = "com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method = "close"> <property name="forceShutdown" value="true"/> </bean> <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp"> </bean> <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"> <property name="transactionManager"> <ref bean="atomikosTransactionManager"/> </property> <property name="userTransaction"> <ref bean="atomikosUserTransaction"/> </property> </bean>
配置完毕,是不是也挺简单的,但是如果确实需要使用JTA事务,请首先选择应用服务器事务管理器,本示例不适合生产环境,如果非要运用到生产环境,可以考虑购买AtomikosTransactionsEssentials商业支持。
Spring还提供了对特定应用服务器事务管理器集成的支持,目前提供对IBM WebSphere、BEA WebLogic、 Oracle OC4J应用服务器高级事务的支持,具体使用请参考Spring Javadoc。
现在我们已经学习如何配置事务管理器了,但是只有事务管理器Spring能自动进行事务管理吗?当然不能了,这需要我们来控制,目前Spring支持两种事务管理方式:编程式和声明式事务管理。接下来先看一下如何进行编程式事务管理吧。