[發明專利]分布式事務處理方法及分布式系統

有效

• 申請號: 201810204077.9
• 申請日: 2018-03-13
• 公開（公告）號: CN108491252B
• 公開（公告）日: 2022-03-22
• 發明（設計）人: 紀少聰
• 申請（專利權）人: 萬惠投資管理有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京超凡志成知識產權代理事務所(普通合伙) 11371
• 代理人: 鄧超

本發明實施例提供一種分布式事務處理方法及分布式系統。所述分布式事務處理方法包括：協調子系統向管理子系統發送事務標識申請，以獲取事務標識，并向執行子系統發送帶有所述目標事務標識的執行請求；所述執行子系統接收到所述執行請求后，執行對所述執行請求對應的數據進行修改操作，對修改的數據進行緩存得到緩存數據；所述執行子系統將執行結果返回給所述協調子系統；所述協調子系統根據每個執行子系統執行結果向所述管理子系統發送所述目標事務標識對應的事務狀態的更改請求，以將所述事務狀態更改為結果狀態；以及所述執行子系統從所述管理子系統中獲取所述事務狀態，根據所述事務狀態對該事務標識對應的所述緩存數據進行提交或回滾操作。

技術領域

本發明涉及計算機技術領域，具體而言，涉及一種分布式事務處理方法及分布式系統。

背景技術

為了緩解單機系統的性能壓力與減少系統大小，一種有效的方式是將系統拆分成多個子系統，由這些子系統組合成的大系統，是分布式系統的一種形式。分布式事務的目的是，在大系統的一個業務操作中多個子系統的執行結果能成功或者失敗。分布式事務最基本的解決方案是“二階段提交協議”。“二階段提交協議”有兩個階段：“準備”階段與“提交/回滾”階段。其中“提交/回滾”階段是在整個事務結束時執行的，其缺點是如果系統在這個環節因為宕機或重啟等原因導致系統強制關閉，則無法達到該方案的最終效果，而且未執行“提交/回滾”階段，被修改的數據是未進行確認的，可能被其他業務操作使用，如果這些數據是錯誤的，卻未被“回滾”，則會導致系統的錯誤。造成上述問題的原因是，“提交/回滾”階段是主動的。這種主動的方式并不能應對因為宕機或重啟等原因導致系統強制關閉所造成的影響。

發明內容

有鑒于此，本發明實施例的目的在于提供一種分布式事務處理方法及分布式系統。

本發明實施例提供的一種分布式事務處理方法，應用于分布式系統，所述分布式系統包括相互通信的協調子系統、管理子系統及執行子系統；所述分布式事務處理方法包括：

所述協調子系統向所述管理子系統發送事務標識申請，以獲取目標事務標識，并向所述執行子系統發送帶有所述目標事務標識的執行請求；

所述執行子系統接收到所述執行請求后，執行所述執行請求對應的事務；

所述執行子系統在對所述執行請求對應的數據進行修改時，對修改的數據進行緩存得到緩存數據；

所述執行子系統將執行結果返回給所述協調子系統；

所述協調子系統根據每個執行子系統執行結果向所述管理子系統發送所述目標事務標識對應的事務狀態的更改請求，以將所述事務狀態更改為結果狀態，所述結果狀態包括成功和失敗；以及

所述執行子系統從所述管理子系統中獲取所述事務狀態，根據所述事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作。

本發明實施例還提供一種分布式系統，所述分布式系統包括相互通信的協調子系統、管理子系統及執行子系統；

所述協調子系統用于向所述管理子系統發送事務標識申請，以獲取目標事務標識，并向所述執行子系統發送帶有所述目標事務標識的執行請求；

所述執行子系統用于接收到所述執行請求后，執行所述執行請求對應的事務；

所述執行子系統還用于在對所述執行請求對應的數據進行修改時，對修改的數據進行緩存得到緩存數據；

所述執行子系統還用于將執行結果返回給所述協調子系統；

所述協調子系統還用于根據每個執行子系統執行結果得到統計結果，向所述管理子系統提交統計結果；

所述管理子系統用于根據所述統計結果更改所述事務狀態為結果狀態，所述結果狀態包括成功和失敗；以及