`
zznj1123
  • 浏览: 123658 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

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接口注入何种实现类:

Xml代码 复制代码
  1. (1)利用JDBC作为持久层的局部事务:   
  2. <?xml version="1.0" encoding="utf-8"?>  
  3. <beans xmlns="http://www.springframework.org/schema/beans"  
  4.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  5.        xsi:schemaLocation="http://www.springframework.org/schema/beans    
  6.        http://www.springframework.org/schema/beans/spring-beans.xsd">  
  7.   
  8. <!-- 定义数据源Bean,使用C3P0数据源 -->  
  9. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy- method="close">  
  10.     <!-- 指定连接数据库的驱动 -->  
  11.     <property name="driverClass" value="com.mysql.jdbc.Driver"/>  
  12.     <!-- 指定连接数据库的URL -->  
  13.     <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>  
  14.     <!-- 指定连接数据库的用户名 -->  
  15.     <property name="user" value="root"/>  
  16.     <!-- 指定连接数据库的密码 -->  
  17.     <property name="password" value="123"/>  
  18.     <!-- 指定连接数据库连接池的最大连接数 -->  
  19.     <property name="maxPoolSize" value="40"/>  
  20.     <!-- 指定连接数据库连接池的最小连接数 -->  
  21.     <property name="minPoolSize" value="1"/>  
  22.     <!-- 指定连接数据库连接池的初始化连接数 -->  
  23.     <property name="initialPoolSize" value="1"/>  
  24.     <!-- 指定连接数据库连接池的连接最大空闲时间 -->  
  25.     <property name="maxIdleTime" value="20"/>  
  26. </bean>  
  27.   
  28. <!—定义JDBC数据源的局部事务管理器 -->  
  29. <!-- 使用DataSourceTransactionManager类,该类实现PlatformTransactionManager接口 ,是针对采用数据源连接的特定实现 -->  
  30. <bean id="transactionManager"    
  31.         class="org.springframework.jdbc.datasource.   
  32.         DataSourceTransactionManager">  
  33.         <!—DataSourceTransactionManager需要注入一个DataSource的引用-->  
  34.          <property name="dataSource" ref="dataSource"/>  
  35.     </bean>  
  36. </beans>  
  37.   
  38. (2)利用Hibernate作为持久层的局部事务:   
  39. <?xml version="1.0" encoding="utf-8"?>  
  40. <beans xmlns="http://www.springframework.org/schema/beans"  
  41.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  42.        xsi:schemaLocation="http://www.springframework.org/schema/beans    
  43.        http://www.springframework.org/schema/beans/spring-beans.xsd">  
  44.     <!-- 定义数据源Bean,使用C3P0数据源 -->  
  45.     <bean id="dataSource" class="com.mchange.v2.c3p0.    
  46.     ComboPooledDataSource" destroy-method="close">  
  47.         <!-- 指定连接数据库的驱动 -->  
  48.         <property name="driverClass" value="com.mysql.jdbc.Driver"/>  
  49.         <!-- 指定连接数据库的URL -->  
  50.         <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>  
  51.         <!-- 指定连接数据库的用户名 -->  
  52.         <property name="user" value="root"/>  
  53.         <!-- 指定连接数据库的密码 -->  
  54.         <property name="password" value="123"/>  
  55.         <!-- 指定连接数据库连接池的最大连接数 -->  
  56.         <property name="maxPoolSize" value="40"/>  
  57.         <!-- 指定连接数据库连接池的最小连接数 -->  
  58.         <property name="minPoolSize" value="1"/>  
  59.         <!-- 指定连接数据库连接池的初始化连接数 -->  
  60.         <property name="initialPoolSize" value="1"/>  
  61.         <!-- 指定连接数据库连接池的连接最大空闲时间 -->  
  62.         <property name="maxIdleTime" value="20"/>  
  63.     </bean>  
  64.   
  65.     <!-- 定义Hibernate的SessionFactory -->  
  66.     <bean id="sessionFactory" class="org.springframework.orm.hibernate3.    
  67.     LocalSessionFactoryBean">  
  68.         <!-- 注入SessionFactory所需的数据源 -->  
  69.         <property name="dataSource" ref="dataSource"/>  
  70.         <!--列出全部映射文件 -->  
  71.         <property name="mappingResources">  
  72.               <list>  
  73.                   <!--列出所有的PO映射文件 -->  
  74.                 <value>org/hnylj/vo/User.hbm.xml</value>  
  75.               </list>  
  76.         </property>  
  77.           <!-- 定义Hibernate的SessionFactory属性 -->  
  78.         <property name="hibernateProperties">  
  79.             <props>  
  80.                 <!-- 指定Hibernate的连接方言 -->  
  81.                 <prop key="hibernate.dialect">org.hibernate.dialect.    
  82.                 MySQLDialect</prop>  
  83.         </property>  
  84.     </bean>  
  85.   
  86.     <!-- 配置Hibernate的局部事务管理器 -->  
  87.     <!-- 使用HibernateTransactionManager类,该类实现PlatformTransactionManager   
  88.     接口,是针对采用Hibernate持久化连接的特定实现 -->  
  89.     <bean id="transactionManager"    
  90.       class="org.springframework.orm.hibernate3.    
  91.       HibernateTransactionManager">  
  92.             <!--注入一个SessionFactorybean的引用 -->  
  93.          <property name="sessionFactory" ref="sessionFactory"/>  
  94.      </bean>  
  95. </beans>  
  96.   
  97. (3)利用Hibernate作为持久层的全局事务:   
  98. <?xml version="1.0" encoding="utf-8"?>  
  99. <beans xmlns="http://www.springframework.org/schema/beans"  
  100.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  101.        xsi:schemaLocation="http://www.springframework.org/schema/beans    
  102.        http://www.springframework.org/schema/beans/spring-beans.xsd">  
  103.     <!—定义JNDI数据源Bean -->  
  104.     <bean id="dataSource" class="org.springframework.jndi.    
  105.     JndiObjectFactoryBean">  
  106.         <!--  容器管理数据源的JNDI -->  
  107.          <property name="jndiName" value="jdbc/jtest"/>  
  108.     </bean>  
  109.     <!--定义Hibernate的SessionFactory -->  
  110.     <bean id="sessionFactory" class="org.springframework.orm.hibernate3.    
  111.     LocalSessionFactoryBean">  
  112.         <!-- 注入SessionFactory所需的数据源-->  
  113.         <property name="dataSource" ref="dataSource"/>  
  114.         <!--列出全部映射文件 -->  
  115.         <property name="mappingResources">  
  116.               <list>  
  117.                   <!-- 列出所有的PO映射文件 -->  
  118.                 <value>org/hnylj/vo/User.hbm.xml</value>  
  119.               </list>  
  120.         </property>  
  121.           <!-- 定义Hibernate的SessionFactory的属性 -->  
  122.         <property name="hibernateProperties">  
  123.              <props>  
  124.                 <!-- 指定Hibernate的连接方言 -->  
  125.                 <prop key="hibernate.dialect">org.hibernate.dialect.    
  126.                 MySQLDialect</prop>  
  127.          </property>  
  128.     </bean>  
  129.     <!-- 使用JtaTransactionManager类,该类实现PlatformTransactionManager接口-->  
  130.     <!-- JtaTransactionManager不需要知道数据源,或任何其他特定资源,   
  131.             因为使用容器的全局事务管理 -->  
  132.     <bean id="transactionManager"    
  133.            class="org.springframework.transaction.jta.   
  134.            JtaTransactionManager" />  
  135. </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代码 复制代码
  1. <?xml version="1.0" encoding="utf-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans"  
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans    
  5.        http://www.springframework.org/schema/beans/spring-beans.xsd">  
  6.     <!-- 定义数据源Bean,使用C3P0数据源 -->  
  7.     <bean id="dataSource" class="com.mchange.v2.c3p0.    
  8.     ComboPooledDataSource" destroy-method="close">  
  9.         <!-- 指定连接数据库的驱动 -->  
  10.         <property name="driverClass" value="com.mysql.jdbc.Driver"/>  
  11.         <!-- 指定连接数据库的URL -->  
  12.         <property name="jdbcUrl" value="jdbc:mysql:3306//127.0.0.1/ssh"/>  
  13.         <!-- 指定连接数据库的用户名 -->  
  14.         <property name="user" value="root"/>  
  15.         <!-- 指定连接数据库的密码 -->  
  16.         <property name="password" value="123"/>  
  17.         <!-- 指定连接数据库连接池的最大连接数 -->  
  18.         <property name="maxPoolSize" value="40"/>  
  19.         
分享到:
评论

相关推荐

    Spring LoadTimeWeaver 的那些事儿

    例如,如果一个数据库连接池库不支持Spring的声明式事务管理,那么LTW可以用来在运行时动态地插入事务管理代码。 尽管LTW提供了灵活性,但也有其局限性。由于它依赖于JVM的instrumentation API,所以可能会影响应用...

    spring3.0+hibernate3.5整合那些事儿

    本文将深入探讨"Spring 3.0 + Hibernate 3.5整合那些事儿",结合给出的标签"源码"和"工具",我们将讨论如何将这两个强大的框架结合在一起,以及在整合过程中可能遇到的问题和解决方案。 首先,Spring是一个全面的...

    我和JAVA数据库操作的那些事儿(2)

    在“我和JAVA数据库操作的那些事儿(2)”这篇博文中,作者分享了实际操作的经验和技巧,涵盖了数据库连接、SQL语句执行、结果集处理以及对象模型的构建。 首先,JDBC是Java平台的标准接口,它允许Java应用程序与...

    Java程序员上班那点事儿

    8. **Spring框架**:Spring是Java企业级应用的主流框架,它提供了依赖注入、AOP(面向切面编程)、事务管理等功能。理解Spring Boot和Spring Cloud,可以快速构建微服务架构。 9. **Maven与Gradle**:作为项目构建...

    mavenssm maven spring3 struts2 mybaits

    pom xml冲突是件挺恶心的事儿 还有就是 遇到了导入myeclipse里 resource文件不编译到指定目录的问题 "&gt;maven建的web项目 用Myeclipse可直接导入 基于注解的零配置struts2 1 页面跳转 2 查数据库 3 事务控制到...

    arthas,懂得都懂,直接解压用就完事儿了

    Arthas,这是一个在Java开发领域中广为人知的神器,尤其对于那些热衷于调试、诊断和优化应用的开发者来说。它是一个开源的命令行工具集,由阿里巴巴开源社区提供,旨在帮助开发者在不重启Java应用的情况下进行问题...

    java面试书籍

    数据库操作也是常见面试题目,包括SQL查询优化、事务管理、连接池配置等。 Spring框架的使用越来越广泛,面试中可能涉及到依赖注入、AOP(面向切面编程)、Spring Boot、Spring Cloud等相关知识。面试指南可能会...

    jbpm4.4+s2sh请假流程例子

    Spring框架则是一个全面的企业级应用框架,包括依赖注入、事务管理、AOP(面向切面编程)等功能,用于构建松耦合的系统。Hibernate是一个对象关系映射(ORM)工具,它简化了数据库操作,将Java对象与数据库表之间的...

    java面试题集合java面试题集合java面试题集合

    Java作为一门广泛使用...通过阅读《Java面试题笔试题大全》、《Java程序员上班那点事儿》、《Java程序员面试宝典》、《Java企业面试题》以及《华为_中软等大公司JAVA面试试题》等资料,可以系统地复习和巩固这些知识。

Global site tag (gtag.js) - Google Analytics