相關文章：Spring聲明式事務管理源碼解讀之事務開始

其實我的感覺就是事務提交要比事務開始復雜，看事務是否提交我們還是要回到TransactionInterceptor類的invoke方法：

Java代碼

public Object invoke(MethodInvocation invocation) throws Throwable {
　　　　// Work out the target class: may be null.
　　　　// The TransactionAttributeSource should be passed the target class
　　　　// as well as the method, which may be from an interface
　　　　Class targetClass = (invocation.getThis() != null) ? invocation.getThis().getClass() : null;
　　　　
　　　　// Create transaction if necessary.
　　　　TransactionInfo txInfo = createTransactionIfNecessary(invocation.getMethod(), targetClass);
　　　　Object retVal = null;
　　　　try {
　　　　　　// This is an around advice.
　　　　　　// Invoke the next interceptor in the chain.
　　　　　　// This will normally result in a target object being invoked.
　　　　　　retVal = invocation.proceed();
　　　　}
　　　　catch (Throwable ex) {
　　　　　　// target invocation exception
　　　　　　doCloseTransactionAfterThrowing(txInfo, ex);
　　　　　　throw ex;
　　　　}
　　　　finally {
　　　　　　doFinally(txInfo);//業(yè)務方法出棧后必須先執(zhí)行的一個方法
　　　　}
　　　　doCommitTransactionAfterReturning(txInfo);
　　　　return retVal;
　　}

其中的doFinally(txInfo)那一行很重要，也就是說不管如何，這個doFinally方法都是要被調用的，為什么它這么重要呢，舉個例子：

我們還是以propregation_required來舉例子吧，假設情況是這樣的，AService中有一個方法調用了BService中的，這兩個方法都處在事務體之中，他們的傳播途徑都是required。那么調用開始了，AService的方法首先入方法棧，并創(chuàng)建了TransactionInfo的實例，接著BService的方法入棧，又創(chuàng)建了一個TransactionInfo的實例，而重點要說明的是TransactionInfo是一個自身關聯(lián)的內部類，第二個方法入棧時，會給新創(chuàng)建的TransactionInfo的實例設置一個屬性，就是TransactionInfo對象中的private TransactionInfo oldTransactionInfo;屬性，這個屬性表明BService方法的創(chuàng)建的TransactionInfo對象是有一個old的transactionInfo對象的，這個oldTransactionInfo對象就是AService方法入棧時創(chuàng)建的TransactionInfo對象，我們還記得在createTransactionIfNecessary方法里有這樣一個方法吧：

Java代碼

protected TransactionInfo createTransactionIfNecessary(Method method, Class targetClass) {
　　　　　　　　// We always bind the TransactionInfo to the thread, even if we didn't create
　　　　// a new transaction here. This guarantees that the TransactionInfo stack
　　　　// will be managed correctly even if no transaction was created by this aspect.
　　　　txInfo.bindToThread();
　　　　return txInfo;
　　}
就是這個bindToThread()方法在作怪：
private void bindToThread() {
　　　　　　// Expose current TransactionStatus, preserving any existing transactionStatus for
　　　　　　// restoration after this transaction is complete.
　　　　　　oldTransactionInfo = (TransactionInfo) currentTransactionInfo.get();
　　　　　　currentTransactionInfo.set(this);
　　　　}

如果當前線程中已經有了一個TransactionInfo，則拿出來放到新建的transactionInfo對象的oldTransactionInfo屬性中，然后再把新建的TransactionInfo設置到當前線程中。

這里有一個概念要搞清楚，就是TransactionInfo對象并不是表明事務狀態(tài)的對象，表明事務狀態(tài)的對象是TransactionStatus對象，這個對象同樣是TransactionInfo的一個屬性。

接下來BService中的那個方法返回，那么該它退棧了，它退棧后要做的就是doFinally方法，即把它的oldTransactionInfo設置到當前線程中（這個TransactionInfo對象顯然就是AService方法入棧時創(chuàng)建的，怎么現(xiàn)在又要設置到線程中去呢，原因就是BService的方法出棧時并不提交事務，因為BService的傳播途徑是required，所以要把棧頂?shù)姆椒ㄋ鶆?chuàng)建transactioninfo給設置到當前線程中），即調用AService的方法時所創(chuàng)建的TransactionInfo對象。那么在AServie的方法出棧時同樣會設置TransactionInfo對象的oldTransactionInfo到當前線程，這時候顯然oldTransactionInfo是空的，但AService中的方法會提交事務，所以它的oldTransactionInfo也應該是空了。

在這個小插曲之后，接下來就應該是到提交事務了，之前在AService的方法出棧時，我們拿到了它入棧時創(chuàng)建的TransactionInfo對象，這個對象中包含了AService的方法事務狀態(tài)。即TransactionStatus對象，很顯然，太顯然了，事務提交中的任何屬性都和事務開始時的創(chuàng)建的對象息息相關，這個TransactionStatus對象哪里來的，我們再回頭看看createTransactionIfNessary方法吧：

Java代碼

protected TransactionInfo createTransactionIfNecessary(Method method, Class targetClass) {
　　　　　　txInfo.newTransactionStatus(this.transactionManager.getTransaction(txAttr));
　　　　}

再看看transactionManager.getTransaction(txAttr)方法吧：

Java代碼

public final TransactionStatus getTransaction(TransactionDefinition definition) 
throws TransactionException {
　　　　
　　　　else if (definition.getPropagationBehavior() == TransactionDefinition.PR
OPAGATION_REQUIRED ||
　　　　　　　　definition.getPropagationBehavior() == TransactionDefinition.PROP
AGATION_REQUIRES_NEW ||
　　　　　　definition.getPropagationBehavior() == TransactionDefinition.PROPAGA
TION_NESTED) {
　　　　　　if (debugEnabled) {
　　　　　　　　logger.debug("Creating new transaction with name [" + definition.
getName() + "]");
　　　　　　}
　　　　　　doBegin(transaction, definition);
　　　　　　boolean newSynchronization = (this.transactionSynchronization != SYN
CHRONIZATION_NEVER);
　　　　　　return newTransactionStatus(definition, transaction, true, newSynchro
nization, debugEnabled, null);
//注意這里的返回值，返回的就是一個TransactionStatus對象,這個對象表明了一個事務的狀態(tài)，比
如說是否是一個新的事務，事務是否已經結束，等等，這個對象是非常重要的，在事務提交的時候還是
會用到它的。　　　　}
　　　　　　}
　　}

#p#

還有一點需要說明的是，AService的方法在執(zhí)行之前創(chuàng)建的transactionstatus確實是通過這個方法創(chuàng)建的，但是，BService的方法在執(zhí)行之前創(chuàng)建transactionstatus的方法就與這個不一樣了，下面會有詳解。

回顧了事務開始時所調用的方法之后，是不是覺得現(xiàn)在對spring如何處理事務越來越清晰了呢。由于這么幾個方法的調用，每個方法入棧之前它的事務狀態(tài)就已經被設置好了。這個事務狀態(tài)就是為了在方法出棧時被調用而準備的。

讓我們再次回到BService中的方法出棧的那個時間段，看看spring都做了些什么，我們知道，后入棧的肯定是先出棧，BService中的方法后入棧，那它肯定要先出棧了，它出棧的時候是要判斷是否要提交事務，釋放資源的，讓我們來看看TransactionInterceptor的invoke的***那個方法doCommitTransactionAfterReturning：

Java代碼

protected void doCommitTransactionAfterReturning(TransactionInfo txInfo) {
　　　　if (txInfo != null && txInfo.hasTransaction()) {
　　　　　　if (logger.isDebugEnabled()) {
　　　　　　　　logger.debug("Invoking commit for transaction on " + txInfo.j
oinpointIdentification());
　　　　　　}
　　　　　　this.transactionManager.commit(txInfo.getTransactionStatus());
//瞧：提交事務時用到了表明事務狀態(tài)的那個TransactionStatus對象了。
　　　　}
　　}

看這個方法的名字就知道spring是要在業(yè)務方法出棧時提交事務，貌似很簡單，但是事實是這樣的嗎？我們接著往下看。

Java代碼

上面這段代碼就是transactionmanager中的commit，但是看上去，它又把自己的職責分配給別人了，從代碼里我們看到，如果事務已經結束了就拋異常，如果事務是rollbackonly的，那么就rollback吧，但是按照正常流程，我們還是想來看一下，事務的提交，就是processCommit(status)這個方法吧。

Java代碼

我們注意到，在判斷一個事務是否是新事務之前還有一個status.hasSavepoint()的判斷，我認為這個判斷事實上就是嵌套事務的判斷，即判斷這個事務是否是嵌套事務，如果不是嵌套事務，則再判斷它是否是一個新事務，下面這段話就非常重要了，BService的中的方法是先出棧的，也就是說在調用BService之前的創(chuàng)建的那個事務狀態(tài)對象在這里要先被判斷，但是由于在調用BService的方法之前已經創(chuàng)建了一個Transaction和Session（假設我們使用的是hibernate3），這時候在創(chuàng)建第二個TransactionInfo（再強調一下吧，TransactionInfo并不是Transaction，Transaction是真正的事務對象，TransactionInfo只不過是一個輔助類而已，用來記錄一系列狀態(tài)的輔助類）的TransactionStatus的時候就會進入下面這個方法（當然在這之前會判斷一下當前線程中是否已經有了一個SessionHolder對象，不清楚SessionHolder作用的同學請看***篇文章）：

Java代碼

我們看到這個方法其實很明了，就是什么樣的傳播途徑就創(chuàng)建什么樣的transactionstatus，這個方法是在事務開始時被調用的，拿到我們之前舉的例子中來看下，我們就恍然大悟了，原來，如果之前已經創(chuàng)建過事務，那個這個新建的transactionstauts就不應該是屬于一個newTransaction了，所以第3個參數(shù)就是false了。

也就是說，在BService的方法出棧要要執(zhí)行processcommit，但是由于BService的那個TransactionStatus不是一個newTransaction，所以它根本不會觸發(fā)這個動作：

Java代碼

else if (status.isNewTransaction()) {//這個判斷非常重要，下面會詳細講解這個判斷的作用
　　　　　　　　　　if (status.isDebug()) {
　　　　　　　　　　　　logger.debug("Initiating transaction commit");
　　　　　　　　　　}
boolean globalRollbackOnly = status.isGlobalRollbackOnly();
　　　　　　　　　　doCommit(status);
}

也就是說在BService的方法出棧后，事務是不會提交的。這完全符合propragation_required的模型。

而在AService的方法出棧后，AService的方法所對應的那個TransactionStatus對象的newTransaction屬性是為true的，即它會觸發(fā)上面這段代碼，進行真正的事務提交。讓我們回想一下AService方法入棧之前創(chuàng)建TransactionStatus對象的情形吧：

newTransactionStatus(definition, transaction, true, newSynchronization, debu
gEnabled, null);

看到第3個參數(shù)為true沒有。

那么事務該提交了吧，事務的提交我想使用過hibernate的人都知道怎么提交了：

txObject.getSessionHolder().getTransaction().commit();

從當前線程中拿到SessionHolder，再拿到開始事務的那個Transaction對象，然后再commit事務。在沒有用spring之前，我們經常這么做。

【編輯推薦】

1. Spring聲明式事務管理源碼解讀之事務開始
2. Spring框架將推出企業(yè)級Web服務器
3. Spring MVC框架的高級配置