Spring事务管理的那些事儿

写在前面的话：
本人开发过一个系统，系统对数据的正确性要求比较高，有个小模块中一次性会向数据库插入1万条左右的数据，在插入这一万条左右的数据的同时还要更新数据库中与此1万条数据相同的数据的某个状态值，更新出错或插入出错，都要回滚并终止执行。这就是一个典型的事务处理问题。

 

很早就接触到了Spring，通过时间的推移和实际项目的运用，对Spring的认识也渐渐增多，有了一些体会和感悟。

下面是本人撰写的一篇关于spring事务管理的文章，希望和广大网友交流与学习！

 

我们都知道spring提供两种管理事务的方式，一种是声明式事务，一种是编程式事务。
Spring的声明式事务管理，基于Spring的AOP，不再需要不停地写commit，rollback，（但Spring仍然没有放弃编程式的事务管理策略）。
Spring的编程式事务管理，为我们提供了一个TransactionTemplate，使用回调机制，将应用代码从样板式的资源获取和释放代码中解放出来，不再有大量的try/catch/finally/try/catch代码块。

 

这两种事务处理方式都非常地优雅，它不需要与任何特定的事务API耦合，并支持多种持久层方案。
（1）声明式事务：基于Spring AOP实现，几乎就是xml文件的配置
（2）编程式事务：统一的事务编码风格，几乎是一个模板化的。

 

以下将对这两种事务管理方式进行探讨：

首先探讨一下声明式事务：
我们知道Spring事务管理的核心接口是：
org.springframework.transaction.PlatformTransactionManager
它定义了三个待实现的方法：
（1）public TransactionStatus getTransaction(TransactionDefinition definition);
 //返回当前活动的事务或根据相应的行为创建一个新的事务（可以查阅API理解）
（2）public void commit(TransactionStatus status);//提交事务
（3）public void rollback(TransactionStatus status); //回滚事务

PlatformTransactionManager是一个与特定平台无关的事务操作接口，不同的底层事务平台应通过Spring的Ioc注入相应的事务操作实现类 (这些实现类也不需要我们去完成，Spring已经为我们提供了)。那么我们来看看针对不同的底层持久化平台，我们需要为PlatformTransactionManager接口注入何种实现类：

（1）利用JDBC作为持久层的局部事务：
<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd">

<!-- 定义数据源Bean，使用C3P0数据源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy- method="close">
    <!-- 指定连接数据库的驱动 -->
    <property name="driverClass" value="com.mysql.jdbc.Driver"/>
    <!-- 指定连接数据库的URL -->
    <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>
    <!-- 指定连接数据库的用户名 -->
    <property name="user" value="root"/>
    <!-- 指定连接数据库的密码 -->
    <property name="password" value="123"/>
    <!-- 指定连接数据库连接池的最大连接数 -->
    <property name="maxPoolSize" value="40"/>
    <!-- 指定连接数据库连接池的最小连接数 -->
    <property name="minPoolSize" value="1"/>
    <!-- 指定连接数据库连接池的初始化连接数 -->
    <property name="initialPoolSize" value="1"/>
    <!-- 指定连接数据库连接池的连接最大空闲时间 -->
    <property name="maxIdleTime" value="20"/>
</bean>

<!—定义JDBC数据源的局部事务管理器 -->
<!-- 使用DataSourceTransactionManager类，该类实现PlatformTransactionManager接口 ，是针对采用数据源连接的特定实现 -->
<bean id="transactionManager"
        class="org.springframework.jdbc.datasource.
        DataSourceTransactionManager">
        <!—DataSourceTransactionManager需要注入一个DataSource的引用-->
         <property name="dataSource" ref="dataSource"/>
    </bean>
</beans>

（2）利用Hibernate作为持久层的局部事务：
<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!-- 定义数据源Bean，使用C3P0数据源 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.
    ComboPooledDataSource" destroy-method="close">
        <!-- 指定连接数据库的驱动 -->
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <!-- 指定连接数据库的URL -->
        <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>
        <!-- 指定连接数据库的用户名 -->
        <property name="user" value="root"/>
        <!-- 指定连接数据库的密码 -->
        <property name="password" value="123"/>
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="40"/>
        <!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的连接最大空闲时间 -->
        <property name="maxIdleTime" value="20"/>
    </bean>

    <!-- 定义Hibernate的SessionFactory -->
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3.
    LocalSessionFactoryBean">
        <!-- 注入SessionFactory所需的数据源 -->
        <property name="dataSource" ref="dataSource"/>
        <!--列出全部映射文件 -->
        <property name="mappingResources">
              <list>
                  <!--列出所有的PO映射文件 -->
                <value>org/hnylj/vo/User.hbm.xml</value>
              </list>
        </property>
          <!-- 定义Hibernate的SessionFactory属性 -->
        <property name="hibernateProperties">
            <props>
                <!-- 指定Hibernate的连接方言 -->
                <prop key="hibernate.dialect">org.hibernate.dialect.
                MySQLDialect</prop>
        </property>
    </bean>

    <!-- 配置Hibernate的局部事务管理器 -->
    <!-- 使用HibernateTransactionManager类，该类实现PlatformTransactionManager
    接口，是针对采用Hibernate持久化连接的特定实现 -->
    <bean id="transactionManager"
      class="org.springframework.orm.hibernate3.
      HibernateTransactionManager">
            <!--注入一个SessionFactorybean的引用 -->
         <property name="sessionFactory" ref="sessionFactory"/>
     </bean>
</beans>

（3）利用Hibernate作为持久层的全局事务：
<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!—定义JNDI数据源Bean -->
    <bean id="dataSource" class="org.springframework.jndi.
    JndiObjectFactoryBean">
        <!--  容器管理数据源的JNDI -->
         <property name="jndiName" value="jdbc/jtest"/>
    </bean>
    <!--定义Hibernate的SessionFactory -->
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3.
    LocalSessionFactoryBean">
        <!-- 注入SessionFactory所需的数据源-->
        <property name="dataSource" ref="dataSource"/>
        <!--列出全部映射文件 -->
        <property name="mappingResources">
              <list>
                  <!-- 列出所有的PO映射文件 -->
                <value>org/hnylj/vo/User.hbm.xml</value>
              </list>
        </property>
          <!-- 定义Hibernate的SessionFactory的属性 -->
        <property name="hibernateProperties">
             <props>
                <!-- 指定Hibernate的连接方言 -->
                <prop key="hibernate.dialect">org.hibernate.dialect.
                MySQLDialect</prop>
         </property>
    </bean>
    <!-- 使用JtaTransactionManager类，该类实现PlatformTransactionManager接口-->
    <!-- JtaTransactionManager不需要知道数据源，或任何其他特定资源，
            因为使用容器的全局事务管理 -->
    <bean id="transactionManager"
           class="org.springframework.transaction.jta.
           JtaTransactionManager" />
</beans>

（1）利用JDBC作为持久层的局部事务：
<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans.xsd">

<!-- 定义数据源Bean，使用C3P0数据源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy- method="close">
    <!-- 指定连接数据库的驱动 -->
    <property name="driverClass" value="com.mysql.jdbc.Driver"/>
    <!-- 指定连接数据库的URL -->
    <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>
    <!-- 指定连接数据库的用户名 -->
    <property name="user" value="root"/>
    <!-- 指定连接数据库的密码 -->
    <property name="password" value="123"/>
    <!-- 指定连接数据库连接池的最大连接数 -->
    <property name="maxPoolSize" value="40"/>
    <!-- 指定连接数据库连接池的最小连接数 -->
    <property name="minPoolSize" value="1"/>
    <!-- 指定连接数据库连接池的初始化连接数 -->
    <property name="initialPoolSize" value="1"/>
    <!-- 指定连接数据库连接池的连接最大空闲时间 -->
    <property name="maxIdleTime" value="20"/>
</bean>

<!—定义JDBC数据源的局部事务管理器 -->
<!-- 使用DataSourceTransactionManager类，该类实现PlatformTransactionManager接口 ，是针对采用数据源连接的特定实现 -->
<bean id="transactionManager" 
        class="org.springframework.jdbc.datasource.
        DataSourceTransactionManager">
        <!—DataSourceTransactionManager需要注入一个DataSource的引用-->
         <property name="dataSource" ref="dataSource"/>
    </bean>
</beans>

（2）利用Hibernate作为持久层的局部事务：
<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!-- 定义数据源Bean，使用C3P0数据源 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0. 
    ComboPooledDataSource" destroy-method="close">
        <!-- 指定连接数据库的驱动 -->
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <!-- 指定连接数据库的URL -->
        <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>
        <!-- 指定连接数据库的用户名 -->
        <property name="user" value="root"/>
        <!-- 指定连接数据库的密码 -->
        <property name="password" value="123"/>
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="40"/>
        <!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的连接最大空闲时间 -->
        <property name="maxIdleTime" value="20"/>
    </bean>

    <!-- 定义Hibernate的SessionFactory -->
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3. 
    LocalSessionFactoryBean">
        <!-- 注入SessionFactory所需的数据源 -->
        <property name="dataSource" ref="dataSource"/>
        <!--列出全部映射文件 -->
        <property name="mappingResources">
              <list>
                  <!--列出所有的PO映射文件 -->
                <value>org/hnylj/vo/User.hbm.xml</value>
              </list>
        </property>
          <!-- 定义Hibernate的SessionFactory属性 -->
        <property name="hibernateProperties">
            <props>
                <!-- 指定Hibernate的连接方言 -->
                <prop key="hibernate.dialect">org.hibernate.dialect. 
                MySQLDialect</prop>
        </property>
    </bean>

    <!-- 配置Hibernate的局部事务管理器 -->
    <!-- 使用HibernateTransactionManager类，该类实现PlatformTransactionManager
    接口，是针对采用Hibernate持久化连接的特定实现 -->
    <bean id="transactionManager" 
      class="org.springframework.orm.hibernate3. 
      HibernateTransactionManager">
            <!--注入一个SessionFactorybean的引用 -->
         <property name="sessionFactory" ref="sessionFactory"/>
     </bean>
</beans>

（3）利用Hibernate作为持久层的全局事务：
<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!—定义JNDI数据源Bean -->
    <bean id="dataSource" class="org.springframework.jndi. 
    JndiObjectFactoryBean">
        <!--  容器管理数据源的JNDI -->
         <property name="jndiName" value="jdbc/jtest"/>
    </bean>
    <!--定义Hibernate的SessionFactory -->
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3. 
    LocalSessionFactoryBean">
        <!-- 注入SessionFactory所需的数据源-->
        <property name="dataSource" ref="dataSource"/>
        <!--列出全部映射文件 -->
        <property name="mappingResources">
              <list>
                  <!-- 列出所有的PO映射文件 -->
                <value>org/hnylj/vo/User.hbm.xml</value>
              </list>
        </property>
          <!-- 定义Hibernate的SessionFactory的属性 -->
        <property name="hibernateProperties">
             <props>
                <!-- 指定Hibernate的连接方言 -->
                <prop key="hibernate.dialect">org.hibernate.dialect. 
                MySQLDialect</prop>
         </property>
    </bean>
    <!-- 使用JtaTransactionManager类，该类实现PlatformTransactionManager接口-->
    <!-- JtaTransactionManager不需要知道数据源，或任何其他特定资源，
            因为使用容器的全局事务管理 -->
    <bean id="transactionManager" 
           class="org.springframework.transaction.jta.
           JtaTransactionManager" />
</beans>

在上面的配置中，对于采用jdbc，hibernate等，我们只要提供相应的PlatformTransactionManager实现类即可。可见Spring对事务的操作仅仅修改一下配置文件，不需要修改任何实际的代码，就可以在不同的事务管理策略之间切换，非常地方便，Spring为我们提供了高度的解耦。

 

以上就是我们在spring中处理事务所需要的事务管理器的配置，那么在具体的业务处理bean中我们如何控制事务呢？
一般都推荐事务最好做在service层，底层的dao可以不考虑事务，有时设计得不好可能会出现事务的嵌套，增加程序复杂度。而且将事务的处理放在service层中进行，对于我们异常体系的设计也带来好处，service层抛出的异常可以在web捕获，并将异常信息在web页面给用户提示。所以接下来我们就将在service层开始事务，提交事务，回滚事务等。作为声明式事务管理，spring已经帮我们做好了这一切，基本上就是代理模式。

 

以下就是Spring提供的4种事务代理方式：
1.使用TransactionProxyFactoryBean为目标bean生成事务代理，此方式是最传统，也是配置文件最臃肿的一种方式。
2.使用bean继承的事务代理方式，此方式比较简洁，但依然是增量式配置，bean越多配置文件越臃肿。
3.使用BeanNameAutoProxyCreator，根据bean name自动生成事务代理的方式，这是直接利用Spring的AOP框架配置事务代理的方式，需要对Spring的AOP框架有所了解，但也不必成为AOP专家，这种方式避免了增量式配置，也是推荐的方式。
4.使用DefaultAdvisorAutoProxyCreator，这也是直接利用Spring的AOP框架配置事务代理的方式，只是这种配置方式的可读性不如第三种方式。

 

对于第一种：使用TransactionProxyFactoryBean为目标bean生成事务代理：
因为TransactionProxyFactoryBean产生的是代理Bean，所以我们在配置TransactionProxyFactoryBean时，需要指定目标Bean。每个TransactionProxyFactoryBean为一个目标Bean生成事务代理，事务代理的方法改写了目标Bean的方法，就是在目标Bean的方法执行之前加入开始事务，在目标Bean的方法正常结束之前提交事务，如果遇到特定异常则回滚事务。TransactionProxyFactoryBean创建事务代理时，需要了解当前事务所处的环境，该环境属性通过PlatformTransactionManager实例传入，而相关事务传入规则在TransactionProxyFactoryBean的定义中给出。

下面该方法的配置方式：

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!-- 定义数据源Bean，使用C3P0数据源 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.
    ComboPooledDataSource" destroy-method="close">
        <!-- 指定连接数据库的驱动 -->
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <!-- 指定连接数据库的URL -->
        <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>
        <!-- 指定连接数据库的用户名 -->
        <property name="user" value="root"/>
        <!-- 指定连接数据库的密码 -->
        <property name="password" value="123"/>
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="40"/>