[發明專利]一種分布式系統執行腳本的方法及裝置

在審

• 申請號: 201911017059.0
• 申請日: 2019-10-24
• 公開（公告）號: CN110839064A
• 公開（公告）日: 2020-02-25
• 發明（設計）人: 馬曉
• 申請（專利權）人: 蘇寧云計算有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F9/46;G06F9/50
• 代理公司: 江蘇圣典律師事務所 32237
• 代理人: 許峰

1.一種分布式系統執行腳本的方法，其特征在于，所述分布式系統包括協調者節點和參與者節點，所述方法包括：

獲取并解析腳本，所述腳本包括節點key值和操作命令；

獲取參與者節點的狀態信息，所述狀態信息包括節點key分布槽位信息；

根據所述節點key值和所述節點key分布槽位信息，發送所述操作命令給參與者節點。

2.按照權利要求1所述的方法，其特征在于，所述根據所述節點key值和所述節點key分布槽位信息，發送所述操作命令給參與者節點，具體包括：

所述協調者節點向所述參與者節點發送狀態詢問請求，收到所述參與者節點響應后，向所述參與者節點發送預提交請求；

所述參與者節點接收所述預提交請求，執行預提交操作，并記錄undo信息，同時向所述協調者節點返回響應；

所述協調者節點接收所述響應后，向所有參與者節點發送執行提交請求；

所述參與者節點接收所述執行提交請求后，執行事務提交，同時向所述協調者節點返回事務完成響應。

3.按照權利要求2所述的方法，其特征在于，所述協調者節點向所述參與者節點發送狀態詢問請求，收到所述參與者節點響應后，向所述參與者節點發送預提交請求，具體包括：

所述協調者節點向所述參與者節點發送狀態詢問請求，所述參與者節點接收所述狀態詢問請求后，根據自身狀態，向所述協調者節點作出回復響應；當狀態良好時，則回復響應為YES響應，當狀態異常或不在線時，則回復響應為NO響應；

若所述協調者節點接收的回復響應均為YES響應，則向所述參與者節點發送預提交請求。

4.按照權利要求3所述的方法，其特征在于，還包括：若所述協調者節點接收的回復響應中包含至少一個NO響應，則執行事務的中斷，所述協調者節點向所有的參與者節點發送中止請求，所述參與者節點接收所述中止請求后，執行事務中斷。

5.按照權利要求2所述的方法，其特征在于，所述參與者節點接收所述預提交請求，執行預提交操作，并記錄undo信息，同時向所述協調者節點返回響應之后，還包括：

若所述協調者節點沒有接收到所述響應，則向所有參與者節點發送中止請求；

所述參與者節點接收所述中止請求之后，利用所述undo信息，執行事務的回滾，并在完成回滾之后，釋放所有的事務資源，并向所述協調者節點發送響應；

所述協調者節點接收所述參與者節點反饋的響應之后，執行事務中斷。

6.一種分布式系統執行腳本的裝置，其特征在于，分布式系統包括協調者節點和參與者節點，所述裝置包括：

解析模塊，用于獲取并解析腳本，所述腳本包括節點key值和操作命令；

獲取模塊，用于獲取參與者節點的狀態信息，所述狀態信息包括節點key分布槽位信息；

發送模塊，根據所述節點key值和所述節點key分布槽位信息，發送所述操作命令給參與者節點。

7.根據權利要求6所述的裝置，其特征在于，所述發送模塊包括：

詢問子模塊，用于所述協調者節點向所述參與者節點發送狀態詢問請求，收到所述參與者節點響應后，向所述參與者節點發送預提交請求；

預提交子模塊，用于所述參與者節點接收所述預提交請求，執行預提交操作，并記錄undo信息，同時向所述協調者節點返回響應；

發送子模塊，用于所述協調者節點接收所述響應后，向所有參與者節點發送執行提交請求；

執行子模塊，用于所述參與者節點接收所述執行提交請求后，執行事務提交，同時向所述協調者節點返回事務完成響應。

8.根據權利要求7所述的裝置，其特征在于，所述詢問子模塊，還包括：

第一判斷單元，用于所述協調者節點向所述參與者節點發送狀態詢問請求，所述參與者節點接收所述狀態詢問請求后，根據自身狀態，向所述協調者節點作出回復響應；當狀態良好時，則回復響應為YES響應，當狀態異常或不在線時，則回復響應為NO響應；

若所述協調者節點接收的回復響應均為YES響應，則向所述參與者節點發送預提交請求。