[發明專利]一種分布式事務提交方法及裝置

有效

• 申請號: 201910779564.2
• 申請日: 2019-08-22
• 公開（公告）號: CN110532069B
• 公開（公告）日: 2021-06-29
• 發明（設計）人: 易存道
• 申請（專利權）人: 北京寶蘭德軟件股份有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 苗曉靜

1.一種分布式事務提交方法，其特征在于，包括：

接收到提交全局事務的請求后，參與所述全局事務的所有XA資源，依次采用一階段事務提交的方式將與所述全局事務有關的修改提交到所在XA資源的主節點中，在所在XA資源的讀寫分離代理的事務日志中記錄反向操作，所述反向操作用于還原對所在XA資源的修改；其中，所述XA資源至少包括：用于數據修改操作的主節點、用于數據查詢操作的從節點、用于控制讀寫分離和數據同步的讀寫分離代理；所述讀寫分離代理包括用于記錄對所述主節點或從節點所做操作的事務日志；

參與所述全局事務的所有XA資源均成功提交所述全局事務后，在參與所述全局事務的各個XA資源中，將所述反向操作從所在XA資源的讀寫分離代理的事務日志中清除，通知所在XA資源的主節點將所述全局事務的提交同步到所在XA資源的從節點中。

2.根據權利要求1所述的分布式事務提交方法，其特征在于，還包括：

參與所述全局事務的任一XA資源提交所述全局事務失敗，在參與所述全局事務的各個XA資源中，若所在XA資源尚未提交所述全局事務，直接丟棄該全局事務劃分原子操作相關的改動；若所在XA資源已經提交所述全局事務，從所在XA資源的讀寫分離代理的事務日志中讀取所述全局事務對應的反向操作，在所在XA資源的主節點中執行該反向操作，還原對所在XA資源的修改。

3.根據權利要求2所述的分布式事務提交方法，其特征在于，所述原子操作包括單個XA資源的原子操作、全局事務的原子操作；所述單個XA資源的原子操作為XAResouce.start()調用之后、XAResrouce.end()調用之前的操作；所述全局事務的原子操作為參與全局事務的每個XA資源上的原子操作的合集。

4.根據權利要求1或2所述的分布式事務提交方法，其特征在于，所述一階段事務提交的方式采用XAResource.commitOnePhase來提交當前XA資源所要執行的事務，如果提交成功，則整個當前XA資源所要執行的事務提交完成，如果提交失敗，則整個當前XA資源所要執行的事務回滾完成。

5.一種分布式事務提交裝置，其特征在于，包括：

事務提交單元，用于接收到提交全局事務的請求后，參與所述全局事務的所有XA資源，依次采用一階段事務提交的方式將與所述全局事務有關的修改提交到所在XA資源的主節點中，在所在XA資源的讀寫分離代理的事務日志中記錄反向操作，所述反向操作用于還原對所在XA資源的修改；其中，所述XA資源至少包括：用于數據修改操作的主節點、用于數據查詢操作的從節點、用于控制讀寫分離和數據同步的讀寫分離代理；所述讀寫分離代理包括用于記錄對所述主節點或從節點所做操作的事務日志；

事務提交成功后處理單元，用于參與所述全局事務的所有XA資源均成功提交所述全局事務后，在參與所述全局事務的各個XA資源中，將所述反向操作從所在XA資源的讀寫分離代理的事務日志中清除，通知所在XA資源的主節點將所述全局事務的提交同步到所在XA資源的從節點中。

6.根據權利要求5所述的分布式事務提交裝置，其特征在于，還包括：

回滾單元，用于參與所述全局事務的任一XA資源提交所述全局事務失敗，在參與所述全局事務的各個XA資源中，若所在XA資源尚未提交所述全局事務，直接丟棄該全局事務劃分原子操作相關的改動；若所在XA資源已經提交所述全局事務，從所在XA資源的讀寫分離代理的事務日志中讀取所述全局事務對應的反向操作，在所在XA資源的主節點中執行該反向操作，還原對所在XA資源的修改。

7.根據權利要求6所述的分布式事務提交裝置，其特征在于，所述原子操作包括單個XA資源的原子操作、全局事務的原子操作；所述單個XA資源的原子操作為XAResouce.start()調用之后、XAResrouce.end()調用之前的操作；所述全局事務的原子操作為參與全局事務的每個XA資源上的原子操作的合集。