Spring事务管理高级应用难点剖析

Spring最成功，最吸引人的地方莫过于轻量级的声明式事务管理，仅此一点，它就宣告了重量级EJB容器的覆灭。Spring声明式事务管理将开发者从繁复的事务管理代码中解脱出来，专注于业务逻辑的开发上，这是一件可以被拿来顶礼膜拜的事情。

成都创新互联网站建设提供从项目策划、软件开发，软件安全维护、网站优化(SEO)、网站分析、效果评估等整套的建站服务，主营业务为成都做网站、网站建设，成都APP应用开发以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。成都创新互联深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！

但是，世界并未从此消停，开发人员需要面对的是层出不穷的应用场景，这些场景往往逾越了普通Spring技术书籍的理想界定。因此，随着应用开发的深入，在使用经过Spring层层封装的声明式事务时，开发人员越来越觉得自己坠入了迷雾，陷入了沼泽，体会不到外界所宣称的那种畅快淋漓。本系列文章的目标旨在整理并剖析实际应用中种种让我们迷茫的场景，让阳光照进云遮雾障的山头。

很少有使用Spring但不使用Spring事务管理器的应用，因此常常有人会问：是否用了Spring，就一定要用Spring事务管理器，否则就无法进行数据的持久化操作呢？事务管理器和DAO是什么关系呢？

也许是DAO和事务管理如影随行的缘故吧，这个看似简单的问题实实在在地存在着，从初学者心中涌出，萦绕在开发老手的脑际。答案当然是否定的！我们都知道：Spring事务管理是保证数据操作的事务性（即原子性、一致性、隔离性、持久性，也即所谓的ACID），脱离了事务性，DAO照样可以顺利地进行数据的操作。下面，我们来看一段使用SpringJDBC进行数据访问的代码：

清单1.UserJdbcWithoutTransManagerService.java

 
 
 
 
  
  
  
  packageuser.withouttm; 
  
  
  
  
  
  
  
  importorg.springframework.beans.factory.annotation.Autowired; 
  
  
  
  importorg.springframework.jdbc.core.JdbcTemplate; 
  
  
  
  importorg.springframework.stereotype.Service; 
  
  
  
  importorg.springframework.context.ApplicationContext; 
  
  
  
  importorg.springframework.context.support.ClassPathXmlApplicationContext; 
  
  
  
  importorg.apache.commons.dbcp.BasicDataSource; 
  
  
  
  
  
  
  
  @Service("service1") 
  
  
  
  publicclassUserJdbcWithoutTransManagerService{ 
  
  
  
  @Autowired 
  
  
  
  privateJdbcTemplatejdbcTemplate; 
  
  
  
  
  
  
  
  publicvoidaddScore(StringuserName,inttoAdd){ 
  
  
  
  Stringsql="UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?"; 
  
  
  
  jdbcTemplate.update(sql,toAdd,userName); 
  
  
  
  } 
  
  
  
  
  
  
  
  publicstaticvoidmain(String[]args){ 
  
  
  
  ApplicationContextctx= 
  
  
  
  newClassPathXmlApplicationContext("user/withouttm/jdbcWithoutTransManager.xml"); 
  
  
  
  UserJdbcWithoutTransManagerServiceservice= 
  
  
  
  (UserJdbcWithoutTransManagerService)ctx.getBean("service1"); 
  
  
  
  JdbcTemplatejdbcTemplate=(JdbcTemplate)ctx.getBean("jdbcTemplate"); 
  
  
  
  BasicDataSourcebasicDataSource=(BasicDataSource)jdbcTemplate.getDataSource(); 
  
  
  
  
  
  
  
  //①.检查数据源autoCommit的设置 
  
  
  
  System.out.println("autoCommit:"+basicDataSource.getDefaultAutoCommit()); 
  
  
  
  
  
  
  
  //②.插入一条记录，初始分数为10 
  
  
  
  jdbcTemplate.execute( 
  
  
  
  "INSERTINTOt_user(user_name,password,score)VALUES('tom','123456',10)"); 
  
  
  
  
  
  
  
  //③.调用工作在无事务环境下的服务类方法,将分数添加20分 
  
  
  
  service.addScore("tom",20); 
  
  
  
  
  
  
  
  //④.查看此时用户的分数 
  
  
  
  intscore=jdbcTemplate.queryForInt( 
  
  
  
  "SELECTscoreFROMt_userWHEREuser_name='tom'"); 
  
  
  
  System.out.println("score:"+score); 
  
  
  
  jdbcTemplate.execute("DELETEFROMt_userWHEREuser_name='tom'"); 
  
  
  
  } 
  
  
  
  }

jdbcWithoutTransManager.xml的配置文件如下所示：

清单2.jdbcWithoutTransManager.xml

 
 
 
 
  
  
  
   xmlversionxmlversion="1.0"encoding="UTF-8"?>
  
  
  
  
  
  
  
  
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  
  
  
  xmlns:context="http://www.springframework.org/schema/context"
  
  
  
  xmlns:p="http://www.springframework.org/schema/p"
  
  
  
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
  
  
  
  http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
  
  
  
  http://www.springframework.org/schema/context 
  
  
  
  http://www.springframework.org/schema/context/spring-context-3.0.xsd">
  
  
  
  
  
  
  
   
  
  
  
  
  
  
  
  
class="org.apache.commons.dbcp.BasicDataSource"
  
  
  
  destroy-method="close"
  
  
  
  p:driverClassName="oracle.jdbc.driver.OracleDriver"
  
  
  
  p:url="jdbc:oracle:thin:@localhost:1521:orcl"
  
  
  
  p:username="test"
  
  
  
  p:password="test"/>
  
  
  
  
  
  
  
  
class="org.springframework.jdbc.core.JdbcTemplate"
  
  
  
  p:dataSource-ref="dataSource"/>
  
  
  
   beans>

运行UserJdbcWithoutTransManagerService，在控制台上打出如下的结果：

 
 
 
 
  
  
  
  defaultAutoCommit:true 
  
  
  
  score:30

在jdbcWithoutTransManager.xml中，没有配置任何事务管理器，但是数据已经成功持久化到数据库中。在默认情况下，dataSource数据源的autoCommit被设置为true――这也意谓着所有通过JdbcTemplate执行的语句马上提交，没有事务。如果将dataSource的defaultAutoCommit设置为false，再次运行UserJdbcWithoutTransManagerService，将抛出错误，原因是新增及更改数据的操作都没有提交到数据库，所以④处的语句因无法从数据库中查询到匹配的记录而引发异常。

对于强调读速度的应用，数据库本身可能就不支持事务，如使用MyISAM引擎的MySQL数据库。这时，无须在Spring应用中配置事务管理器，因为即使配置了，也是没有实际用处的。

不过，对于Hibernate来说，情况就有点复杂了。因为Hibernate的事务管理拥有其自身的意义，它和Hibernate一级缓存有密切的关系：当我们调用Session的save、update等方法时，Hibernate并不直接向数据库发送SQL语句，而是在提交事务（commit）或flush一级缓存时才真正向数据库发送SQL。所以，即使底层数据库不支持事务，Hibernate的事务管理也是有一定好处的，不会对数据操作的效率造成负面影响。所以，如果是使用Hibernate数据访问技术，没有理由不配置HibernateTransactionManager事务管理器。但是，不使用Hibernate事务管理器，在Spring中，Hibernate照样也可以工作，来看下面的例子： #p#

清单3.UserHibernateWithoutTransManagerService.java

 
 
 
 
  
  
  
  packageuser.withouttm; 
  
  
  
  
  
  
  
  importorg.springframework.beans.factory.annotation.Autowired; 
  
  
  
  importorg.springframework.jdbc.core.JdbcTemplate; 
  
  
  
  importorg.springframework.stereotype.Service; 
  
  
  
  importorg.springframework.context.ApplicationContext; 
  
  
  
  importorg.springframework.context.support.ClassPathXmlApplicationContext; 
  
  
  
  importorg.springframework.orm.hibernate3.HibernateTemplate; 
  
  
  
  importorg.apache.commons.dbcp.BasicDataSource; 
  
  
  
  importuser.User; 
  
  
  
  
  
  
  
  @Service("service2") 
  
  
  
  publicclassUserHibernateWithoutTransManagerService{ 
  
  
  
  @Autowired 
  
  
  
  privateHibernateTemplatehibernateTemplate; 
  
  
  
  
  
  
  
  publicvoidaddScore(StringuserName,inttoAdd){ 
  
  
  
  Useruser=(User)hibernateTemplate.get(User.class,userName); 
  
  
  
  user.setScore(user.getScore()+toAdd); 
  
  
  
  hibernateTemplate.update(user); 
  
  
  
  } 
  
  
  
  
  
  
  
  publicstaticvoidmain(String[]args){ 
  
  
  
  //参考UserJdbcWithoutTransManagerService相应代码 
  
  
  
  … 
  
  
  
  } 
  
  
  
  }

此时，采用hiberWithoutTransManager.xml的配置文件，其配置内容如下：

清单4.hiberWithoutTransManager.xml

 
 
 
 
  
  
  
   xmlversionxmlversion="1.0"encoding="UTF-8"?>
  
  
  
  
  
  
  
  
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  
  
  
  xmlns:context="http://www.springframework.org/schema/context"
  
  
  
  xmlns:p="http://www.springframework.org/schema/p"
  
  
  
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
  
  
  
  http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
  
  
  
  http://www.springframework.org/schema/context 
  
  
  
  http://www.springframework.org/schema/context/spring-context-3.0.xsd">
  
  
  
   
  
  
  
  … 
  
  
  
  
  
  
  
  
class= 
  
  
  
  "org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"
  
  
  
  p:dataSource-ref="dataSource">
  
  
  
  
  
  
  
  
  
  
  
  user.User value>
  
  
  
   list>
  
  
  
   property>
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  org.hibernate.dialect.Oracle10gDialect 
  
  
  
   prop>
  
  
  
  true prop>
  
  
  
   props>
  
  
  
   property>
  
  
  
   bean>
  
  
  
  
  
  
  
  
  
  
  
  
class="org.springframework.orm.hibernate3.HibernateTemplate"
  
  
  
  p:sessionFactory-ref="sessionFactory"/>
  
  
  
   beans>

运行UserHibernateWithoutTransManagerService，程序正确执行，并得到类似于UserJdbcWithoutTransManagerService的执行结果，这说明Hibernate在Spring中，在没有事务管理器的情况下，依然可以正常地进行数据的访问。

应用分层的迷惑

Web、Service及DAO三层划分就像西方国家的立法、行政、司法三权分立一样被奉为金科玉律，甚至有开发人员认为如果要使用Spring事务管理就一定先要进行三层的划分。这个看似荒唐的论调在开发人员中颇有市场。更有甚者，认为每层必须先定义一个接口，然后再定义一个实现类。其结果是：一个很简单的功能，也至少需要3个接口，3个类，再加上视图层的JSP和JS等，打牌都可以转上两桌了，这种误解贻害不浅。

对将“面向接口编程”奉为圭臬，认为放之四海而皆准的论调，笔者深不以为然。是的，“面向接口编程”是MartinFowler，RodJohnson这些大师提倡的行事原则。如果拿这条原则去开发架构，开发产品，怎么强调都不为过。但是，对于我们一般的开发人员来说，做的最多的是普通工程项目，往往最多的只是一些对数据库增、删、查、改的功能。此时，“面向接口编程”除了带来更多的类文件外，看不到更多其它的好处。

Spring框架提供的所有附加的好处（AOP、注解增强、注解MVC等）唯一的前提就是让POJO的类变成一个受Spring容器管理的Bean，除此以外没有其它任何的要求。下面的实例用一个POJO完成所有的功能，既是Controller，又是Service，还是DAO：

清单5.MixLayerUserService.java

 
 
 
 
  
  
  
  packageuser.mixlayer; 
  
  
  
  importorg.springframework.beans.factory.annotation.Autowired; 
  
  
  
  importorg.springframework.jdbc.core.JdbcTemplate; 
  
  
  
  importorg.springframework.stereotype.Controller; 
  
  
  
  importorg.springframework.web.bind.annotation.RequestMapping; 
  
  
  
  //①.将POJO类通过注解变成SpringMVC的Controller 
  
  
  
  @Controller 
  
  
  
  publicclassMixLayerUserService{ 
  
  
  
  
  
  
  
  //②.自动注入JdbcTemplate 
  
  
  
  @Autowired 
  
  
  
  privateJdbcTemplatejdbcTemplate; 
  
  
  
  
  
  
  
  //③.通过SpringMVC注解映URL请求 
  
  
  
  @RequestMapping("/logon.do") 
  
  
  
  publicStringlogon(StringuserName,Stringpassword){ 
  
  
  
  if(isRightUser(userName,password)){ 
  
  
  
  Stringsql="UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?"; 
  
  
  
  jdbcTemplate.update(sql,20,userName); 
  
  
  
  return"success"; 
  
  
  
  }else{ 
  
  
  
  return"fail"; 
  
  
  
  } 
  
  
  
  } 
  
  
  
  privatebooleanisRightUser(StringuserName,Stringpassword){ 
  
  
  
  //dosth... 
  
  
  
  returntrue; 
  
  
  
  } 
  
  
  
  }

通过@Controller注解将MixLayerUserService变成Web层的Controller，同时也是Service层的服务类。此外，由于直接使用JdbcTemplate访问数据，所以MixLayerUserService还是一个DAO。来看一下对应的Spring配置文件：

清单6.applicationContext.xml

 
 
 
 
  
  
  
   xmlversionxmlversion="1.0"encoding="UTF-8"?>
  
  
  
  
  
  
  
  
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  
  
  
  xmlns:context="http://www.springframework.org/schema/context"
  
  
  
  xmlns:p="http://www.springframework.org/schema/p"
  
  
  
  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-3.0.xsd 
  
  
  
  http://www.springframework.org/schema/context 
  
  
  
   http://www.springframework.org/schema/context/spring-context-3.0.xsd 
  
  
  
   http://www.springframework.org/schema/aop 
  
  
  
   http://www.springframework.org/schema/aop/spring-aop-3.0.xsd 
  
  
  
   http://www.springframework.org/schema/tx 
  
  
  
  http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
  
  
  
   
  
  
  
  
  
  
  
   
  
  
  
  
  
  
  
  
 .AnnotationMethodHandlerAdapter"/>
  
  
  
  
  
  
  
   
  
  
  
  
  
  
  
  
 .InternalResourceViewResolver" 
  
  
  
  pp:prefix="/WEB-INF/jsp/"p:suffix=".jsp"/>
  
  
  
  
  
  
  
   
  
  
  
  
  
  
  
  
class="org.apache.commons.dbcp.BasicDataSource"
  
  
  
  destroy-method="close"
  
  
  
  p:driverClassName="oracle.jdbc.driver.OracleDriver"
  
  
  
  p:url="jdbc:oracle:thin:@localhost:1521:orcl"
  
  
  
  p:username="test"
  
  
  
  p:password="test"/>
  
  
  
  
  
  
  
  
  
  
  
  
class="org.springframework.jdbc.core.JdbcTemplate"
  
  
  
  p:dataSource-ref="dataSource"/>
  
  
  
  
  
  
  
   
  
  
  
  
  
  
  
  
class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
  
  
  
  p:dataSource-ref="dataSource"/>
  
  
  
  
  
  
  
   
  
  
  
  
  
  
  
  
  
  
  
  
expression="execution(public*user.mixlayer.MixLayerUserService.*(..))"/>
  
  
  
  
  
  
  
  
advice-ref="jdbcAdvice"order="0"/>
  
  
  
   aop:config>
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
   tx:attributes>
  
  
  
   tx:advice>
  
  
  
   beans>

在①处，我们定义配置了AnnotationMethodHandlerAdapter，以便启用SpringMVC的注解驱动功能。而②和③处通过Spring的aop及tx命名空间，以及Aspject的切点表达式语法进行事务增强的定义，对MixLayerUserService的所有公有方法进行事务增强。要使程序能够运行起来还必须进行web.xml的相关配置：#p#

清单7.web.xml

 
 
 
 
  
  
  
   xmlversionxmlversion="1.0"encoding="GB2312"?>
  
  
  
  
  
  
  
  
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  
  
  
  xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee 
  
  
  
  http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
  
  
  
  
  
  
  
  contextConfigLocation param-name>
  
  
  
  classpath*:user/mixlayer/applicationContext.xml param-value>
  
  
  
   context-param>
  
  
  
  
  
  
  
  log4jConfigLocation param-name>
  
  
  
  /WEB-INF/classes/log4j.properties param-value>
  
  
  
   context-param>
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  org.springframework.web.util.Log4jConfigListener 
  
  
  
   listener-class>
  
  
  
   listener>
  
  
  
  
  
  
  
  
  
  
  
  org.springframework.web.context.ContextLoaderListener 
  
  
  
   listener-class>
  
  
  
   listener>
  
  
  
  
  
  
  
  
  
  
  
  user servlet-name>
  
  
  
  
  
  
  
  org.springframework.web.servlet.DispatcherServlet 
  
  
  
   servlet-class>
  
  
  
   
  
  
  
  
  
  
  
  contextConfigLocation param-name>
  
  
  
  classpath:user/mixlayer/applicationContext.xml param-value>
  
  
  
   init-param>
  
  
  
  1 load-on-startup>
  
  
  
   servlet>
  
  
  
  
  
  
  
  user servlet-name>
  
  
  
  *.do url-pattern>
  
  
  
   servlet-mapping>
  
  
  
   web-app>

这个配置文件很简单，唯一需要注意的是DispatcherServlet的配置。默认情况下SpringMVC根据Servlet的名字查找WEB-INF下的 -servlet.xml作为SpringMVC的配置文件，在此，我们通过contextConfigLocation参数显式指定SpringMVC配置文件的确切位置。

将org.springframework.jdbc及org.springframework.transaction的日志级别设置为DEBUG，启动项目，并访问http://localhost:8088/logon.do?userName=tom应用，MixLayerUserService#logon方法将作出响应，查看后台输出日志：

清单8执行日志

 
 
 
 
  
  
  
  13:24:22,625DEBUG(AbstractPlatformTransactionManager.java:365)- 
  
  
  
  Creatingnewtransactionwithname 
  
  
  
   [user.mixlayer.MixLayerUserService.logon]:PROPAGATION_REQUIRED,ISOLATION_DEFAULT 
  
  
  
  13:24:22,906DEBUG(DataSourceTransactionManager.java:205)- 
  
  
  
  AcquiredConnection[org.apache.commons.dbcp.PoolableConnection@6e1cbf] 
  
  
  
   forJDBCtransaction 
  
  
  
  13:24:22,921DEBUG(DataSourceTransactionManager.java:222)- 
  
  
  
  SwitchingJDBCConnection 
  
  
  
   [org.apache.commons.dbcp.PoolableConnection@6e1cbf]tomanualcommit 
  
  
  
  13:24:22,921DEBUG(JdbcTemplate.java:785)- 
  
  
  
  ExecutingpreparedSQLupdate 
  
  
  
  13:24:22,921DEBUG(JdbcTemplate.java:569)- 
  
  
  
  ExecutingpreparedSQLstatement 
  
  
  
   [UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?] 
  
  
  
  13:24:23,140DEBUG(JdbcTemplate.java:794)- 
  
  
  
  SQLupdateaffected0rows 
  
  
  
  13:24:23,140DEBUG(AbstractPlatformTransactionManager.java:752)- 
  
  
  
  Initiatingtransactioncommit 
  
  
  
  13:24:23,140DEBUG(DataSourceTransactionManager.java:265)- 
  
  
  
  CommittingJDBCtransactiononConnection 
  
  
  
   [org.apache.commons.dbcp.PoolableConnection@6e1cbf] 
  
  
  
  13:24:23,140DEBUG(DataSourceTransactionManager.java:323)- 
  
  
  
  ReleasingJDBCConnection[org.apache.commons.dbcp.PoolableConnection@6e1cbf] 
  
  
  
   aftertransaction 
  
  
  
  13:24:23,156DEBUG(DataSourceUtils.java:312)- 
  
  
  
  ReturningJDBCConnectiontoDataSource

日志中粗体部分说明了MixLayerUserService#logon方法已经正确运行在事务上下文中。Spring框架本身不应该是复杂化代码的理由，使用Spring的开发者应该是无拘无束的：从实际应用出发，去除掉那些所谓原则性的接口，去除掉强制分层的束缚，简单才是硬道理。

事务方法嵌套调用的迷茫

Spring事务一个被讹传很广说法是：一个事务方法不应该调用另一个事务方法，否则将产生两个事务。结果造成开发人员在设计事务方法时束手束脚，生怕一不小心就踩到地雷。其实这种是不认识Spring事务传播机制而造成的误解，Spring对事务控制的支持统一在TransactionDefinition类中描述，该类有以下几个重要的接口方法：

◆intgetPropagationBehavior()：事务的传播行为；
◆intgetIsolationLevel()：事务的隔离级别；
◆intgetTimeout()：事务的过期时间；
◆booleanisReadOnly()：事务的读写特性。

很明显，除了事务的传播行为外，事务的其它特性Spring是借助底层资源的功能来完成的，Spring无非只充当个代理的角色。但是事务的传播行为却是Spring凭借自身的框架提供的功能，是Spring提供给开发者最珍贵的礼物，讹传的说法玷污了Spring事务框架最美丽的光环。所谓事务传播行为就是多个事务方法相互调用时，事务如何在这些方法间传播。Spring支持7种事务传播行为：

◆PROPAGATION_REQUIRED如果当前没有事务，就新建一个事务，如果已经存在一个事务中，加入到这个事务中。这是最常见的选择。

◆PROPAGATION_SUPPORTS支持当前事务，如果当前没有事务，就以非事务方式执行。

◆PROPAGATION_MANDATORY使用当前的事务，如果当前没有事务，就抛出异常。

◆PROPAGATION_REQUIRES_NEW新建事务，如果当前存在事务，把当前事务挂起。

◆PROPAGATION_NOT_SUPPORTED以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。

◆PROPAGATION_NEVER以非事务方式执行，如果当前存在事务，则抛出异常。

◆PROPAGATION_NESTED如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则执行与PROPAGATION_REQUIRED类似的操作。

Spring默认的事务传播行为是PROPAGATION_REQUIRED，它适合于绝大多数的情况。假设ServiveX#methodX()都工作在事务环境下（即都被Spring事务增强了），假设程序中存在如下的调用链：Service1#method1()->Service2#method2()->Service3#method3()，那么这3个服务类的3个方法通过Spring的事务传播机制都工作在同一个事务中。

下面，我们来看一下实例，UserService#logon()方法内部调用了UserService#updateLastLogonTime()和ScoreService#addScore()方法，这两个类都继承于BaseService。它们之间的类结构说明如下：

图1.UserService和ScoreService

具体的代码如下所示：

清单9UserService.java

 
 
 
 
  
  
  
  @Service("userService") 
  
  
  
  publicclassUserServiceextendsBaseService{ 
  
  
  
  @Autowired 
  
  
  
  privateJdbcTemplatejdbcTemplate; 
  
  
  
  @Autowired 
  
  
  
  privateScoreServicescoreService; 
  
  
  
  
  
  
  
  publicvoidlogon(StringuserName){ 
  
  
  
  updateLastLogonTime(userName); 
  
  
  
  scoreService.addScore(userName,20); 
  
  
  
  } 
  
  
  
  
  
  
  
  publicvoidupdateLastLogonTime(StringuserName){ 
  
  
  
  Stringsql="UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?"; 
  
  
  
  jdbcTemplate.update(sql,System.currentTimeMillis(),userName); 
  
  
  
  } 
  
  
  
  }

UserService中注入了ScoreService的Bean，ScoreService的代码如下所示：

清单10ScoreService.java

 
 
 
 
  
  
  
  @Service("scoreUserService") 
  
  
  
  publicclassScoreServiceextendsBaseService{ 
  
  
  
  @Autowired 
  
  
  
  privateJdbcTemplatejdbcTemplate; 
  
  
  
  publicvoidaddScore(StringuserName,inttoAdd){ 
  
  
  
  Stringsql="UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?"; 
  
  
  
  jdbcTemplate.update(sql,toAdd,userName); 
  
  
  
  } 
  
  
  
  }

通过Spring的事务配置为ScoreService及UserService中所有公有方法都添加事务增强，让这些方法都工作于事务环境下。下面是关键的配置代码：#p#

清单11事务增强配置

 
 
 
 
  
  
  
   
  
  
  
  
  
  
  
  
  
  
  
  
 
  
  
  
  expression="within(user.nestcall.BaseService+)"/>
  
  
  
  
  
  
  
  
advice-ref="jdbcAdvice"order="0"/>
  
  
  
   aop:config>
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
   tx:attributes>
  
  
  
   tx:advice>

将日志级别设置为DEBUG，启动Spring容器并执行UserService#logon()的方法，仔细观察如下的输出日志：

清单12执行日志

 
 
 
 
  
  
  
  16:25:04,765DEBUG(AbstractPlatformTransactionManager.java:365)- 
  
  
  
  Creatingnewtransactionwithname[user.nestcall.UserService.logon]: 
  
  
  
  PROPAGATION_REQUIRED,ISOLATION_DEFAULT①为UserService#logon方法启动一个事务 
  
  
  
  16:25:04,765DEBUG(DataSourceTransactionManager.java:205)- 
  
  
  
  AcquiredConnection[org.apache.commons.dbcp.PoolableConnection@32bd65] 
  
  
  
  forJDBCtransaction 
  
  
  
  logonmethod... 
  
  
  
  updateLastLogonTime...②直接执行updateLastLogonTime方法 
  
  
  
  16:25:04,781DEBUG(JdbcTemplate.java:785)-ExecutingpreparedSQLupdate 
  
  
  
  16:25:04,781DEBUG(JdbcTemplate.java:569)-ExecutingpreparedSQLstatement 
  
  
  
  [UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?] 
  
  
  
  16:25:04,828DEBUG(JdbcTemplate.java:794)-SQLupdateaffected0rows 
  
  
  
  16:25:04,828DEBUG(AbstractPlatformTransactionManager.java:470)-Participating 
  
  
  
  inexistingtransaction③ScoreService#addScore方法加入到UserService#logon的事务中 
  
  
  
  addScore... 
  
  
  
  16:25:04,828DEBUG(JdbcTemplate.java:785)-ExecutingpreparedSQLupdate 
  
  
  
  16:25:04,828DEBUG(JdbcTemplate.java:569)-ExecutingpreparedSQLstatement 
  
  
  
  [UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?] 
  
  
  
  16:25:04,828DEBUG(JdbcTemplate.java:794)-SQLupdateaffected0rows 
  
  
  
  16:25:04,828DEBUG(AbstractPlatformTransactionManager.java:752)- 
  
  
  
  Initiatingtransactioncommit 
  
  
  
  16:25:04,828DEBUG(DataSourceTransactionManager.java:265)-CommittingJDBCtransaction 
  
  
  
  onConnection[org.apache.commons.dbcp.PoolableConnection@32bd65] 
  
  
  
  16:25:04,828DEBUG(DataSourceTransactionManager.java:323)-ReleasingJDBCConnection 
  
  
  
  [org.apache.commons.dbcp.PoolableConnection@32bd65]aftertransaction 
  
  
  
  16:25:04,828DEBUG(DataSourceUtils.java:312)-ReturningJDBCConnectiontoDataSource

从上面的输入日志中，可以清楚地看到Spring为UserService#logon()方法启动了一个新的事务，而UserSerive#updateLastLogonTime()和UserService#logon()是在相同的类中，没有观察到有事务传播行为的发生，其代码块好像“直接合并”到UserService#logon()中。接着，当执行到ScoreService#addScore()方法时，我们就观察到了发生了事务传播的行为：Participatinginexistingtransaction，这说明ScoreService#addScore()添加到UserService#logon()的事务上下文中，两者共享同一个事务。所以最终的结果是UserService的logon(),updateLastLogonTime()以及ScoreService的addScore都工作于同一事务中。

多线程的困惑

由于Spring事务管理器是通过线程相关的ThreadLocal来保存数据访问基础设施，再结合IOC和AOP实现高级声明式事务的功能，所以Spring的事务天然地和线程有着千丝万缕的联系。

我们知道Web容器本身就是多线程的，Web容器为一个Http请求创建一个独立的线程，所以由此请求所牵涉到的Spring容器中的Bean也是运行于多线程的环境下。在绝大多数情况下，Spring的Bean都是单实例的（singleton），单实例Bean的最大的好处是线程无关性，不存在多线程并发访问的问题，也即是线程安全的。一个类能够以单实例的方式运行的前提是“无状态”：即一个类不能拥有状态化的成员变量。我们知道，在传统的编程中，DAO必须执有一个Connection，而Connection即是状态化的对象。所以传统的DAO不能做成单实例的，每次要用时都必须new一个新的实例。传统的Service由于将有状态的DAO作为成员变量，所以传统的Service本身也是有状态的。

但是在Spring中，DAO和Service都以单实例的方式存在。Spring是通过ThreadLocal将有状态的变量（如Connection等）本地线程化，达到另一个层面上的“线程无关”，从而实现线程安全。Spring不遗余力地将状态化的对象无状态化，就是要达到单实例化Bean的目的。由于Spring已经通过ThreadLocal的设施将Bean无状态化，所以Spring中单实例Bean对线程安全问题拥有了一种天生的免疫能力。不但单实例的Service可以成功运行于多线程环境中，Service本身还可以自由地启动独立线程以执行其它的Service。下面，通过一个实例对此进行描述：

清单13UserService.java在事务方法中启动独立线程运行另一个事务方法

 
 
 
 
  
  
  
  @Service("userService") 
  
  
  
  publicclassUserServiceextendsBaseService{ 
  
  
  
  @Autowired 
  
  
  
  privateJdbcTemplatejdbcTemplate; 
  
  
  
  
  
  
  
  @Autowired 
  
  
  
  privateScoreServicescoreService; 
  
  
  
  //①在logon方法体中启动一个独立的线程，在该独立的线程中执行ScoreService#addScore()方法 
  
  
  
  publicvoidlogon(StringuserName){ 
  
  
  
  System.out.println("logonmethod..."); 
  
  
  
  updateLastLogonTime(userName); 
  
  
  
  ThreadmyThread=newMyThread(this.scoreService,userName,20); 
  
  
  
  myThread.start(); 
  
  
  
  } 
  
  
  
  
  
  
  
  publicvoidupdateLastLogonTime(StringuserName){ 
  
  
  
  System.out.println("updateLastLogonTime..."); 
  
  
  
  Stringsql="UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?"; 
  
  
  
  jdbcTemplate.update(sql,System.currentTimeMillis(),userName); 
  
  
  
  } 
  
  
  
  //②封装ScoreService#addScore()的线程 
  
  
  
  privateclassMyThreadextendsThread{ 
  
  
  
  privateScoreServicescoreService; 
  
  
  
  privateStringuserName; 
  
  
  
  privateinttoAdd; 
  
  
  
  privateMyThread(ScoreServicescoreService,StringuserName,inttoAdd){ 
  
  
  
  this.scoreService=scoreService; 
  
  
  
  this.userName=userName; 
  
  
  
  this.toAdd=toAdd; 
  
  
  
  } 
  
  
  
  publicvoidrun(){ 
  
  
  
  scoreService.addScore(userName,toAdd); 
  
  
  
  } 
  
  
  
  } 
  
  
  
  }

将日志级别设置为DEBUG，执行UserService#logon()方法，观察以下输出的日志：

清单14执行日志

 
 
 
 
  
  
  
  [main](AbstractPlatformTransactionManager.java:365)-Creatingnewtransactionwithname 
  
  
  
  [user.multithread.UserService.logon]:PROPAGATION_REQUIRED,ISOLATION_DEFAULT① 
  
  
  
  
  
  
  
  [main](DataSourceTransactionManager.java:205)-AcquiredConnection 
  
  
  
  [org.apache.commons.dbcp.PoolableConnection@1353249]forJDBCtransaction 
  
  
  
  
  
  
  
  logonmethod... 
  
  
  
  
  
  
  
  updateLastLogonTime... 
  
  
  
  
  
  
  
  [main](JdbcTemplate.java:785)-ExecutingpreparedSQLupdate 
  
  
  
  [main](JdbcTemplate.java:569)-ExecutingpreparedSQLstatement 
  
  
  
  [UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?] 
  
  
  
  [main](JdbcTemplate.java:794)-SQLupdateaffected0rows 
  
  
  
  [main](AbstractPlatformTransactionManager.java:752)-Initiatingtransactioncommit 
  
  
  
  
  
  
  
  [Thread-2](AbstractPlatformTransactionManager.java:365)- 
  
  
  
  Creatingnewtransactionwithname[user.multithread.ScoreService.addScore]: 
  
  
  
  PROPAGATION_REQUIRED,ISOLATION_DEFAULT② 
  
  
  
  [main](DataSourceTransactionManager.java:265)-CommittingJDBCtransaction 
  
  
  
  onConnection[org.apache.commons.dbcp.PoolableConnection@1353249]③ 
  
  
  
  
  
  
  
  [main](DataSourceTransactionManager.java:323)-ReleasingJDBCConnection 
  
  
  
  [org.apache.commons.dbcp.PoolableConnection@1353249]aftertransaction 
  
  
  
  [main](DataSourceUtils.java:312)-ReturningJDBCConnectiontoDataSource 
  
  
  
  
  
  
  
  [Thread-2](DataSourceTransactionManager.java:205)-AcquiredConnection 
  
  
  
  [org.apache.commons.dbcp.PoolableConnection@10dc656]forJDBCtransaction 
  
  
  
  
  
  
  
  addScore... 
  
  
  
  
  
  
  
  [main](JdbcTemplate.java:416)-ExecutingSQLstatement 
  
  
  
  [DELETEFROMt_userWHEREuser_name='tom'] 
  
  
  
  [main](DataSourceUtils.java:112)-FetchingJDBCConnectionfromDataSource 
  
  
  
  [Thread-2](JdbcTemplate.java:785)-ExecutingpreparedSQLupdate 
  
  
  
  [Thread-2](JdbcTemplate.java:569)-ExecutingpreparedSQLstatement 
  
  
  
  [UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?] 
  
  
  
  [main](DataSourceUtils.java:312)-ReturningJDBCConnectiontoDataSource 
  
  
  
  [Thread-2](JdbcTemplate.java:794)-SQLupdateaffected0rows 
  
  
  
  [Thread-2](AbstractPlatformTransactionManager.java:752)-Initiatingtransactioncommit 
  
  
  
  [Thread-2](DataSourceTransactionManager.java:265)-CommittingJDBCtransaction 
  
  
  
  onConnection[org.apache.commons.dbcp.PoolableConnection@10dc656]④ 
  
  
  
  [Thread-2](DataSourceTransactionManager.java:323)-ReleasingJDBCConnection 
  
  
  
  [org.apache.commons.dbcp.PoolableConnection@10dc656]aftertransaction

在①处，在主线程（main）执行的UserService#logon()方法的事务启动，在③处，其对应的事务提交，而在子线程（Thread-2）执行的ScoreService#addScore()方法的事务在②处启动，在④处对应的事务提交。

所以，我们可以得出这样的结论：在相同线程中进行相互嵌套调用的事务方法工作于相同的事务中。如果这些相互嵌套调用的方法工作在不同的线程中，不同线程下的事务方法工作在独立的事务中。

小结

Spring声明式事务是Spring最核心，最常用的功能。由于Spring通过IOC和AOP的功能非常透明地实现了声明式事务的功能，一般的开发者基本上无须了解Spring声明式事务的内部细节，仅需要懂得如何配置就可以了。

但是在实际应用开发过程中，Spring的这种透明的高阶封装在带来便利的同时，也给我们带来了迷惑。就像通过流言传播的消息，最终听众已经不清楚事情的真相了，而这对于应用开发来说是很危险的。本系列文章通过剖析实际应用中给开发者造成迷惑的各种难点，通过分析Spring事务管理的内部运作机制将真相还原出来。在本文中，我们通过剖析了解到以下的真相：

◆在没有事务管理的情况下，DAO照样可以顺利进行数据操作；

◆将应用分成Web，Service及DAO层只是一种参考的开发模式，并非是事务管理工作的前提条件；

◆Spring通过事务传播机制可以很好地应对事务方法嵌套调用的情况，开发者无须为了事务管理而刻意改变服务方法的设计；

◆由于单实例的对象不存在线程安全问题，所以进行事务管理增强的Bean可以很好地工作在多线程环境下。

在下一篇文章中，笔者将继续分析Spring事务管理的以下难点：

◆混合使用多种数据访问技术（如SpringJDBC+Hibernate）的事务管理问题；

◆在通过Bean的方法通过SpringAOP增强存在哪些特殊的情况。

本文标题：Spring事务管理高级应用难点剖析
网站地址：http://www.shufengxianlan.com/qtweb/news24/504974.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容