[發明專利]主動領取任務的方法、工作節點、系統及存儲介質

有效

• 申請號: 201710439793.0
• 申請日: 2017-06-12
• 公開（公告）號: CN107249029B
• 公開（公告）日: 2019-09-06
• 發明（設計）人: 周德江;鄭荃瑋
• 申請（專利權）人: 優刻得科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 上海華誠知識產權代理有限公司 31300
• 代理人: 肖華

1.一種主動領取任務的方法，其特征在于，多個工作節點中的每個工作節點周期地進行以下步驟,以從數據中心主動領取任務：

S0)從所述數據中心中獲取多個任務以及多個當前工作節點信息，并根據所述多個任務以及所述多個當前工作節點信息，進行一致性哈希計算，得到多個實際工作節點信息；

S1)根據所述多個當前工作節點信息，判斷所述多個任務中的當前任務是否被領取，如果否，則進入步驟S2)，如果是，則進入步驟S3)；

S2)根據所述多個實際工作節點信息，將所述當前任務添加到所述數據中心中的所述多個當前工作節點信息中，并進入步驟S10)；

S3)根據所述多個當前工作節點信息，判斷所述當前任務是否被本地領取，如果是，則進入S4，否則進入S10；

S4)判斷所述當前任務在多個當前工作節點信息中對應的當前工作節點是否與所述當前任務在所述多個實際工作節點信息中對應的實際工作節點相同，如果是，則進入S6，否則進入S5；

S5)從本地任務列表中判斷所述當前任務的處理狀態，如果是第一狀態或第二狀態，則進入步驟S9，如果是第三狀態或第四狀態，則進入S8；

S6)判斷所述當前任務是否在所述本地任務列表中，如果是，則進入S10，否則進入S7；

S7)將所述當前任務添加到所述本地任務列表中，并進入S10；

S8)從所述本地任務列表中刪除所述當前任務，并根據所述多個實際工作節點信息，將所述當前任務更新到所述數據中心中的多個當前工作節點信息中，并且進入S10；

S9)將所述當前任務的所述處理狀態設置為所述第二狀態，并且進入S10；

S10)判斷所述當前任務是否是所述多個任務中的最后一個任務，如果是，則返回S0，否則進入S11；

S11)將所述多個任務中的下一個任務確定作為所述當前任務，并返回S1，其中，所述第一狀態是指所述當前任務正在被本地處理，所述第二狀態是指所述當前任務正在被本地處理、且不能被本地再次處理，所述第三狀態是指所述當前任務已被本地處理結束，所述第四狀態是指所述當前任務已被本地處理結束、且不能被本地再次處理。

2.如權利要求1所述的主動領取任務的方法，其特征在于，所述每個工作節點周期地將所述本地任務列表傳送給所述數據中心，用于更新所述多個當前工作節點信息。

3.如權利要求2所述的主動領取任務的方法，其特征在于，所述多個當前工作節點信息中的每個當前工作節點信息包括當前工作節點、當前領取任務、以及當前更新時間，其中，每個當前工作節點將所述本地任務列表傳送給所述數據中心的時間作為所述當前更新時間。

4.如權利要求3所述的主動領取任務的方法，其特征在于，所述多個實際工作節點信息中的每個實際工作節點信息包括所述當前任務和實際工作節點，

其中，在步驟S2)中，將所述當前任務對應的所述實際工作節點作為所述當前工作節點，并將所述當前任務添加作為與所述當前工作節點對應的所述當前領取任務。

5.如權利要求4所述的主動領取任務的方法，其特征在于，所述本地任務列表包含本地領取任務以及對應的處理狀態，所述處理狀態包括所述第一狀態、所述第二狀態、所述第三狀態、所述第四狀態，

其中，當本地領取任務處于所述第二狀態、且已被本地工作節點處理結束時，將所述本地領取任務的所述處理狀態設置為所述第四狀態。

6.如權利要求5所述的主動領取任務的方法，其特征在于，步驟S8)中，將所述當前任務對應的所述實際工作節點作為所述當前工作節點，并將所述當前任務更新作為與所述當前工作節點對應的所述當前領取任務。

7.如權利要求3-6中任一項所述的主動領取任務的方法，其特征在于，所述數據中心周期地判斷所述當前工作節點信息中的所述當前更新時間與當前實際時間的差是否大于預定時間，如果是，則刪除所述當前更新時間所對應的當前工作節點信息。