[發明專利]一種適用于分布式任務管理系統的狀態一致性維護方法

有效

• 申請號: 201410292893.1
• 申請日: 2014-06-26
• 公開（公告）號: CN104077181B
• 公開（公告）日: 2017-08-29
• 發明（設計）人: 高原;盧建剛;顧文杰;任升;沙一川;曾堅永;趙瑞鋒;方華建
• 申請（專利權）人: 國電南瑞科技股份有限公司;廣東電網有限責任公司電力調度控制中心
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 南京縱橫知識產權代理有限公司32224
• 代理人: 董建林,許婉靜

1.一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：包括以下步驟，

步驟（1），分布式任務管理系統節點狀態的維護，分布式任務管理系統的所有節點定期廣播發送心跳報文，通知其他節點本機的生存狀態；

步驟（2），分布式任務管理系統的任務初始化，在分布式任務管理系統的每個節點上運行任務管理程序，在任意一個節點上輸入所有的待部署任務，任務管理程序根據活躍節點數量決定部署情況，并與分布式任務管理系統中所有節點進行通信，得到確認回復后，分布式任務管理系統到達一致的初始化狀態；

步驟（3），分布式任務管理系統的任務狀態改變，當分布式任務管理系統的任意一個節點上的任務運行狀態發生改變時，任務管理程序都會與分布式任務管理系統中所有節點進行通信，得到確認回復后，每個節點同時實施改動，分布式任務管理系統進入另一個一致的狀態；

步驟（4），節點故障和恢復的處理，當分布式任務管理系統中的一個節點故障退出或者恢復加入后，分布式任務管理系統的節點集合發生改變，分布式任務管理系統保持維持一致的狀態，所述步驟（4）分布式任務管理系統出現一個故障節點，則總節點數減一，提案獲得半數以上通過的數量閾值相應降低；故障恢復的節點首先向分布式任務管理系統中發出設置本機當前任務狀態的提案請求，本機的任務由斷網改變為在線的狀態改變提案，其他節點收到后發現編號過舊，則會發出否定回復，并附加本機的任務狀態信息，故障恢復的節點接收到否定回復，并選擇最大編號的節點進行學習，更新本地任務狀態后重新加入分布式任務管理系統運行，總的節點數加一，提案獲得半數以上通過的數量閾值相應增加；

其中，步驟（1）所述分布式任務管理系統的所有節點定期廣播發送的心跳報文包括節點名、節點編號、本機狀態編號，當3秒的時間間隔后，分布式任務管理系統接收不到某個節點的心跳，判斷該節點為故障，能正常收到心跳的節點判斷為活躍節點，節點編號為節點的優先級，編號越小的優先級越大；

步驟（2）所述任務管理程序根據活躍節點數量決定部署情況的過程為，

（1）任務管理程序查看所有活躍的節點；

（2）將任務負載均衡的部署到每個活躍的節點上，并將部署計劃通知到每個活躍節點。

2.根據權利要求1所述的一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：步驟（3）所述任務管理程序都會與分布式任務管理系統中所有節點進行通信，將需要進行的改變發出給所有節點，得到半數以上節點確認回復后，每個節點同時實施改動，分布式任務管理系統進入另一個一致的狀態。

3.根據權利要求1所述的一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：步驟（3）分布式任務管理系統的每一次狀態改變，都會在各節點心跳報文的本機狀態編號的當前狀態編號加1，各節點的初始化的本機狀態編號為0。

4.根據權利要求1所述的一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：步驟（3）需要狀態改變的節點將狀態改變作為提案請求發出，并進行提案接收，發出提案請求時，當前狀態編號加1，若接收的提案的狀態編號大于本機的狀態編號，則給出確認回復，否則，給出否定回復反對接收到的提案，需要狀態改變的節點接收到半數以上的活躍節點確認回復后，表示此提案請求被批準，則該節點發送提交報文，讓分布式任務管理系統所有活躍節點改變任務狀態，所有活躍節點更新本機狀態編號，并且回復完成給發送提交報文的節點。

5.根據權利要求1或4所述的一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：若接收到多個節點的提案請求，且每個提案請求的本機狀態編號一致，則只確認回復節點編號最小的提案請求。

6.根據權利要求4所述的一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：所述接收者若接收的提案的狀態編號比本地狀態編號小或者等于本地編號，則說明提案發送者的狀態比系統中全局的狀態要舊，存在狀態變化的提交報文丟失過，此時狀態舊的節點需要從狀態新的節點學習狀態信息，提案接收者在給出否定回復時，順帶捎上本節點最新的任務狀態信息。

7.根據權利要求4所述的一種適用于分布式任務管理系統的狀態一致性維護方法，其特征在于：所述接收者若在接收到比本機狀態編號大提案的狀態編號后，又接收到一個編號更大的提案的狀態編號，接收者給此更大編號的提案者發送確認回復時要捎帶本節點需要先學習到最新狀態的請求，發送者在給此接收者發出提交報文時捎帶上一輪的狀態，接收者學習完上一輪狀態后，在本地提交狀態改變。