[發明專利]一種面向物聯網流計算的負載均衡和容錯方法

有效

• 申請號: 201711456506.3
• 申請日: 2017-12-28
• 公開（公告）號: CN109981710B
• 公開（公告）日: 2021-10-29
• 發明（設計）人: 毛峻嶺
• 申請（專利權）人: 中移物聯網有限公司;中國移動通信集團公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 姚文嫻;張穎玲

1.一種面向物聯網流計算的負載均衡和容錯方法，其特征在于，包括：

對任務池中當前任務領取節點標識對應的任務信息進行加鎖，將所述任務信息中的更新時間修改為當前時間，對修改后的任務信息進行解鎖；

計算當前任務領取節點當前的負載冗余時間；

所述負載冗余時間為：在所述當前任務領取節點的計算處理列表中任務的最大流計算間隔內，所述計算處理列表各個任務歸一化負載冗余的最小值；

第i個任務的歸一化負載冗余Gi＝(任務i的流計算間隔-完成任務i的計算時間)/(任務i流計算間隔)；

若所述當前的負載冗余時間大于第一門限值，在等待第一預設時間后，對所述任務池中N個滿足第一預設條件的任務進行加鎖，將N個任務中的M個任務加入當前任務領取節點對應的計算處理列表中，將加入M個任務后的當前任務領取節點對應的計算處理列表中任務的任務信息進行更新；

若所述當前的負載冗余時間小于0，選取當前任務領取節點對應的計算處理列表中的任務集合S，對所述任務池中與所述任務集合S中任務標識對應的任務加鎖，修改所述任務池中與所述任務集合S中的任務標識對應任務的任務信息。

2.根據權利要求1所述的方法，其特征在于，所述第一預設時間為所述負載冗余時間的減函數；

所述N為所述負載冗余時間任務數的樂觀估計，所述M為小于N的整數。

3.根據權利要求1或2所述的方法，其特征在于，所述對所述任務池中N個滿足第一預設條件的任務進行加鎖，包括：

訪問所述任務池，從所述任務池中讀取N個滿足第一預設條件的任務，對所述任務池中N個滿足第一預設條件的任務進行加鎖，所述滿足第一預設條件的任務包括：狀態為空閑狀態且計算節點為空的任務，或者更新時間大于第二預設時間的任務。

4.根據權利要求1或2所述的方法，其特征在于，所述將N個任務中的M個任務加入當前任務領取節點對應的計算處理列表中，將加入M個任務后的當前任務領取節點對應的計算處理列表中任務的任務信息進行更新，包括：

通過預估負載在讀取的N個任務中選擇M個任務加入當前任務領取節點對應的計算處理列表中，將加入M個任務后的當前任務領取節點對應的計算處理列表中任務按流計算間隔升序排列后進行計算處理；

計算處理后將加入M個任務后的當前任務領取節點對應的計算處理列表中任務的任務狀態更新為處理狀態，將加入M個任務后的當前任務領取節點對應的計算處理列表中任務領取節點標識更新為當前節點標識，將加入M個任務后的當前任務領取節點對應的計算處理列表中任務的更新時間修改為當前時間；

將更新任務信息后當前任務領取節點對應的計算處理列表中任務進行解鎖。

5.根據權利要求1或2所述的方法，其特征在于，所述選取當前任務領取節點對應的計算處理列表中的任務集合S，對所述任務池中與所述任務集合S中任務標識對應的任務加鎖，修改所述任務池中與所述任務集合S中的任務標識對應任務的任務信息，包括：

從所述當前任務領取節點對應的計算處理列表中選取任務集合S，其中，所述任務集合S根據當前任務領取節點每次加入任務后的負載冗余時間的減少量進行選取；

在所述任務池中查找與所述任務集合S中任務標識對應的任務，對所述任務池中與所述任務集合S中任務標識對應的任務加鎖；

修改所述任務池中與所述任務集合S中的任務標識對應任務的任務狀態為空閑狀態，修改所述任務池中與所述任務集合S中的任務標識對應任務的更新時間為當前時間，修改所述任務池中與所述任務集合S中的任務標識對應任務的計算節點為空；

對所述任務池中與所述任務集合S中任務標識對應的任務解鎖。