[發(fā)明專利]一種實(shí)現(xiàn)分布式事務(wù)的方法和裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201310655744.2
• 申請(qǐng)日: 2013-12-06
• 公開(kāi)（公告）號(hào): CN103631647A
• 公開(kāi)（公告）日: 2014-03-12
• 發(fā)明（設(shè)計(jì)）人: 郭永強(qiáng);易旭
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46
• 代理公司: 北京德琦知識(shí)產(chǎn)權(quán)代理有限公司 11018
• 代理人: 閻敏;宋志強(qiáng)

技術(shù)領(lǐng)域

本發(fā)明涉及分布式事務(wù)技術(shù)領(lǐng)域，尤其涉及一種實(shí)現(xiàn)分布式事務(wù)的方法和裝置。

背景技術(shù)

當(dāng)前企業(yè)級(jí)的應(yīng)用中，有很多的系統(tǒng)涉及到多個(gè)數(shù)據(jù)源，針對(duì)多個(gè)數(shù)據(jù)源的處理就要涉及到分布式事務(wù)；分布式事務(wù)實(shí)現(xiàn)的好與壞，直接影響到該企業(yè)級(jí)應(yīng)用的性能以及用戶體驗(yàn)。

現(xiàn)有的實(shí)現(xiàn)分布式事務(wù)的解決方案之一是利用一些商用的應(yīng)用服務(wù)器來(lái)實(shí)現(xiàn)，比如WebSphere。

另外一種普遍的分布式事務(wù)解決方案是將涉及到多個(gè)數(shù)據(jù)源的操作封裝為一個(gè)大的事務(wù)，如圖1所示。啟動(dòng)事務(wù)后，順序進(jìn)行涉及多個(gè)數(shù)據(jù)源的多個(gè)操作，如果在這多個(gè)操作中出現(xiàn)操作失敗或者是出現(xiàn)異常，則回滾該事務(wù)。

上述兩種分布式事務(wù)實(shí)現(xiàn)方案的缺點(diǎn)是：

第一種，利用商用的應(yīng)用服務(wù)器實(shí)現(xiàn)分布式事務(wù)，需要購(gòu)買商用應(yīng)用服務(wù)器的授權(quán)，代價(jià)相對(duì)昂貴。

第二種，利用將涉及多個(gè)數(shù)據(jù)源的多個(gè)操作封裝為一個(gè)事務(wù)的方式雖然能夠?qū)崿F(xiàn)分布式事務(wù)，但是針對(duì)不同數(shù)據(jù)源的多個(gè)操作必須順序執(zhí)行，整個(gè)系統(tǒng)的性能會(huì)因此受到影響。

發(fā)明內(nèi)容

本發(fā)明提供了一種實(shí)現(xiàn)分布式事務(wù)的方法，能夠?qū)崿F(xiàn)針對(duì)多個(gè)數(shù)據(jù)源的事務(wù)并發(fā)進(jìn)行，且無(wú)需使用專門(mén)的商用應(yīng)用服務(wù)器。

本發(fā)明提供了一種實(shí)現(xiàn)分布式事務(wù)的裝置，能夠?qū)崿F(xiàn)針對(duì)多個(gè)數(shù)據(jù)源的事務(wù)并發(fā)進(jìn)行，且無(wú)需使用專門(mén)的商用應(yīng)用服務(wù)器。

本發(fā)明的技術(shù)方案是這樣實(shí)現(xiàn)的：

一種實(shí)現(xiàn)分布式事務(wù)的方法，包括：

設(shè)置N個(gè)子線程，每個(gè)子線程負(fù)責(zé)處理分布式事務(wù)中的一個(gè)事務(wù)；其中，各個(gè)事務(wù)針對(duì)不同的數(shù)據(jù)源，每個(gè)事務(wù)包括針對(duì)該數(shù)據(jù)源的一個(gè)以上操作；

初始化CountDownLatch類，將所述CountDownLatch類計(jì)數(shù)器的初始值設(shè)置為N；

主線程調(diào)用CountDownLatch類的await方法；

分別啟動(dòng)所述N個(gè)子線程；當(dāng)一個(gè)子線程執(zhí)行完成時(shí)，調(diào)用CountDownLatch類的countDown方法，使得所述CountDownLatch類計(jì)數(shù)器的值減1；

當(dāng)所述CountDownLatch類計(jì)數(shù)器的值為0時(shí)，繼續(xù)執(zhí)行所述主線程。

上述方法可以進(jìn)一步包括：當(dāng)一個(gè)子線程執(zhí)行出現(xiàn)異常時(shí)，將已經(jīng)執(zhí)行完畢的所有子線程回滾，并將所述CountDownLatch類計(jì)數(shù)器的值設(shè)置為0。

當(dāng)所有子線程執(zhí)行完成并且CountDownLatch類的計(jì)數(shù)器減至0時(shí)，記錄所述分布式事務(wù)為成功狀態(tài)；

當(dāng)子線程執(zhí)行出現(xiàn)異常時(shí)，記錄所述分布式事務(wù)為失敗狀態(tài)。

一種實(shí)現(xiàn)分布式事務(wù)的裝置，包括：

初始化模塊，用于設(shè)置N個(gè)子線程，每個(gè)子線程負(fù)責(zé)處理分布式事務(wù)中的一個(gè)事務(wù)；其中，各個(gè)事務(wù)針對(duì)不同的數(shù)據(jù)源，每個(gè)事務(wù)包括針對(duì)該數(shù)據(jù)源的一個(gè)以上操作；還用于初始化CountDownLatch類，將所述CountDownLatch類計(jì)數(shù)器的初始值設(shè)置為N；

主線程控制模塊，用于控制主線程調(diào)用CountDownLatch類的await方法，當(dāng)所述CountDownLatch類計(jì)數(shù)器的值為0時(shí)，繼續(xù)執(zhí)行所述主線程；

子線程控制模塊，用于分別啟動(dòng)所述N個(gè)子線程；當(dāng)一個(gè)子線程執(zhí)行完成時(shí)，調(diào)用CountDownLatch類的countDown方法，使得所述CountDownLatch類計(jì)數(shù)器的值減1。

上述裝置中，子線程控制模塊還可以用于，當(dāng)一個(gè)子線程執(zhí)行出現(xiàn)異常時(shí)，將已經(jīng)執(zhí)行完畢的所有子線程回滾，并將所述CountDownLatch類計(jì)數(shù)器的值設(shè)置為0。

當(dāng)所有子線程執(zhí)行完成并且CountDownLatch類的計(jì)數(shù)器減至0時(shí)，記錄所述分布式事務(wù)為成功狀態(tài)；當(dāng)子線程執(zhí)行出現(xiàn)異常時(shí)，記錄所述分布式事務(wù)為失敗狀態(tài)。

可見(jiàn)，本發(fā)明提出的實(shí)現(xiàn)分布式事務(wù)的方法和裝置，設(shè)置N個(gè)子線程，每個(gè)子線程負(fù)責(zé)處理分布式事務(wù)中的一個(gè)事務(wù)，并且通過(guò)CountDownLatch類來(lái)實(shí)現(xiàn)N個(gè)子線程同步執(zhí)行，從而實(shí)現(xiàn)了針對(duì)多個(gè)數(shù)據(jù)源的多個(gè)分布式事務(wù)并發(fā)進(jìn)行。

附圖說(shuō)明

圖1為現(xiàn)有技術(shù)中分布式事務(wù)的實(shí)現(xiàn)方式；

圖2為本發(fā)明提出的實(shí)現(xiàn)分布式事務(wù)的方法流程圖；

圖3為本發(fā)明實(shí)施例一的實(shí)現(xiàn)流程圖。

具體實(shí)施方式

本發(fā)明提出一種實(shí)現(xiàn)分布式事務(wù)的方法，如圖2為該方法實(shí)現(xiàn)流程圖，包括：