日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間:8:30-17:00
你可能遇到了下面的問題
關閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Spring事務管理高級應用難點剖析

Spring最成功,最吸引人的地方莫過于輕量級的聲明式事務管理,僅此一點,它就宣告了重量級EJB容器的覆滅。Spring聲明式事務管理將開發(fā)者從繁復的事務管理代碼中解脫出來,專注于業(yè)務邏輯的開發(fā)上,這是一件可以被拿來頂禮膜拜的事情。

成都創(chuàng)新互聯(lián)網(wǎng)站建設提供從項目策劃、軟件開發(fā),軟件安全維護、網(wǎng)站優(yōu)化(SEO)、網(wǎng)站分析、效果評估等整套的建站服務,主營業(yè)務為成都做網(wǎng)站、網(wǎng)站建設,成都APP應用開發(fā)以傳統(tǒng)方式定制建設網(wǎng)站,并提供域名空間備案等一條龍服務,秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務。成都創(chuàng)新互聯(lián)深信只要達到每一位用戶的要求,就會得到認可,從而選擇與我們長期合作。這樣,我們也可以走得更遠!

但是,世界并未從此消停,開發(fā)人員需要面對的是層出不窮的應用場景,這些場景往往逾越了普通Spring技術書籍的理想界定。因此,隨著應用開發(fā)的深入,在使用經(jīng)過Spring層層封裝的聲明式事務時,開發(fā)人員越來越覺得自己墜入了迷霧,陷入了沼澤,體會不到外界所宣稱的那種暢快淋漓。本系列文章的目標旨在整理并剖析實際應用中種種讓我們迷茫的場景,讓陽光照進云遮霧障的山頭。

很少有使用Spring但不使用Spring事務管理器的應用,因此常常有人會問:是否用了Spring,就一定要用Spring事務管理器,否則就無法進行數(shù)據(jù)的持久化操作呢?事務管理器和DAO是什么關系呢?

也許是DAO和事務管理如影隨行的緣故吧,這個看似簡單的問題實實在在地存在著,從初學者心中涌出,縈繞在開發(fā)老手的腦際。答案當然是否定的!我們都知道:Spring事務管理是保證數(shù)據(jù)操作的事務性(即原子性、一致性、隔離性、持久性,也即所謂的ACID),脫離了事務性,DAO照樣可以順利地進行數(shù)據(jù)的操作。下面,我們來看一段使用SpringJDBC進行數(shù)據(jù)訪問的代碼:

清單1.UserJdbcWithoutTransManagerService.java

 
 
 
 
  1. packageuser.withouttm;
  2. importorg.springframework.beans.factory.annotation.Autowired;
  3. importorg.springframework.jdbc.core.JdbcTemplate;
  4. importorg.springframework.stereotype.Service;
  5. importorg.springframework.context.ApplicationContext;
  6. importorg.springframework.context.support.ClassPathXmlApplicationContext;
  7. importorg.apache.commons.dbcp.BasicDataSource;
  8. @Service("service1")
  9. publicclassUserJdbcWithoutTransManagerService{
  10. @Autowired
  11. privateJdbcTemplatejdbcTemplate;
  12. publicvoidaddScore(StringuserName,inttoAdd){
  13. Stringsql="UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?";
  14. jdbcTemplate.update(sql,toAdd,userName);
  15. }
  16. publicstaticvoidmain(String[]args){
  17. ApplicationContextctx=
  18. newClassPathXmlApplicationContext("user/withouttm/jdbcWithoutTransManager.xml");
  19. UserJdbcWithoutTransManagerServiceservice=
  20. (UserJdbcWithoutTransManagerService)ctx.getBean("service1");
  21. JdbcTemplatejdbcTemplate=(JdbcTemplate)ctx.getBean("jdbcTemplate");
  22. BasicDataSourcebasicDataSource=(BasicDataSource)jdbcTemplate.getDataSource();
  23. //①.檢查數(shù)據(jù)源autoCommit的設置
  24. System.out.println("autoCommit:"+basicDataSource.getDefaultAutoCommit());
  25. //②.插入一條記錄,初始分數(shù)為10
  26. jdbcTemplate.execute(
  27. "INSERTINTOt_user(user_name,password,score)VALUES('tom','123456',10)");
  28. //③.調(diào)用工作在無事務環(huán)境下的服務類方法,將分數(shù)添加20分
  29. service.addScore("tom",20);
  30. //④.查看此時用戶的分數(shù)
  31. intscore=jdbcTemplate.queryForInt(
  32. "SELECTscoreFROMt_userWHEREuser_name='tom'");
  33. System.out.println("score:"+score);
  34. jdbcTemplate.execute("DELETEFROMt_userWHEREuser_name='tom'");
  35. }
  36. }

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

清單2.jdbcWithoutTransManager.xml

 
 
 
 
  1. xmlversionxmlversion="1.0"encoding="UTF-8"?>
  2. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xmlns:p="http://www.springframework.org/schema/p"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans
  6. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  7. http://www.springframework.org/schema/context
  8. http://www.springframework.org/schema/context/spring-context-3.0.xsd">
  9. class="org.apache.commons.dbcp.BasicDataSource"
  10. destroy-method="close"
  11. p:driverClassName="oracle.jdbc.driver.OracleDriver"
  12. p:url="jdbc:oracle:thin:@localhost:1521:orcl"
  13. p:username="test"
  14. p:password="test"/>
  15. class="org.springframework.jdbc.core.JdbcTemplate"
  16. p:dataSource-ref="dataSource"/>
  17. beans>

運行UserJdbcWithoutTransManagerService,在控制臺上打出如下的結果:

 
 
 
 
  1. defaultAutoCommit:true
  2. score:30

在jdbcWithoutTransManager.xml中,沒有配置任何事務管理器,但是數(shù)據(jù)已經(jīng)成功持久化到數(shù)據(jù)庫中。在默認情況下,dataSource數(shù)據(jù)源的autoCommit被設置為true――這也意謂著所有通過JdbcTemplate執(zhí)行的語句馬上提交,沒有事務。如果將dataSource的defaultAutoCommit設置為false,再次運行UserJdbcWithoutTransManagerService,將拋出錯誤,原因是新增及更改數(shù)據(jù)的操作都沒有提交到數(shù)據(jù)庫,所以④處的語句因無法從數(shù)據(jù)庫中查詢到匹配的記錄而引發(fā)異常。

對于強調(diào)讀速度的應用,數(shù)據(jù)庫本身可能就不支持事務,如使用MyISAM引擎的MySQL數(shù)據(jù)庫。這時,無須在Spring應用中配置事務管理器,因為即使配置了,也是沒有實際用處的。

不過,對于Hibernate來說,情況就有點復雜了。因為Hibernate的事務管理擁有其自身的意義,它和Hibernate一級緩存有密切的關系:當我們調(diào)用Session的save、update等方法時,Hibernate并不直接向數(shù)據(jù)庫發(fā)送SQL語句,而是在提交事務(commit)或flush一級緩存時才真正向數(shù)據(jù)庫發(fā)送SQL。所以,即使底層數(shù)據(jù)庫不支持事務,Hibernate的事務管理也是有一定好處的,不會對數(shù)據(jù)操作的效率造成負面影響。所以,如果是使用Hibernate數(shù)據(jù)訪問技術,沒有理由不配置HibernateTransactionManager事務管理器。但是,不使用Hibernate事務管理器,在Spring中,Hibernate照樣也可以工作,來看下面的例子: #p#

清單3.UserHibernateWithoutTransManagerService.java

 
 
 
 
  1. packageuser.withouttm;
  2. importorg.springframework.beans.factory.annotation.Autowired;
  3. importorg.springframework.jdbc.core.JdbcTemplate;
  4. importorg.springframework.stereotype.Service;
  5. importorg.springframework.context.ApplicationContext;
  6. importorg.springframework.context.support.ClassPathXmlApplicationContext;
  7. importorg.springframework.orm.hibernate3.HibernateTemplate;
  8. importorg.apache.commons.dbcp.BasicDataSource;
  9. importuser.User;
  10. @Service("service2")
  11. publicclassUserHibernateWithoutTransManagerService{
  12. @Autowired
  13. privateHibernateTemplatehibernateTemplate;
  14. publicvoidaddScore(StringuserName,inttoAdd){
  15. Useruser=(User)hibernateTemplate.get(User.class,userName);
  16. user.setScore(user.getScore()+toAdd);
  17. hibernateTemplate.update(user);
  18. }
  19. publicstaticvoidmain(String[]args){
  20. //參考UserJdbcWithoutTransManagerService相應代碼
  21. }
  22. }

此時,采用hiberWithoutTransManager.xml的配置文件,其配置內(nèi)容如下:

清單4.hiberWithoutTransManager.xml

 
 
 
 
  1. xmlversionxmlversion="1.0"encoding="UTF-8"?>
  2. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xmlns:p="http://www.springframework.org/schema/p"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans
  6. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  7. http://www.springframework.org/schema/context
  8. http://www.springframework.org/schema/context/spring-context-3.0.xsd">
  9. class=
  10. "org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"
  11. p:dataSource-ref="dataSource">
  12. user.User value>
  13. list>
  14. property>
  15. org.hibernate.dialect.Oracle10gDialect
  16. prop>
  17. true prop>
  18. props>
  19. property>
  20. bean>
  21. class="org.springframework.orm.hibernate3.HibernateTemplate"
  22. p:sessionFactory-ref="sessionFactory"/>
  23. beans>

運行UserHibernateWithoutTransManagerService,程序正確執(zhí)行,并得到類似于UserJdbcWithoutTransManagerService的執(zhí)行結果,這說明Hibernate在Spring中,在沒有事務管理器的情況下,依然可以正常地進行數(shù)據(jù)的訪問。

應用分層的迷惑

Web、Service及DAO三層劃分就像西方國家的立法、行政、司法三權分立一樣被奉為金科玉律,甚至有開發(fā)人員認為如果要使用Spring事務管理就一定先要進行三層的劃分。這個看似荒唐的論調(diào)在開發(fā)人員中頗有市場。更有甚者,認為每層必須先定義一個接口,然后再定義一個實現(xiàn)類。其結果是:一個很簡單的功能,也至少需要3個接口,3個類,再加上視圖層的JSP和JS等,打牌都可以轉(zhuǎn)上兩桌了,這種誤解貽害不淺。

對將“面向接口編程”奉為圭臬,認為放之四海而皆準的論調(diào),筆者深不以為然。是的,“面向接口編程”是MartinFowler,RodJohnson這些大師提倡的行事原則。如果拿這條原則去開發(fā)架構,開發(fā)產(chǎn)品,怎么強調(diào)都不為過。但是,對于我們一般的開發(fā)人員來說,做的最多的是普通工程項目,往往最多的只是一些對數(shù)據(jù)庫增、刪、查、改的功能。此時,“面向接口編程”除了帶來更多的類文件外,看不到更多其它的好處。

Spring框架提供的所有附加的好處(AOP、注解增強、注解MVC等)唯一的前提就是讓POJO的類變成一個受Spring容器管理的Bean,除此以外沒有其它任何的要求。下面的實例用一個POJO完成所有的功能,既是Controller,又是Service,還是DAO:

清單5.MixLayerUserService.java

 
 
 
 
  1. packageuser.mixlayer;
  2. importorg.springframework.beans.factory.annotation.Autowired;
  3. importorg.springframework.jdbc.core.JdbcTemplate;
  4. importorg.springframework.stereotype.Controller;
  5. importorg.springframework.web.bind.annotation.RequestMapping;
  6. //①.將POJO類通過注解變成SpringMVC的Controller
  7. @Controller
  8. publicclassMixLayerUserService{
  9. //②.自動注入JdbcTemplate
  10. @Autowired
  11. privateJdbcTemplatejdbcTemplate;
  12. //③.通過SpringMVC注解映URL請求
  13. @RequestMapping("/logon.do")
  14. publicStringlogon(StringuserName,Stringpassword){
  15. if(isRightUser(userName,password)){
  16. Stringsql="UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?";
  17. jdbcTemplate.update(sql,20,userName);
  18. return"success";
  19. }else{
  20. return"fail";
  21. }
  22. }
  23. privatebooleanisRightUser(StringuserName,Stringpassword){
  24. //dosth...
  25. returntrue;
  26. }
  27. }

通過@Controller注解將MixLayerUserService變成Web層的Controller,同時也是Service層的服務類。此外,由于直接使用JdbcTemplate訪問數(shù)據(jù),所以MixLayerUserService還是一個DAO。來看一下對應的Spring配置文件:

清單6.applicationContext.xml

 
 
 
 
  1. xmlversionxmlversion="1.0"encoding="UTF-8"?>
  2. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xmlns:p="http://www.springframework.org/schema/p"
  5. xmlns:aop="http://www.springframework.org/schema/aop"
  6. xmlns:tx="http://www.springframework.org/schema/tx"
  7. xsi:schemaLocation="http://www.springframework.org/schema/beans
  8. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  9. http://www.springframework.org/schema/context
  10.  http://www.springframework.org/schema/context/spring-context-3.0.xsd
  11.  http://www.springframework.org/schema/aop
  12.  http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  13.  http://www.springframework.org/schema/tx
  14. http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
  15.  .AnnotationMethodHandlerAdapter"/>
  16.  .InternalResourceViewResolver"
  17. pp:prefix="/WEB-INF/jsp/"p:suffix=".jsp"/>
  18. class="org.apache.commons.dbcp.BasicDataSource"
  19. destroy-method="close"
  20. p:driverClassName="oracle.jdbc.driver.OracleDriver"
  21. p:url="jdbc:oracle:thin:@localhost:1521:orcl"
  22. p:username="test"
  23. p:password="test"/>
  24. class="org.springframework.jdbc.core.JdbcTemplate"
  25. p:dataSource-ref="dataSource"/>
  26. class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
  27. p:dataSource-ref="dataSource"/>
  28. expression="execution(public*user.mixlayer.MixLayerUserService.*(..))"/>
  29. advice-ref="jdbcAdvice"order="0"/>
  30. aop:config>
  31. tx:attributes>
  32. tx:advice>
  33. beans>

在①處,我們定義配置了AnnotationMethodHandlerAdapter,以便啟用SpringMVC的注解驅(qū)動功能。而②和③處通過Spring的aop及tx命名空間,以及Aspject的切點表達式語法進行事務增強的定義,對MixLayerUserService的所有公有方法進行事務增強。要使程序能夠運行起來還必須進行web.xml的相關配置:#p#

清單7.web.xml

 
 
 
 
  1. xmlversionxmlversion="1.0"encoding="GB2312"?>
  2. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
  4. http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
  5. contextConfigLocation param-name>
  6. classpath*:user/mixlayer/applicationContext.xml param-value>
  7. context-param>
  8. log4jConfigLocation param-name>
  9. /WEB-INF/classes/log4j.properties param-value>
  10. context-param>
  11. org.springframework.web.util.Log4jConfigListener
  12. listener-class>
  13. listener>
  14. org.springframework.web.context.ContextLoaderListener
  15. listener-class>
  16. listener>
  17. user servlet-name>
  18. org.springframework.web.servlet.DispatcherServlet
  19. servlet-class>
  20. contextConfigLocation param-name>
  21. classpath:user/mixlayer/applicationContext.xml param-value>
  22. init-param>
  23. 1 load-on-startup>
  24. servlet>
  25. user servlet-name>
  26. *.do url-pattern>
  27. servlet-mapping>
  28. web-app>

這個配置文件很簡單,唯一需要注意的是DispatcherServlet的配置。默認情況下SpringMVC根據(jù)Servlet的名字查找WEB-INF下的 -servlet.xml作為SpringMVC的配置文件,在此,我們通過contextConfigLocation參數(shù)顯式指定SpringMVC配置文件的確切位置。

將org.springframework.jdbc及org.springframework.transaction的日志級別設置為DEBUG,啟動項目,并訪問http://localhost:8088/logon.do?userName=tom應用,MixLayerUserService#logon方法將作出響應,查看后臺輸出日志:

清單8執(zhí)行日志

 
 
 
 
  1. 13:24:22,625DEBUG(AbstractPlatformTransactionManager.java:365)-
  2. Creatingnewtransactionwithname
  3.  [user.mixlayer.MixLayerUserService.logon]:PROPAGATION_REQUIRED,ISOLATION_DEFAULT
  4. 13:24:22,906DEBUG(DataSourceTransactionManager.java:205)-
  5. AcquiredConnection[org.apache.commons.dbcp.PoolableConnection@6e1cbf]
  6.  forJDBCtransaction
  7. 13:24:22,921DEBUG(DataSourceTransactionManager.java:222)-
  8. SwitchingJDBCConnection
  9.  [org.apache.commons.dbcp.PoolableConnection@6e1cbf]tomanualcommit
  10. 13:24:22,921DEBUG(JdbcTemplate.java:785)-
  11. ExecutingpreparedSQLupdate
  12. 13:24:22,921DEBUG(JdbcTemplate.java:569)-
  13. ExecutingpreparedSQLstatement
  14.  [UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?]
  15. 13:24:23,140DEBUG(JdbcTemplate.java:794)-
  16. SQLupdateaffected0rows
  17. 13:24:23,140DEBUG(AbstractPlatformTransactionManager.java:752)-
  18. Initiatingtransactioncommit
  19. 13:24:23,140DEBUG(DataSourceTransactionManager.java:265)-
  20. CommittingJDBCtransactiononConnection
  21.  [org.apache.commons.dbcp.PoolableConnection@6e1cbf]
  22. 13:24:23,140DEBUG(DataSourceTransactionManager.java:323)-
  23. ReleasingJDBCConnection[org.apache.commons.dbcp.PoolableConnection@6e1cbf]
  24.  aftertransaction
  25. 13:24:23,156DEBUG(DataSourceUtils.java:312)-
  26. ReturningJDBCConnectiontoDataSource

日志中粗體部分說明了MixLayerUserService#logon方法已經(jīng)正確運行在事務上下文中。Spring框架本身不應該是復雜化代碼的理由,使用Spring的開發(fā)者應該是無拘無束的:從實際應用出發(fā),去除掉那些所謂原則性的接口,去除掉強制分層的束縛,簡單才是硬道理。

事務方法嵌套調(diào)用的迷茫

Spring事務一個被訛傳很廣說法是:一個事務方法不應該調(diào)用另一個事務方法,否則將產(chǎn)生兩個事務。結果造成開發(fā)人員在設計事務方法時束手束腳,生怕一不小心就踩到地雷。其實這種是不認識Spring事務傳播機制而造成的誤解,Spring對事務控制的支持統(tǒng)一在TransactionDefinition類中描述,該類有以下幾個重要的接口方法:

◆intgetPropagationBehavior():事務的傳播行為;
◆intgetIsolationLevel():事務的隔離級別;
◆intgetTimeout():事務的過期時間;
◆booleanisReadOnly():事務的讀寫特性。

很明顯,除了事務的傳播行為外,事務的其它特性Spring是借助底層資源的功能來完成的,Spring無非只充當個代理的角色。但是事務的傳播行為卻是Spring憑借自身的框架提供的功能,是Spring提供給開發(fā)者最珍貴的禮物,訛傳的說法玷污了Spring事務框架最美麗的光環(huán)。所謂事務傳播行為就是多個事務方法相互調(diào)用時,事務如何在這些方法間傳播。Spring支持7種事務傳播行為:

◆PROPAGATION_REQUIRED如果當前沒有事務,就新建一個事務,如果已經(jīng)存在一個事務中,加入到這個事務中。這是最常見的選擇。

◆PROPAGATION_SUPPORTS支持當前事務,如果當前沒有事務,就以非事務方式執(zhí)行。

◆PROPAGATION_MANDATORY使用當前的事務,如果當前沒有事務,就拋出異常。

◆PROPAGATION_REQUIRES_NEW新建事務,如果當前存在事務,把當前事務掛起。

◆PROPAGATION_NOT_SUPPORTED以非事務方式執(zhí)行操作,如果當前存在事務,就把當前事務掛起。

◆PROPAGATION_NEVER以非事務方式執(zhí)行,如果當前存在事務,則拋出異常。

◆PROPAGATION_NESTED如果當前存在事務,則在嵌套事務內(nèi)執(zhí)行。如果當前沒有事務,則執(zhí)行與PROPAGATION_REQUIRED類似的操作。

Spring默認的事務傳播行為是PROPAGATION_REQUIRED,它適合于絕大多數(shù)的情況。假設ServiveX#methodX()都工作在事務環(huán)境下(即都被Spring事務增強了),假設程序中存在如下的調(diào)用鏈:Service1#method1()->Service2#method2()->Service3#method3(),那么這3個服務類的3個方法通過Spring的事務傳播機制都工作在同一個事務中。

下面,我們來看一下實例,UserService#logon()方法內(nèi)部調(diào)用了UserService#updateLastLogonTime()和ScoreService#addScore()方法,這兩個類都繼承于BaseService。它們之間的類結構說明如下:

 
圖1.UserService和ScoreService

具體的代碼如下所示:

清單9UserService.java

 
 
 
 
  1. @Service("userService")
  2. publicclassUserServiceextendsBaseService{
  3. @Autowired
  4. privateJdbcTemplatejdbcTemplate;
  5. @Autowired
  6. privateScoreServicescoreService;
  7. publicvoidlogon(StringuserName){
  8. updateLastLogonTime(userName);
  9. scoreService.addScore(userName,20);
  10. }
  11. publicvoidupdateLastLogonTime(StringuserName){
  12. Stringsql="UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?";
  13. jdbcTemplate.update(sql,System.currentTimeMillis(),userName);
  14. }
  15. }

UserService中注入了ScoreService的Bean,ScoreService的代碼如下所示:

清單10ScoreService.java

 
 
 
 
  1. @Service("scoreUserService")
  2. publicclassScoreServiceextendsBaseService{
  3. @Autowired
  4. privateJdbcTemplatejdbcTemplate;
  5. publicvoidaddScore(StringuserName,inttoAdd){
  6. Stringsql="UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?";
  7. jdbcTemplate.update(sql,toAdd,userName);
  8. }
  9. }

通過Spring的事務配置為ScoreService及UserService中所有公有方法都添加事務增強,讓這些方法都工作于事務環(huán)境下。下面是關鍵的配置代碼:#p#

清單11事務增強配置

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

將日志級別設置為DEBUG,啟動Spring容器并執(zhí)行UserService#logon()的方法,仔細觀察如下的輸出日志:

清單12執(zhí)行日志

 
 
 
 
  1. 16:25:04,765DEBUG(AbstractPlatformTransactionManager.java:365)-
  2. Creatingnewtransactionwithname[user.nestcall.UserService.logon]:
  3. PROPAGATION_REQUIRED,ISOLATION_DEFAULT①為UserService#logon方法啟動一個事務
  4. 16:25:04,765DEBUG(DataSourceTransactionManager.java:205)-
  5. AcquiredConnection[org.apache.commons.dbcp.PoolableConnection@32bd65]
  6. forJDBCtransaction
  7. logonmethod...
  8. updateLastLogonTime...②直接執(zhí)行updateLastLogonTime方法
  9. 16:25:04,781DEBUG(JdbcTemplate.java:785)-ExecutingpreparedSQLupdate
  10. 16:25:04,781DEBUG(JdbcTemplate.java:569)-ExecutingpreparedSQLstatement
  11. [UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?]
  12. 16:25:04,828DEBUG(JdbcTemplate.java:794)-SQLupdateaffected0rows
  13. 16:25:04,828DEBUG(AbstractPlatformTransactionManager.java:470)-Participating
  14. inexistingtransaction③ScoreService#addScore方法加入到UserService#logon的事務中
  15. addScore...
  16. 16:25:04,828DEBUG(JdbcTemplate.java:785)-ExecutingpreparedSQLupdate
  17. 16:25:04,828DEBUG(JdbcTemplate.java:569)-ExecutingpreparedSQLstatement
  18. [UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?]
  19. 16:25:04,828DEBUG(JdbcTemplate.java:794)-SQLupdateaffected0rows
  20. 16:25:04,828DEBUG(AbstractPlatformTransactionManager.java:752)-
  21. Initiatingtransactioncommit
  22. 16:25:04,828DEBUG(DataSourceTransactionManager.java:265)-CommittingJDBCtransaction
  23. onConnection[org.apache.commons.dbcp.PoolableConnection@32bd65]
  24. 16:25:04,828DEBUG(DataSourceTransactionManager.java:323)-ReleasingJDBCConnection
  25. [org.apache.commons.dbcp.PoolableConnection@32bd65]aftertransaction
  26. 16:25:04,828DEBUG(DataSourceUtils.java:312)-ReturningJDBCConnectiontoDataSource

從上面的輸入日志中,可以清楚地看到Spring為UserService#logon()方法啟動了一個新的事務,而UserSerive#updateLastLogonTime()和UserService#logon()是在相同的類中,沒有觀察到有事務傳播行為的發(fā)生,其代碼塊好像“直接合并”到UserService#logon()中。接著,當執(zhí)行到ScoreService#addScore()方法時,我們就觀察到了發(fā)生了事務傳播的行為:Participatinginexistingtransaction,這說明ScoreService#addScore()添加到UserService#logon()的事務上下文中,兩者共享同一個事務。所以最終的結果是UserService的logon(),updateLastLogonTime()以及ScoreService的addScore都工作于同一事務中。

多線程的困惑

由于Spring事務管理器是通過線程相關的ThreadLocal來保存數(shù)據(jù)訪問基礎設施,再結合IOC和AOP實現(xiàn)高級聲明式事務的功能,所以Spring的事務天然地和線程有著千絲萬縷的聯(lián)系。

我們知道Web容器本身就是多線程的,Web容器為一個Http請求創(chuàng)建一個獨立的線程,所以由此請求所牽涉到的Spring容器中的Bean也是運行于多線程的環(huán)境下。在絕大多數(shù)情況下,Spring的Bean都是單實例的(singleton),單實例Bean的最大的好處是線程無關性,不存在多線程并發(fā)訪問的問題,也即是線程安全的。一個類能夠以單實例的方式運行的前提是“無狀態(tài)”:即一個類不能擁有狀態(tài)化的成員變量。我們知道,在傳統(tǒng)的編程中,DAO必須執(zhí)有一個Connection,而Connection即是狀態(tài)化的對象。所以傳統(tǒng)的DAO不能做成單實例的,每次要用時都必須new一個新的實例。傳統(tǒng)的Service由于將有狀態(tài)的DAO作為成員變量,所以傳統(tǒng)的Service本身也是有狀態(tài)的。

但是在Spring中,DAO和Service都以單實例的方式存在。Spring是通過ThreadLocal將有狀態(tài)的變量(如Connection等)本地線程化,達到另一個層面上的“線程無關”,從而實現(xiàn)線程安全。Spring不遺余力地將狀態(tài)化的對象無狀態(tài)化,就是要達到單實例化Bean的目的。由于Spring已經(jīng)通過ThreadLocal的設施將Bean無狀態(tài)化,所以Spring中單實例Bean對線程安全問題擁有了一種天生的免疫能力。不但單實例的Service可以成功運行于多線程環(huán)境中,Service本身還可以自由地啟動獨立線程以執(zhí)行其它的Service。下面,通過一個實例對此進行描述:

清單13UserService.java在事務方法中啟動獨立線程運行另一個事務方法

 
 
 
 
  1. @Service("userService")
  2. publicclassUserServiceextendsBaseService{
  3. @Autowired
  4. privateJdbcTemplatejdbcTemplate;
  5. @Autowired
  6. privateScoreServicescoreService;
  7. //①在logon方法體中啟動一個獨立的線程,在該獨立的線程中執(zhí)行ScoreService#addScore()方法
  8. publicvoidlogon(StringuserName){
  9. System.out.println("logonmethod...");
  10. updateLastLogonTime(userName);
  11. ThreadmyThread=newMyThread(this.scoreService,userName,20);
  12. myThread.start();
  13. }
  14. publicvoidupdateLastLogonTime(StringuserName){
  15. System.out.println("updateLastLogonTime...");
  16. Stringsql="UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?";
  17. jdbcTemplate.update(sql,System.currentTimeMillis(),userName);
  18. }
  19. //②封裝ScoreService#addScore()的線程
  20. privateclassMyThreadextendsThread{
  21. privateScoreServicescoreService;
  22. privateStringuserName;
  23. privateinttoAdd;
  24. privateMyThread(ScoreServicescoreService,StringuserName,inttoAdd){
  25. this.scoreService=scoreService;
  26. this.userName=userName;
  27. this.toAdd=toAdd;
  28. }
  29. publicvoidrun(){
  30. scoreService.addScore(userName,toAdd);
  31. }
  32. }
  33. }

將日志級別設置為DEBUG,執(zhí)行UserService#logon()方法,觀察以下輸出的日志:

清單14執(zhí)行日志

 
 
 
 
  1. [main](AbstractPlatformTransactionManager.java:365)-Creatingnewtransactionwithname
  2. [user.multithread.UserService.logon]:PROPAGATION_REQUIRED,ISOLATION_DEFAULT①
  3. [main](DataSourceTransactionManager.java:205)-AcquiredConnection
  4. [org.apache.commons.dbcp.PoolableConnection@1353249]forJDBCtransaction
  5. logonmethod...
  6. updateLastLogonTime...
  7. [main](JdbcTemplate.java:785)-ExecutingpreparedSQLupdate
  8. [main](JdbcTemplate.java:569)-ExecutingpreparedSQLstatement
  9. [UPDATEt_useruSETu.last_logon_time=?WHEREuser_name=?]
  10. [main](JdbcTemplate.java:794)-SQLupdateaffected0rows
  11. [main](AbstractPlatformTransactionManager.java:752)-Initiatingtransactioncommit
  12. [Thread-2](AbstractPlatformTransactionManager.java:365)-
  13. Creatingnewtransactionwithname[user.multithread.ScoreService.addScore]:
  14. PROPAGATION_REQUIRED,ISOLATION_DEFAULT②
  15. [main](DataSourceTransactionManager.java:265)-CommittingJDBCtransaction
  16. onConnection[org.apache.commons.dbcp.PoolableConnection@1353249]③
  17. [main](DataSourceTransactionManager.java:323)-ReleasingJDBCConnection
  18. [org.apache.commons.dbcp.PoolableConnection@1353249]aftertransaction
  19. [main](DataSourceUtils.java:312)-ReturningJDBCConnectiontoDataSource
  20. [Thread-2](DataSourceTransactionManager.java:205)-AcquiredConnection
  21. [org.apache.commons.dbcp.PoolableConnection@10dc656]forJDBCtransaction
  22. addScore...
  23. [main](JdbcTemplate.java:416)-ExecutingSQLstatement
  24. [DELETEFROMt_userWHEREuser_name='tom']
  25. [main](DataSourceUtils.java:112)-FetchingJDBCConnectionfromDataSource
  26. [Thread-2](JdbcTemplate.java:785)-ExecutingpreparedSQLupdate
  27. [Thread-2](JdbcTemplate.java:569)-ExecutingpreparedSQLstatement
  28. [UPDATEt_useruSETu.score=u.score+?WHEREuser_name=?]
  29. [main](DataSourceUtils.java:312)-ReturningJDBCConnectiontoDataSource
  30. [Thread-2](JdbcTemplate.java:794)-SQLupdateaffected0rows
  31. [Thread-2](AbstractPlatformTransactionManager.java:752)-Initiatingtransactioncommit
  32. [Thread-2](DataSourceTransactionManager.java:265)-CommittingJDBCtransaction
  33. onConnection[org.apache.commons.dbcp.PoolableConnection@10dc656]④
  34. [Thread-2](DataSourceTransactionManager.java:323)-ReleasingJDBCConnection
  35. [org.apache.commons.dbcp.PoolableConnection@10dc656]aftertransaction

在①處,在主線程(main)執(zhí)行的UserService#logon()方法的事務啟動,在③處,其對應的事務提交,而在子線程(Thread-2)執(zhí)行的ScoreService#addScore()方法的事務在②處啟動,在④處對應的事務提交。

所以,我們可以得出這樣的結論:在相同線程中進行相互嵌套調(diào)用的事務方法工作于相同的事務中。如果這些相互嵌套調(diào)用的方法工作在不同的線程中,不同線程下的事務方法工作在獨立的事務中。

小結

Spring聲明式事務是Spring最核心,最常用的功能。由于Spring通過IOC和AOP的功能非常透明地實現(xiàn)了聲明式事務的功能,一般的開發(fā)者基本上無須了解Spring聲明式事務的內(nèi)部細節(jié),僅需要懂得如何配置就可以了。

但是在實際應用開發(fā)過程中,Spring的這種透明的高階封裝在帶來便利的同時,也給我們帶來了迷惑。就像通過流言傳播的消息,最終聽眾已經(jīng)不清楚事情的真相了,而這對于應用開發(fā)來說是很危險的。本系列文章通過剖析實際應用中給開發(fā)者造成迷惑的各種難點,通過分析Spring事務管理的內(nèi)部運作機制將真相還原出來。在本文中,我們通過剖析了解到以下的真相:

◆在沒有事務管理的情況下,DAO照樣可以順利進行數(shù)據(jù)操作;

◆將應用分成Web,Service及DAO層只是一種參考的開發(fā)模式,并非是事務管理工作的前提條件;

◆Spring通過事務傳播機制可以很好地應對事務方法嵌套調(diào)用的情況,開發(fā)者無須為了事務管理而刻意改變服務方法的設計;

◆由于單實例的對象不存在線程安全問題,所以進行事務管理增強的Bean可以很好地工作在多線程環(huán)境下。

在下一篇文章中,筆者將繼續(xù)分析Spring事務管理的以下難點:

◆混合使用多種數(shù)據(jù)訪問技術(如SpringJDBC+Hibernate)的事務管理問題;

◆在通過Bean的方法通過SpringAOP增強存在哪些特殊的情況。


網(wǎng)頁標題:Spring事務管理高級應用難點剖析
分享URL:http://m.5511xx.com/article/dpegosg.html