[發(fā)明專利]一種分布式事務(wù)處理方法、系統(tǒng)及相關(guān)設(shè)備

在審

• 申請?zhí)枺?/td>: 202110342631.1
• 申請日: 2021-03-30
• 公開（公告）號: CN115145715A
• 公開（公告）日: 2022-10-04
• 發(fā)明（設(shè)計）人: 姜宇
• 申請（專利權(quán)）人: 華為云計算技術(shù)有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/48;G06F16/27;G06F16/23
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 熊永強;李稷芳

1.一種分布式事務(wù)處理方法，其特征在于，所述方法應(yīng)用于分布式系統(tǒng)，所述分布式系統(tǒng)包括鎖服務(wù)器集群和事務(wù)協(xié)調(diào)器集群，所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器用于控制分布式事務(wù)的處理過程，所述分布式事務(wù)的處理過程包括所述分布式事務(wù)涉及的數(shù)據(jù)庫的鎖操作，所述方法包括：

所述鎖服務(wù)器集群中的第一鎖服務(wù)器根據(jù)事務(wù)協(xié)調(diào)器列表，向所述事務(wù)協(xié)調(diào)器列表中的每個事務(wù)協(xié)調(diào)器發(fā)送鎖數(shù)據(jù)的獲取請求；

若所述第一鎖服務(wù)器獲取到所述事務(wù)協(xié)調(diào)器列表中每個事務(wù)協(xié)調(diào)器發(fā)送的鎖數(shù)據(jù)，所述第一鎖服務(wù)器所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器發(fā)送的鎖請求進行處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述事務(wù)協(xié)調(diào)器列表是由第二鎖服務(wù)器同步至所述第一鎖服務(wù)器的，所述事務(wù)協(xié)調(diào)器列表記錄了進行鎖操作活躍的事務(wù)協(xié)調(diào)器，所述第二鎖服務(wù)器是所述第一鎖服務(wù)器向所述事務(wù)協(xié)調(diào)器列表中的每個事務(wù)協(xié)調(diào)器發(fā)送鎖數(shù)據(jù)的獲取請求之前，對所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器發(fā)送的鎖請求進行處理的主鎖服務(wù)器。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述第一鎖服務(wù)器對所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器發(fā)送的鎖請求進行處理，包括：

所述第一鎖服務(wù)器接收事務(wù)協(xié)調(diào)器集群中第一事務(wù)協(xié)調(diào)器發(fā)送的加鎖請求；

當(dāng)所述事務(wù)協(xié)調(diào)器列表中不包括所述第一事務(wù)協(xié)調(diào)器的標(biāo)識時，所述第一鎖服務(wù)器將所述第一事務(wù)協(xié)調(diào)器的標(biāo)識加入所述事務(wù)協(xié)調(diào)器列表，得到更新后的事務(wù)協(xié)調(diào)器列表；

所述第一鎖服務(wù)器將所述更新后的事務(wù)協(xié)調(diào)器列表同步給所述鎖服務(wù)器集群中的其他鎖服務(wù)器；

所述第一鎖服務(wù)器在確認將所述更新后的事務(wù)協(xié)調(diào)器列表成功同步給所述其他鎖服務(wù)器中預(yù)設(shè)比例的鎖服務(wù)器的情況下，根據(jù)所述加鎖請求執(zhí)行加鎖操作，并將執(zhí)行加鎖操作后的鎖數(shù)據(jù)保存至所述第一鎖服務(wù)器的存儲區(qū)域。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述方法還包括：

所述第一鎖服務(wù)器在確認沒有將所述更新后的事務(wù)協(xié)調(diào)器列表同步給所述其他鎖服務(wù)器中預(yù)設(shè)比例的鎖服務(wù)器的情況下，向所述第一事務(wù)協(xié)調(diào)器發(fā)送加鎖失敗的消息，并刪除所述更新后的事務(wù)協(xié)調(diào)器列表中所述第一事務(wù)協(xié)調(diào)器的標(biāo)識。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，當(dāng)所述事務(wù)協(xié)調(diào)器列表中包括所述第一事務(wù)協(xié)調(diào)器的標(biāo)識時，所述第一鎖服務(wù)器根據(jù)所述加鎖請求執(zhí)行加鎖操作，并將執(zhí)行加鎖操作后的鎖數(shù)據(jù)保存至所述第一鎖服務(wù)器的存儲區(qū)域。

6.根據(jù)權(quán)利要求1至5任一項所述的方法，其特征在于，所述第一鎖服務(wù)器對所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器發(fā)送的鎖請求進行處理之前，還包括：

所述第一鎖服務(wù)器向所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器發(fā)送第一指示消息，所述第一指示消息指示所述事務(wù)協(xié)調(diào)器集群中的事務(wù)協(xié)調(diào)器將鎖請求發(fā)送給所述第一鎖服務(wù)器。

7.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述向所述事務(wù)協(xié)調(diào)器列表中的每個事務(wù)協(xié)調(diào)器發(fā)送鎖數(shù)據(jù)的獲取請求之前，所述方法還包括：

所述第一鎖服務(wù)器在預(yù)設(shè)時長內(nèi)沒有接收到所述第二鎖服務(wù)器發(fā)送的心跳包。

8.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述第一鎖服務(wù)器是根據(jù)預(yù)設(shè)算法從所述鎖服務(wù)器集群中選取的候選主鎖服務(wù)器。

9.根據(jù)權(quán)利要求1至8所述的方法，其特征在于，所述方法還包括：

所述第一鎖服務(wù)器在沒有接收到所述事務(wù)協(xié)調(diào)器列表中第二事務(wù)協(xié)調(diào)器發(fā)送的鎖數(shù)據(jù)時，向所述事務(wù)協(xié)調(diào)器列表中第三事務(wù)協(xié)調(diào)器發(fā)送所述獲取請求，所述第三事務(wù)協(xié)調(diào)器中包括所述第二事務(wù)協(xié)調(diào)器中鎖數(shù)據(jù)的備份；

所述第一鎖服務(wù)器接收所述第三事務(wù)協(xié)調(diào)器發(fā)送的所述第二事務(wù)協(xié)調(diào)器中包括的鎖數(shù)據(jù)。