[發明專利]一種云數據庫中分布式事務的實現方法

在審

• 申請號: 201310556809.8
• 申請日: 2013-11-12
• 公開（公告）號: CN103577588A
• 公開（公告）日: 2014-02-12
• 發明（設計）人: 馬軍;石輝;裴文斌;曹玉清;王俊民
• 申請（專利權）人: 西安雷迪維護系統設備有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;H04L29/08
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種云數據庫中分布式事務的實現方法，其特征在于，以一個節點組為一個節點組池，每個節點組里包括至少2個數據相同的數據節點，包括以下步驟：

步驟一、代理端根據客戶端的請求開啟事務交易存儲器、事務交易結果分析器、事務交易控制器；所述事務交易存儲器用于存儲客戶端下發的命令、所述事務交易結果分析器用于分析數據節點執行命令的結果；所述事務交易控制器用于控制各個數據節點的分布式事務、以及用于調取事務交易存儲器存儲的命令、調取事務交易結果分析器的分析結果；

步驟二、事務交易控制器判斷節點組中是否有未開啟過分布式事務的數據節點；如果有，事務交易控制器從節點組中任意選取一個未開啟過分布式事務的數據節點并進入步驟三；如果無，則對外宣布失敗；

步驟三、事務交易控制器判斷被選取的數據節點將要執行的命令是之前出錯需要重新執行的命令還是一條新的命令將要執行，如果是一條新的命令將要執行，則進入步驟四；如果是之前出錯需要重新執行的命令，那么事務交易控制器從事務交易存儲器中取出客戶端之前下發給該數據節點所屬的節點組的所有命令，并按客戶端下發的順序將這些命令重新下發給新選取的未開啟過分布式事務的數據節點，然后進入步驟五；

步驟四、事務交易控制器將命令下發至被選取的數據節點并將該條命令通過事務交易存儲器進行存儲；

步驟五、數據節點執行下發的命令并將執行的結果返回給事務交易控制器；

步驟六、事務交易控制器調取事務交易結果分析器，通過事務交易結果分析器按照預先設定的規則判斷該被選取的數據節點執行命令是否成功，若成功，事務交易控制器給客戶端一個命令執行成功的響應，然后進入步驟七；若不成功，則返回步驟二；

步驟七、在上一條命令執行成功的數據節點的基礎上，根據客戶端逐次下發的命令逐次反復執行步驟二至六，直到所有的命令下發完畢；

步驟八、事務交易控制器根據客戶端下發的提交命令調取事務交易結果分析器，通過交易結果分析器按照預先設定的規則判斷數據節點執行提交命令是否成功，若成功，則進入步驟九；若不成功，返回步驟二；

步驟九、事務交易控制器給客戶端一個提交命令成功的響應。

2.根據權利要求1所述的云數據庫中分布式事務的實現方法，其特征在于，以至少2個節點組為一個節點組池，每個節點組里包括至少2個數據相同的數據節點，所述步驟一包括代理端根據客戶端的請求開啟事務交易存儲器、事務交易結果分析器、事務交易控制器、事務交易拆分器；所述事務交易拆分器用于將客戶端下發的命令拆分為各個節點組對應的分命令；

在所述步驟三之后，還包括步驟A；

步驟A、事務交易拆分器將客戶端下發的命令拆分為各個節點組對應的分命令；

所述步驟四包括事務交易控制器將各個分命令分別下發至各個節點組中被選取的數據節點、并且將各個分命令按與節點組的對應關系存儲在事務交易存儲器中。

3.根據權利要求2所述的云數據庫中分布式事務的實現方法，其特征在于，所述步驟八包括以下步驟：

步驟B、根據客戶端下發的提交命令，事務交易拆分器將所述提交命令拆分為各個節點組對應的分提交命令；

步驟C、事務交易拆分器將各個分提交命令分別下發至對應的節點組，同時將各個分提交命令置于事務交易存儲器按與節點組的對應關系進行存儲；

步驟D、在之前所有命令執行成功的數據節點的基礎上，繼續執行當前分提交命令，并將執行結果返回給事務交易控制器；

步驟E、事務交易控制器調取事務交易結果分析器，通過事務交易結果分析器按照預先設定的規則分析數據節點執行當前分提交命令是否成功，若成功，則進入步驟九；若不成功，返回步驟二。

4.根據權利要求1或2或3所述的云數據庫中分布式事務的實現方法，其特征在于，在步驟二之前，還包括步驟F：

步驟F、事務交易控制器判斷節點組池中是否有需要的節點組，若有，則進入步驟二，若無，則對外宣布失敗。

5.根據權利要求4所述的云數據庫中分布式事務的實現方法，其特征在于，包括至少2個事務交易控制器，每個事務交易控制器對應至少一個數據節點，每個事務交易控制器對應的數據節點不可交叉對應至其他事務交易控制器對應的數據節點。

6.根據權利要求4所述的云數據庫中分布式事務的實現方法，其特征在于，代理端包括至少2個事務交易存儲器，每個事務交易存儲器不可重復存儲客戶端下發的命令。