TransactionManager

旭龍 2013-08-07

展開全文

您有沒有想過，為什么會有六種事務(wù)劃分屬性（NotSupported、Required、Supports、RequiresNew、Mandatory和Never）？這六種都是由容器托管事務(wù) (CMT)的bean來支持的，但如果使用的是bean托管事務(wù)(BMT)，EJB規(guī)范所能提供的功能難道就只有通過UserTransaction接口啟動和提交/回滾事務(wù)嗎？顯然，CMT模型好像更強大，比如，BMT不能使當前事務(wù)掛起然后恢復，這就意味著在BMT bean中無法仿真RequiresNew和NotSupported劃分，至少是在使用UserTransaction接口時。

　　雖然EJB規(guī)范并沒有解釋為什么會存在以上所提到的不對稱情況，但是在BMT模型中依然有一種用來使事務(wù)掛起然后恢復的合法方式。如果曾經(jīng)研究過javax.transaction包的內(nèi)容，您可能會注意到，與UserTransaction接口一起的還有一個TransactionManager接口，它看起來就像一個擴展的UserTransaction：同樣的方法——begin()、commit()和rollback()，再加上suspend()和resume()。

　　如果能從EJB中得到一個TransactionManager實現(xiàn)，我們就可以實現(xiàn)編程式地使事務(wù)掛起然后恢復的目標。雖然J2EE 1.3和EJB 2.0規(guī)范都未提到TransactionManager的可用性，但它們也都沒有明確表示禁止使用它。此外，對于CMT事務(wù)劃分，容器是從內(nèi)部使用Java Transaction API (JTA)，因此，我們幾乎可以100%地肯定：TransactionManager是存在的，惟一的問題只是在代碼中獲得對它的引用。

　　在這篇文章中，我們將了解如何利用幾個流行的容器來獲得一個TransactionManager，以及如何用它來擴展bean托管事務(wù)的功能，使它們和容器托管事務(wù)一樣強大。我們也將簡述一些涉及使用這些高級功能的風險，在文章的結(jié)尾，我們還將探討如何在流行的Spring框架中使用TransactionManager。
在各種J2EE服務(wù)器中獲得TransactionManager的引用

　　J2EE和EJB規(guī)范沒有描述任何獲得TransactionManager引用的標準方法，每個J2EE容器供應商可以隨意將其放置在任何地方，甚至不需提供任何機制，就可以從應用程序代碼中對它進行訪問。但在實踐中，如今所有的容器都有獲取它的機制。以下是一些如何從最流行的J2EE容器獲得TransactionManager引用的例子。
拋出一個UserTransaction (WebLogic、Orion、OC4J)

　　任何一個兼容J2EE的容器都必須使UserTransaction對象在JNDI中的java:comp/UserTransaction下可用。因為UserTransaction接口是TransactionManager的子集，所以一些J2EE容器供應商選擇為它們提供一種通用的實現(xiàn)。WebLogic 8、Orion 2和Oracle的OC4J EJB3預覽版都是這種方法的例子。在這些容器中，只要從JNDI中獲得一個UserTransaction對象，再把它轉(zhuǎn)到TransactionManager，就可以獲得對TransactionManager的引用。這可能是最簡單的一種情況。

Java代碼

private TransactionManager getFromUserTransaction()
throws Exception {
InitialContext ctx = new InitialContext();
UserTransaction ut = (UserTransaction)
ctx.lookup("java:comp/UserTransaction");
if (ut instanceof TransactionManager) {
log("UserTransaction also TransactionManager");
return (TransactionManager)ut;
}
return null;
}

直接從JNDI中獲取TransactionManager (JBoss、WebLogic)

　　在JBoss 3和WebLogic 8中，可從JNDI獲取TransactionManager（雖然名稱不一樣），因此可以通過簡單的查找而獲得：

Java代碼

private TransactionManager getFromJNDI()
throws Exception {
InitialContext ctx = new InitialContext();
try {
// WebLogic
return (TransactionManager)
ctx.lookup("javax.transaction.TransactionManager");
}
catch (Exception e) { }
try {
// JBoss
return (TransactionManager)
ctx.lookup("java:/TransactionManager");
}
catch (Exception e) { }
return null;
}

從一個定制的工廠獲取TransactionManager (Websphere)

　　在WebSphere 4/5/6中，TransactionManager的引用要從工廠類中獲取。但是，麻煩的是，工廠類的名稱隨WebSphere版本的不同而有所改變。

Java代碼

public TransactionManager getFromWebsphereFactory()
throws Exception {
try {
// WebSphere 5.1 or 6.0
return
com.ibm.ws.Transaction.TransactionManagerFactory
.getTransactionManager();
}
catch (ClassNotFoundException ex) {}
try {
// WebSphere 5.0
return
com.ibm.ejs.jts.jta.TransactionManagerFactory
.getTransactionManager();
}
catch (ClassNotFoundException ex) {}
try {
// WebSphere 4.0
com.ibm.ejs.jts.jta.JTSXA..getTransactionManager();
}
catch (ClassNotFoundException ex) { }
return null;
}

　　在WebLogic 7/8/9中，對TransactionManager的引用可以通過在Weblogic 7的TxHelper中定義的靜態(tài)方法getTransactionManager()而獲得。該類在WebLogic 8中被否決了，而用TransactionHelper取而代之。

Java代碼

public TransactionManager getFromWebLogicFactory()
throws Exception {
try {
// WebLogic 8/9
return
weblogic.transaction.TransactionHelper
.getTransactionManager();
}
catch (ClassNotFoundException ex) {}
try {
// WebLogic 7
return
weblogic.transaction.TxHelper
.getTransactionManager();
}
catch (ClassNotFoundException ex) {}
return null;
}

使用TransactionManager

　　一旦成功地獲得TransactionManager引用，就可以用它來掛起和恢復事務(wù)，正如以下的示例代碼所示。

...

Java代碼

// obtain UserTransaction object and start transaction
InitialContext ctx = new InitialContext();
UserTransaction userTransaction = (UserTransaction)
ctx.lookup("java:comp/UserTransaction");
// start first transaction
userTransaction.begin();
// obtain TransactionManager
// using one of the methods described above
TransactionManager tm = getTransactionManager();
// suspend transaction
// suspend() returns reference to suspended
// Transaction object which later should be passed
// to resume()
Transaction transaction = tm.suspend();
// here you can do something outside of transaction
// or start new transaction,
// do something and then commit or rollback
userTransaction.begin();
// commit subtransaction
userTransaction.commit();
// resume suspended transaction
tm.resume(transaction);
// commit first transaction
userTransaction.commit();
...

正如您所看到的，在TransactionManager接口的幫助下，可以對UserTransaction所提供的標準功能進行擴展，在BMT代碼中實現(xiàn)與CMT bean相同的靈活性水平。

　　需要知道的是，當事務(wù)被掛起時，并不意味著事務(wù)的計時器停止了。換言之，如果把事務(wù)的超時設(shè)定為30秒，而事務(wù)已掛起了20秒并恢復了，那么該事務(wù)只剩10秒就要到達超時了。事務(wù)的掛起會解除事務(wù)與正在運行的線程之間的關(guān)聯(lián)，然后resume()調(diào)用會再次將其關(guān)連，而不影響事務(wù)超時計時器。
已知問題

　　因為J2EE規(guī)范并不要求TransactionManager在J2EE容器中的可用性以及功能（雖然從底層的JTA基礎(chǔ)架構(gòu)中我們知道它應該是存在的），所以有些應用服務(wù)器中存在一些問題。例如，在WebLogic 7、8以及9（beta版）中有種特別奇怪的現(xiàn)象：假如一個事務(wù)被標記為回滾（通過調(diào)用UserTransaction.setRollbackOnly ()），然后被掛起，當被掛起的事務(wù)嘗試恢復時，它將會出現(xiàn)如下的提示：

　　javax.transaction.InvalidTransactionException: Attempt to resume an inactive transaction

　　以下代碼說明了該行為：

Java代碼

...
// obtain UserTransaction object and start transaction
InitialContext ctx = new InitialContext();
UserTransaction userTransaction = (UserTransaction)
ctx.lookup("java:comp/UserTransaction");
userTransaction.begin();
// mark for rollback
userTransaction.setRollbackOnly();
TransactionManager tm = getTransactionManager();
// suspend transaction
Transaction transaction = tm.suspend();
// resume suspended transaction
// this call will fail with InvalidTransactionException
// in WebLogic
tm.resume(transaction);

...

　　幸運的是，對于該問題，有一個應急方案。WebLogic的TransactionManager實現(xiàn)連同標準的resume （Transaction transaction）方法，有一個可用于替代的forceResume方法。以下的代碼展示了一種在WebLogic中運行代碼時需要用到的模式。注意，在這種情況下，應該把對TransactionManager的引用轉(zhuǎn)換到WebLogic的定制實現(xiàn)接口（WebLogic 7中的weblogic.transaction.TransactionManager或WebLogic 8以及更高版本中的weblogic.transaction.ClientTransactionManager）。

...
// obtain UserTransaction object and start transaction

Java代碼

InitialContext ctx = new InitialContext();
UserTransaction userTransaction = (UserTransaction)
ctx.lookup("java:comp/UserTransaction");
userTransaction.begin();
// mark for rollback
userTransaction.setRollbackOnly();
TransactionManager tm = getTransactionManager();
// suspend transaction
Transaction transaction = tm.suspend();
// resume suspended transaction
try {
// first try standard JTA call
tm.resume(transaction);
}
catch (InvalidTransactionException e) {
// standard method failed, try forceResume()
if (tm instanceof
weblogic.transaction.ClientTransactionManager) {
// WebLogic 8 and above
((weblogic.transaction.ClientTransactionManager)tm)
.forceResume(transaction);
}
else if (tm instanceof
weblogic.transaction.TransactionManager) {
// WebLogic 7
((weblogic.transaction.TransactionManager)tm)
.forceResume(transaction)
}
else {
// cannot resume
throw e;
}
}

...

TransactionManager在Spring Framework中的用法

　　在流行的Spring framework中，以上所描述的技術(shù)都被廣泛地用于事務(wù)代理。應該注意的是，每次使用PROPAGATION_REQUIRES_NEW或PROPAGATION_NOT_SUPPORTED、事務(wù)屬性以及JtaTransactionManager來配置Spring的TransactionProxyFactoryBean時， Spring就會用JTA的TransactionManager來掛起和恢復事務(wù)。Spring太智能了，但有時太智能了反而使我無法接受——甚至沒有指定，它就會發(fā)現(xiàn)容器中的TransactionManager。例如，當在一個Spring應用程序上下文中定義 JtaTransactionManager時，就可以為UserTransaction提供一個JNDI名，而如果UserTransaction也實現(xiàn)了它，它就將“自動檢測”TransactionManager。如上所示，這對WebLogic、Orion和Oracle OC4J都適用。

　　有時，這可能并不是我們所想要的，尤其是當您想要嚴格遵循J2EE/EJB規(guī)范，并確保跨所有J2EE容器的完全可移植性的時候。正如我們所看到的，有時候編程式的事務(wù)掛起和恢復可能存在一些問題。雖然Spring知道如何繞過這些問題，至少是對于上面所描述的問題，即，在Welogic中，在掛起之前將事務(wù)標記為回滾。在這種情況下，可以在配置JtaTransactionManager時把 autodetectTransactionManager屬性設(shè)定為false。如果這么做了，那么任何使用 PROPAGATION_REQUIRES_NEW或PROPAGATION_NOT_SUPPORTED事務(wù)屬性的嘗試都會拋出 TransactionSuspensionNotSupportedException而失敗。但PROPAGATIO-REQUIRED、 PROPAGATION-SUPPORTS、PROPAGATION-MANDATORY以及PROPAGATION-NEVER應該會正常運行。這對應于JTA Usertransaction所提供的功能，而且在任一個兼容J2EE的容器中都起作用。

　　以下是Spring應用程序上下文中的事務(wù)管理器定義，其中禁用了TransactionManager自動檢測：

Xml代碼

<bean id="transactionManager" class=
"org.springframework.transaction.jta.JtaTransactionManager">
<property name="userTransactionName">
<value>javax.transaction.UserTransaction</value>
</property>
<property name="autodetectTransactionManager">
<value>false</value>
</property>
</bean>

結(jié)束語

　　J2EE規(guī)范不要求對JIA TransactionManager接口的支持。但由于J2EE使用JTA作為它的底層事務(wù)基礎(chǔ)架構(gòu)，所以幾乎所有的J2EE服務(wù)器都把它公開為 J2EE的擴展。存在一些已知的兼容性問題，而在某些情況下，可以用特定于容器的代碼來繞過這些問題。但是，如果需要實現(xiàn)編程式事務(wù)掛起，則J2EE中的 TransactionManager是一個強大的特性。只需首先在所選擇的J2EE服務(wù)器中檢測一下它是否可用就可以了。