from:
http://javatar.iteye.com/blog/981787關于Dubbo服務框架的分布式事務,雖然現在不急著做,但可以討論一下。
我覺得事務的管理不應該屬于Dubbo框架,
Dubbo只需實現可被事務管理即可,
像JDBC和JMS都是可被事務管理的分布式資源,
Dubbo只要實現相同的可被事務管理的行為,比如可以回滾,
其它事務的調度,都應該由專門的事務管理器實現。
在Java中,分布式事務主要的規范是JTA/XA,
其中:JTA是Java的事務管理器規范,
XA是工業標準的X/Open CAE規范,可被兩階段提交及回滾的事務資源定義,
比如某數據庫實現了XA規范,則不管是JTA,還是MSDTC,都可以基于同樣的行為對該數據庫進行事務處理。
在JTA/XA中,主要有兩個擴展點: (1) TransactionManager JTA事務管理器接口,實現該接口,即可完成對所有XA資源的事務調度,比如BEA的Tuxedo,JBossJTA等。
(2) XAResource XA資源接口,實現該接口,即可被任意TransactionManager調度,比如:JDBC的XAConnection,JMS的XAMQ等。
而Dubbo的遠程服務,也應該是一個XAResource,比如:XAInvoker和XAExporter,
Dubbo只需在第一次提交時,將請求發到服務提供方進行緩存和寫盤,
在第二次提交時,再基于緩存調用服務的Impl實現,
當然一些健狀性分支流程要考慮清楚。
JTA/XA的基本原理如下:
1. 用戶啟動一個事務:
Java代碼

- transactionManager.begin();
2. 事務管理器在當前線程中初始化一個事務實例:
Java代碼

- threadLocal.set(new TransactionImpl());
3. 用戶調用JDBC或JMS或Dubbo請求,請求內部初始化一個XAResource實例:
Java代碼

- XAResource xaResource = new XAResourceImpl(); // 比如:XAConnection
4. JDBC或JMS或Dubbo內部從當前線程獲取事務:
Java代碼

- Transaction transaction = transactionManager.getTransaction(); // 其內部為:threadLocal.get();
5. 將當前XAResource注冊到事務中:
Java代碼

- transaction.enlistResource(xaResource);
6. 用戶提交一個事務:
Java代碼

- transactionManager.commit(); // 其內部為:getTransaction().commit();
7. 事務for循環調用所有注冊的XAResource的兩階段提交:
Java代碼

- Xid xid = new XidImpl();
- for (XAResource xaResource: xaResources) {
- xaResource.prepare(xid);
- xaResource.commit(xid, true);
- xaResource.commit(xid, false);
- }
8. 當然,還有一些異常流程,比如rollback和forget等。
舉例:
Java代碼

- TransactionManager transactionManager = ...; // 從JNDI進行lookup等方式獲取
- transactionManager.begin(); // 啟動事務
- try {
- jdbcConn.executeUpdate(sql); // 執行SQL語句,DB寫入binlog,但不更新表
- jmsMQ.send(message); // 發送消息,MQ記錄消息,但不進入隊列
- dubboService.invoke(parameters); // 調用遠程服務,Provider緩存請求信息,但不執行
- transactionManager.commit(); // 提交事務,數據庫,消息隊列,遠程服務同時提交
- } catch(Throwable t) {
- transactionManager.rollback(); // 回滾事務,數據庫,消息隊列,遠程服務同時回滾
- }