[發(fā)明專利]一種OLTP模式的分布式事務(wù)處理方法、系統(tǒng)及相關(guān)組件

在審

• 申請?zhí)枺?/td>: 202011600837.1
• 申請日: 2020-12-29
• 公開（公告）號: CN112732414A
• 公開（公告）日: 2021-04-30
• 發(fā)明（設(shè)計）人: 高艷濤;張海川
• 申請（專利權(quán)）人: 北京浪潮數(shù)據(jù)技術(shù)有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/54;G06F16/27
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 劉翠香

1.一種OLTP模式的分布式事務(wù)處理方法，其特征在于，包括：

將收到客戶操作請求的節(jié)點(diǎn)作為源節(jié)點(diǎn)，通過所述源節(jié)點(diǎn)向邏輯中心節(jié)點(diǎn)發(fā)送事務(wù)ID請求，以使所述邏輯中心節(jié)點(diǎn)返回按照全局變量的遞增順序分配的事務(wù)ID；

當(dāng)所述源節(jié)點(diǎn)收到所述事務(wù)ID，通過所述源節(jié)點(diǎn)向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述客戶操作請求的修改信息日志，并通過所述邏輯中心節(jié)點(diǎn)向所有所述節(jié)點(diǎn)推送所述修改信息日志；

當(dāng)任一所述節(jié)點(diǎn)接收到所述修改日志信息，通過該節(jié)點(diǎn)向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述修改信息日志的反饋ack信息；

當(dāng)所述邏輯中心節(jié)點(diǎn)收到的所述反饋ack信息的數(shù)量超過第一預(yù)設(shè)數(shù)量，通過所述邏輯中心節(jié)點(diǎn)向所有所述節(jié)點(diǎn)推送對應(yīng)所述客戶操作請求的操作指令；

當(dāng)任一所述節(jié)點(diǎn)接收到所述操作指令，通過該節(jié)點(diǎn)執(zhí)行所述操作指令并向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述操作指令的完成ack信息；

當(dāng)所述邏輯中心節(jié)點(diǎn)收到的所述完成ack信息的數(shù)量超過第二預(yù)設(shè)數(shù)量，通過所述邏輯中心節(jié)點(diǎn)標(biāo)記所述事務(wù)ID對應(yīng)的事務(wù)已完成。

2.根據(jù)權(quán)利要求1所述分布式事務(wù)處理方法，其特征在于，還包括：

通過zookeeper服務(wù)，監(jiān)測所述邏輯中心節(jié)點(diǎn)是否有效；

當(dāng)所述邏輯中心節(jié)點(diǎn)失效，從第三預(yù)設(shè)數(shù)量的所述節(jié)點(diǎn)中，確定處理進(jìn)程最新的節(jié)點(diǎn)作為所述邏輯中心節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求2所述分布式事務(wù)處理方法，其特征在于，所述從第三預(yù)設(shè)數(shù)量的所述節(jié)點(diǎn)中，確定處理進(jìn)程最新的節(jié)點(diǎn)作為所述邏輯中心節(jié)點(diǎn)的過程，包括：

從第三預(yù)設(shè)數(shù)量的所述節(jié)點(diǎn)中，獲取各所述節(jié)點(diǎn)的已完成事務(wù)的最新事務(wù)ID，并確定數(shù)值最大的最新事務(wù)ID對應(yīng)的所述節(jié)點(diǎn)作為所述邏輯中心節(jié)點(diǎn)。

4.根據(jù)權(quán)利要求3所述分布式事務(wù)處理方法，其特征在于，所述確定處理進(jìn)程最新的節(jié)點(diǎn)作為所述邏輯中心節(jié)點(diǎn)之后，還包括：

當(dāng)所述邏輯中心節(jié)點(diǎn)存在待處理事務(wù)，通過所述邏輯中心節(jié)點(diǎn)向所有所述節(jié)點(diǎn)推送對應(yīng)所述待處理事務(wù)的回滾指令；

當(dāng)任一所述節(jié)點(diǎn)接收到所述回滾指令，通過該節(jié)點(diǎn)執(zhí)行所述回滾指令，并向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述回滾指令的回滾ack信息。

5.根據(jù)權(quán)利要求1至4任一項所述分布式事務(wù)處理方法，其特征在于，所述客戶操作請求包括對屬性圖的屬性信息的修改操作請求。

6.根據(jù)權(quán)利要求5所述分布式事務(wù)處理方法，其特征在于，所述屬性信息包括頂點(diǎn)信息和/或邊信息。

7.根據(jù)權(quán)利要求6所述分布式事務(wù)處理方法，其特征在于，所述第一預(yù)設(shè)數(shù)量和所述第二預(yù)設(shè)數(shù)量具體為所有所述節(jié)點(diǎn)的數(shù)量的一半。

8.一種OLTP模式的分布式事務(wù)處理系統(tǒng)，其特征在于，包括：

ID請求模塊，用于將收到客戶操作請求的節(jié)點(diǎn)作為源節(jié)點(diǎn)，通過所述源節(jié)點(diǎn)向邏輯中心節(jié)點(diǎn)發(fā)送事務(wù)ID請求，以使所述邏輯中心節(jié)點(diǎn)返回按照全局變量的遞增順序分配的事務(wù)ID；

日志發(fā)出模塊，用于當(dāng)所述源節(jié)點(diǎn)收到所述事務(wù)ID，通過所述源節(jié)點(diǎn)向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述客戶操作請求的修改信息日志，并通過所述邏輯中心節(jié)點(diǎn)向所有所述節(jié)點(diǎn)推送所述修改信息日志；

第一反饋模塊，用于當(dāng)任一所述節(jié)點(diǎn)接收到所述修改日志信息，通過該節(jié)點(diǎn)向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述修改信息日志的反饋ack信息；

指令發(fā)出模塊，用于當(dāng)所述邏輯中心節(jié)點(diǎn)收到的所述反饋ack信息的數(shù)量超過第一預(yù)設(shè)數(shù)量，通過所述邏輯中心節(jié)點(diǎn)向所有所述節(jié)點(diǎn)推送對應(yīng)所述客戶操作請求的操作指令；

第二反饋模塊，用于當(dāng)任一所述節(jié)點(diǎn)接收到所述操作指令，通過該節(jié)點(diǎn)執(zhí)行所述操作指令并向所述邏輯中心節(jié)點(diǎn)發(fā)送對應(yīng)所述操作指令的完成ack信息；

標(biāo)記模塊，用于當(dāng)所述邏輯中心節(jié)點(diǎn)收到的所述完成ack信息的數(shù)量超過第二預(yù)設(shè)數(shù)量，通過所述邏輯中心節(jié)點(diǎn)標(biāo)記所述事務(wù)ID對應(yīng)的事務(wù)已完成。