[發(fā)明專利]一種分布式事務(wù)處理方法及裝置

有效

• 申請?zhí)枺?/td>: 201711486720.3
• 申請日: 2017-12-29
• 公開（公告）號: CN108279986B
• 公開（公告）日: 2023-10-03
• 發(fā)明（設(shè)計）人: 郝長久;趙貴陽;周春楠
• 申請（專利權(quán)）人: 億陽安全技術(shù)有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L67/02;H04L67/566
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

1.一種分布式事務(wù)處理方法，其特征在于，所述方法應(yīng)用于消息服務(wù)器，包括：

接收第一業(yè)務(wù)端發(fā)送的第一操作的數(shù)據(jù)；

當(dāng)接收到所述第一業(yè)務(wù)端發(fā)送的第一本地事務(wù)的第一提交結(jié)果時，在所述第一提交結(jié)果為提交成功的情況下，將所述第一操作的數(shù)據(jù)發(fā)送給第二業(yè)務(wù)端；所述第二業(yè)務(wù)端包括至少一個業(yè)務(wù)端；所述第一提交結(jié)果為所述第一業(yè)務(wù)端根據(jù)所述第一操作的數(shù)據(jù)執(zhí)行第一本地事務(wù)的結(jié)果；

當(dāng)接收到任何一個第二業(yè)務(wù)端發(fā)送的第二本地事務(wù)的第二提交結(jié)果后，將所述第二提交結(jié)果對應(yīng)的處理消息反饋給其它的第二業(yè)務(wù)端和所述第一業(yè)務(wù)端，以使所述第一業(yè)務(wù)端和其它的業(yè)務(wù)端根據(jù)所述消息執(zhí)行相應(yīng)的操作；所述第二提交結(jié)果為所述第二業(yè)務(wù)端根據(jù)所述第一操作的數(shù)據(jù)執(zhí)行第二本地事務(wù)的結(jié)果。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在接收到第一業(yè)務(wù)端發(fā)送的第一操作的數(shù)據(jù)后，還包括：

建立監(jiān)聽消息隊列，所述監(jiān)聽消息隊列用于監(jiān)聽所述第一業(yè)務(wù)端和所述消息服務(wù)器的交互信息，以及所述第二業(yè)務(wù)端和所述消息服務(wù)器的交互信息，并在接收到交互信息后反饋給相應(yīng)的業(yè)務(wù)端。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，還包括：當(dāng)監(jiān)聽到所述消息服務(wù)器成功接收到了所述第一業(yè)務(wù)端的第一操作的數(shù)據(jù)后，向所述第一業(yè)務(wù)端反饋第一監(jiān)聽信息，以使所述第一業(yè)務(wù)端在接收到所述的第一監(jiān)聽信息后根據(jù)所述第一操作的數(shù)據(jù)執(zhí)行第一本地事務(wù)。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，還包括：

監(jiān)聽是否接收到所述第二業(yè)務(wù)端發(fā)送的預(yù)制結(jié)果；

當(dāng)接收到所述第二業(yè)務(wù)端發(fā)送的預(yù)制結(jié)果后，向所述第二業(yè)務(wù)端反饋第二監(jiān)聽信息，以使所述第二業(yè)務(wù)端依據(jù)所述第一操作的數(shù)據(jù)執(zhí)行第二本地事務(wù)。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，在向所述第二業(yè)務(wù)端反饋第二監(jiān)聽信息之前，所述方法還包括：

在預(yù)設(shè)的標(biāo)識數(shù)據(jù)庫中記錄所述第一操作的標(biāo)識。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述方法還包括：

在所述消息服務(wù)器重新恢復(fù)工作的情況下，獲取所述消息服務(wù)器中的所有第二操作，得到第二操作組；

將所述第二操作組與所述標(biāo)識數(shù)據(jù)庫進行差異性計算，得到所述標(biāo)識數(shù)據(jù)庫中不包含的第三操作；所述第三操作屬于第二操作組；

將所述第三操作的數(shù)據(jù)發(fā)送給所述第二業(yè)務(wù)端。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

定期查詢是否接收到第一操作的數(shù)據(jù)對應(yīng)的第一提交結(jié)果；

若未接收到所述第一操作數(shù)據(jù)對應(yīng)的第一提交結(jié)果，向所述第一業(yè)務(wù)端核查所述第一操作的數(shù)據(jù)的執(zhí)行情況。

8.根據(jù)權(quán)利要求1所述的方法，其特征在于，還包括：

定期查詢是否接收到第一操作的數(shù)據(jù)對應(yīng)的第二提交結(jié)果；

若未接收到所述第一操作數(shù)據(jù)對應(yīng)的第二提交結(jié)果，向所述第二業(yè)務(wù)端核查所述第一操作的數(shù)據(jù)的執(zhí)行情況。

9.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述當(dāng)接收到任何一個第二業(yè)務(wù)端發(fā)送的第二本地事務(wù)的第二提交結(jié)果后，將所述第二提交結(jié)果對應(yīng)的消息反饋給其它的第二業(yè)務(wù)端和所述第一業(yè)務(wù)端，以使所述第一業(yè)務(wù)端和其它的業(yè)務(wù)端根據(jù)所述消息執(zhí)行相應(yīng)的操作，包括：

當(dāng)任何一個第二業(yè)務(wù)端發(fā)送的第二本地事務(wù)的第二提交結(jié)果為駁回的情況下，向其它的第二業(yè)務(wù)端器和所述第一業(yè)務(wù)端器反饋回滾消息，以使所述其它的第二業(yè)務(wù)端器和所述第一業(yè)務(wù)端器執(zhí)行回滾操作。

10.根據(jù)權(quán)利要求1所述的方法，其特征在于，還包括：

當(dāng)向所述第一業(yè)務(wù)端器發(fā)送所述第二本地事務(wù)的執(zhí)行結(jié)果對應(yīng)的消息后，刪除所述標(biāo)識數(shù)據(jù)庫中所述第一操作的標(biāo)識。