[發(fā)明專利]分布式事務(wù)處理方法、裝置、計算機設(shè)備及可讀存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010595057.6
• 申請日: 2020-06-28
• 公開（公告）號: CN111722946A
• 公開（公告）日: 2020-09-29
• 發(fā)明（設(shè)計）人: 楊哲
• 申請（專利權(quán)）人: 深圳壹賬通智能科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/27
• 代理公司: 北京英特普羅知識產(chǎn)權(quán)代理有限公司 11015
• 代理人: 程超

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

監(jiān)測事務(wù)發(fā)起端是否開啟本地事務(wù)，若是，則調(diào)用AOP組件攔截所述本地事務(wù)并將其寫入預(yù)設(shè)的事務(wù)表中；

監(jiān)聽事務(wù)發(fā)起端是否調(diào)用RPC并生成RPC請求，若是，則調(diào)用AOP組件攔截所述RPC請求并將其寫入預(yù)設(shè)的方法表中；

根據(jù)所述RPC請求通過事務(wù)管理器調(diào)用遠(yuǎn)程設(shè)備運算所述本地事務(wù)；

判斷是否在預(yù)設(shè)的監(jiān)聽時間內(nèi)接收到所述遠(yuǎn)程設(shè)備發(fā)送的運算結(jié)果；若未收到運算結(jié)果或接收到所述遠(yuǎn)程設(shè)備發(fā)送的提交失敗信息，則通過事務(wù)管理器調(diào)用回滾線程，以根據(jù)RPC請求調(diào)用遠(yuǎn)程設(shè)備運算所述本地事務(wù)并生成運算結(jié)果；若接收到所述運算結(jié)果，則刪除事務(wù)表中的本地事務(wù)以及方法表中RPC請求，并將所述運算結(jié)果發(fā)送至所述事務(wù)發(fā)起端。

2.根據(jù)權(quán)利要求1所述的分布式事務(wù)處理方法，其特征在于，監(jiān)測事務(wù)發(fā)起端是否開啟本地事務(wù)之前，包括：

構(gòu)建事務(wù)管理器和AOP組件的spring框架，及具有事務(wù)表和方法表的數(shù)據(jù)庫。

3.根據(jù)權(quán)利要求1所述的分布式事務(wù)處理方法，其特征在于，調(diào)用AOP組件攔截所述RPC請求并將其寫入預(yù)設(shè)的方法表中之后，包括：

根據(jù)所述RPC請求調(diào)用遠(yuǎn)程設(shè)備以判斷所有遠(yuǎn)程設(shè)備是否均準(zhǔn)備就緒；若所有遠(yuǎn)程設(shè)備均準(zhǔn)備就緒，則提取即時執(zhí)行線程；若至少一個遠(yuǎn)程設(shè)備未準(zhǔn)備就緒，則提取延時判斷線程。

4.根據(jù)權(quán)利要求1所述的分布式事務(wù)處理方法，其特征在于，根據(jù)所述RPC請求通過事務(wù)管理器調(diào)用遠(yuǎn)程設(shè)備運算所述本地事務(wù)的步驟，包括：

提取RPC請求中的主機信息，并獲得與所述主機信息對應(yīng)的遠(yuǎn)程設(shè)備，調(diào)用事務(wù)管理器將所述本地事務(wù)提交至所述遠(yuǎn)程設(shè)備；

提取RPC請求中的調(diào)用信息，按照所述調(diào)用信息調(diào)用所述遠(yuǎn)程設(shè)備運算所述本地事務(wù)并生成運算結(jié)果；其中，所述調(diào)用信息中記載有對遠(yuǎn)程設(shè)備的調(diào)用方法；

在所述生成運算結(jié)果之后，還包括：

將所述運算結(jié)果上傳至區(qū)塊鏈中。

5.根據(jù)權(quán)利要求3所述的分布式事務(wù)處理方法，其特征在于，提取延時判斷線程之后，包括：

調(diào)用延時判斷線程，以經(jīng)過預(yù)設(shè)的延遲時間后，再次根據(jù)所述RPC請求調(diào)用遠(yuǎn)程設(shè)備以判斷所有遠(yuǎn)程設(shè)備是否均準(zhǔn)備就緒。

6.根據(jù)權(quán)利要求1所述的分布式事務(wù)處理方法，其特征在于，所述回滾線程包括以下步驟：

提取事務(wù)表中的本地事務(wù)，及提取方法表中的RPC請求；

提取RPC請求中的主機信息，并獲得與所述主機信息對應(yīng)的遠(yuǎn)程設(shè)備，調(diào)用事務(wù)管理器將所述本地事務(wù)提交至所述遠(yuǎn)程設(shè)備；

提取RPC請求中的調(diào)用信息，按照所述調(diào)用信息調(diào)用所述遠(yuǎn)程設(shè)備運算所述本地事務(wù)并生成運算結(jié)果；其中，所述調(diào)用信息中記載有對遠(yuǎn)程設(shè)備的調(diào)用方法；

在所述生成運算結(jié)果之后，還包括：

將所述運算結(jié)果上傳至區(qū)塊鏈中。

7.根據(jù)權(quán)利要求1所述的分布式事務(wù)處理方法，其特征在于，通過事務(wù)管理器調(diào)用回滾線程之后，還包括：

記錄所述回滾線程的調(diào)用次數(shù)，并判斷提交次數(shù)是否超過預(yù)設(shè)的重試閾值；若是，則再次執(zhí)行回滾線程；若否，則生成報警信息。

8.一種分布式事務(wù)處理裝置，其特征在于，包括：

監(jiān)測模塊，用于監(jiān)測事務(wù)發(fā)起端是否開啟本地事務(wù)，若是，則調(diào)用AOP組件攔截所述本地事務(wù)并將其寫入預(yù)設(shè)的事務(wù)表中；

監(jiān)聽模塊，用于監(jiān)聽事務(wù)發(fā)起端是否調(diào)用RPC并生成RPC請求，若是，則調(diào)用AOP組件攔截所述RPC請求并將其寫入預(yù)設(shè)的方法表中；

調(diào)用模塊，用于根據(jù)所述RPC請求通過事務(wù)管理器調(diào)用遠(yuǎn)程設(shè)備運算所述本地事務(wù)；

判斷模塊，用于判斷是否在預(yù)設(shè)的監(jiān)聽時間內(nèi)接收到所述遠(yuǎn)程設(shè)備發(fā)送的運算結(jié)果；若未收到運算結(jié)果或接收到所述遠(yuǎn)程設(shè)備發(fā)送的提交失敗信息，則通過事務(wù)管理器調(diào)用回滾線程，以根據(jù)RPC請求調(diào)用遠(yuǎn)程設(shè)備運算所述本地事務(wù)并生成運算結(jié)果；若接收到所述運算結(jié)果，則刪除事務(wù)表中的本地事務(wù)以及方法表中RPC請求，并將所述運算結(jié)果發(fā)送至所述事務(wù)發(fā)起端。