[發(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
• 代理人: 劉翠香

本申請公開了一種OLTP模式的分布式事務(wù)處理方法，通過邏輯中心節(jié)點選擇獲取部分數(shù)量的節(jié)點ack信息作為反饋進行下一步動作，當收到超過第一預(yù)設(shè)數(shù)量的反饋ack信息就開始推送操作指令，收到超過第二預(yù)設(shè)數(shù)量的完成ack信息即判定事務(wù)完成，這一事務(wù)處理流程提高了每個節(jié)點的可用性和分區(qū)容錯性，對于OLTP模式下的圖數(shù)據(jù)庫的事務(wù)處理效率。相應(yīng)的，本申請還公開了一種OLTP模式的分布式事務(wù)處理系統(tǒng)、裝置及可讀存儲介質(zhì)。

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

本發(fā)明涉及圖數(shù)據(jù)庫領(lǐng)域，特別涉及一種OLTP模式的分布式事務(wù)處理方法、系統(tǒng)及相關(guān)組件。

背景技術(shù)

當前，目前市場上的分布式圖數(shù)據(jù)庫多種多樣，但是對OLTP(On-LineTransaction Processing，聯(lián)機事務(wù)處理過程)模式的支持卻不盡相同。使用較多的開源圖數(shù)據(jù)庫Janusgraph，支持的OLTP模式只有對單個節(jié)點進行處理這一種方案，現(xiàn)有技術(shù)中并沒有出現(xiàn)過OLTP模式的分布式事務(wù)相關(guān)處理的支持方案。

因此，如何提供一種解決上述技術(shù)問題的方案是目前本領(lǐng)域技術(shù)人員需要解決的問題。

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

有鑒于此，本發(fā)明的目的在于提供一種OLTP模式的分布式事務(wù)處理方法、系統(tǒng)及相關(guān)組件。其具體方案如下：

一種OLTP模式的分布式事務(wù)處理方法，包括：

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

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

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

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

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

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

優(yōu)選的，所述分布式事務(wù)處理方法還包括：

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

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

優(yōu)選的，所述從第三預(yù)設(shè)數(shù)量的所述節(jié)點中，確定處理進程最新的節(jié)點作為所述邏輯中心節(jié)點的過程，包括：

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

優(yōu)選的，所述確定處理進程最新的節(jié)點作為所述邏輯中心節(jié)點之后，還包括：

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

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

優(yōu)選的，所述客戶操作請求包括對屬性圖的屬性信息的修改操作請求。

優(yōu)選的，所述屬性信息包括頂點信息和/或邊信息。