[發明專利]分布式事務處理方法、裝置、計算機設備及可讀存儲介質

在審

• 申請號: 202010595057.6
• 申請日: 2020-06-28
• 公開（公告）號: CN111722946A
• 公開（公告）日: 2020-09-29
• 發明（設計）人: 楊哲
• 申請（專利權）人: 深圳壹賬通智能科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/27
• 代理公司: 北京英特普羅知識產權代理有限公司 11015
• 代理人: 程超

本發明涉及云存儲技術，公開了分布式事務處理方法、裝置、計算機設備及可讀存儲介質，包括：調用AOP組件攔截本地事務并將其寫入預設的事務表中；調用AOP組件攔截RPC請求并將其寫入預設的方法表中；通過事務管理器調用遠程設備運算本地事務；判斷是否接收到遠程設備發送的運算結果；若未收到運算結果或接收到遠程設備發送的提交失敗信息，則通過事務管理器調用回滾線程；若接收到運算結果，則刪除本地事務及RPC請求，并將運算結果發送至事務發起端。本發明降低了系統耦合性，避免了業務代碼的入侵以及因頻繁交互而造成效率低下的情況發生；保證了提交本地事務及調用遠程設備的穩定性和可靠性，及獲得運算結果的原子性和一致性。

技術領域

本發明涉及云存儲技術領域，尤其涉及一種分布式事務處理方法、裝置、計算機設備及可讀存儲介質。

背景技術

隨著IT系統的復雜性越來越高，微服務架構下，子系統的數量也就越來越多。在進行業務操作時，一個請求后面往往需要通過多個子系統的協同合作才能完成一系列依賴服務的有序推進。尤其對于有狀態服務，在分布式環境下，多系統多狀態的協同轉換，如何保證各子系統的狀態一致性和數據的有效性是當前分布式事務亟待解決的問題。

業界針對分布式事務已有多套解決方案，XA協議、兩階段提交、三階段提交、TCC等主流方能，能夠解決大部分分布式事務的需求。

然而，這些方案一般都會出現系統耦合性強、代碼侵入性高的問題，并且，一旦服務器向遠程設備提交失敗，則還會觸發事務發起端再次發送本地事務和RPC請求，導致事務發起端與服務器之間頻繁交互本地事務和RPC請求而造成系統效率低下。

發明內容

本發明的目的是提供一種分布式事務處理方法、裝置、計算機設備及可讀存儲介質，用于解決現有技術存在的系統耦合性強、代碼侵入性高，以及事務發起端與服務器之間頻繁交互本地事務和RPC請求而造成系統效率低下的問題；本申請可應用于智慧政務場景中，從而推動智慧城市的建設。

為實現上述目的，本發明提供一種分布式事務處理方法，包括：

監測事務發起端是否開啟本地事務，若是，則調用AOP組件攔截所述本地事務并將其寫入預設的事務表中；

監聽事務發起端是否調用RPC并生成RPC請求，若是，則調用AOP組件攔截所述RPC請求并將其寫入預設的方法表中；

根據所述RPC請求通過事務管理器調用遠程設備運算所述本地事務；

判斷是否在預設的監聽時間內接收到所述遠程設備發送的運算結果；若未收到運算結果或接收到所述遠程設備發送的提交失敗信息，則通過事務管理器調用回滾線程，以根據RPC請求調用遠程設備運算所述本地事務并生成運算結果；若接收到所述運算結果，則刪除事務表中的本地事務以及方法表中RPC請求，并將所述運算結果發送至所述事務發起端。

上述方案中，監測事務發起端是否開啟本地事務之前，包括：

構建事務管理器和AOP組件的spring框架，及具有事務表和方法表的數據庫。

上述方案中，調用AOP組件攔截所述RPC請求并將其寫入預設的方法表中之后，包括：

根據所述RPC請求調用遠程設備以判斷所有遠程設備是否均準備就緒；若所有遠程設備均準備就緒，則提取即時執行線程；若至少一個遠程設備未準備就緒，則提取延時判斷線程。

上述方案中，根據所述RPC請求通過事務管理器調用遠程設備運算所述本地事務的步驟，包括：

提取RPC請求中的主機信息，并獲得與所述主機信息對應的遠程設備，調用事務管理器將所述本地事務提交至所述遠程設備；

提取RPC請求中的調用信息，按照所述調用信息調用所述遠程設備運算所述本地事務并生成運算結果；其中，所述調用信息中記載有對遠程設備的調用方法；