[發明專利]一種工作流調度執行單元控制方法和控制器

有效

• 申請號: 202011623798.7
• 申請日: 2020-12-30
• 公開（公告）號: CN112783123B
• 公開（公告）日: 2021-11-19
• 發明（設計）人: 王冠;夏元清;閆莉萍;詹玉峰;郭澤華;張金會;劉坤;戴荔;翟弟華;鄒偉東;孫中奇;崔冰;劉丹陽
• 申請（專利權）人: 北京理工大學
• 主分類號: G05B19/418
• 分類號: G05B19/418
• 代理公司: 北京高沃律師事務所 11569
• 代理人: 王愛濤

1.一種工作流調度執行單元控制方法，其特征在于，包括：

獲取第一調度執行單元注冊表和系統工作流的調度壓力；所述第一調度執行單元注冊表包括：調度執行單元標識、調度執行單元自測壓力、調度執行單元工作流容量和調度執行單元遠程過程調用信息；所述調度執行單元遠程過程調用信息包括：調度執行單元網絡IP地址、調度執行單元網絡TCP端口號和調度執行單元響應控制器的程序函數路徑字符串；

根據所述第一調度執行單元注冊表和所述系統當前工作流的調度壓力生成調度執行單元預選表；所述調度執行單元預選表為一個排序數組；所述排序數組每一項均包含：調度執行單元標識、調度執行單元承載容量和調度執行單元遠程過程調用信息；

遍歷所述第一調度執行單元注冊表，并確定所述第一調度執行單元注冊表中所有調度執行單元的承載總容量；

根據所述系統工作流的調度壓力確定當前系統中的工作流總量；

根據所述承載總容量和所述工作流總量間的關系確定系統中當前開啟或關閉的所述調度執行單元的個數，得到工作調度執行單元；

獲取第一多生產者單消費者模型隊列；

接收網絡傳遞的工作流，并將接收的工作流返給所述第一多生產者單消費者模型隊列的隊尾，得到第二多生產者單消費者模型隊列；

獲取所述調度執行單元預選表中每一所述工作調度執行單元的承載容量，并從第二多生產者單消費者模型隊列的隊首開始，依序取出與所述工作調度執行單元的承載容量對應個數的工作流后，將取出的工作流對應發送給所述工作調度執行單元，并判斷是否發送成功，得到第一判斷結果；

若所述第一判斷結果為是，則將所述第二多生產者單消費者模型隊列作為新的所述第一多生產者單消費者模型隊列后，返回“接收網絡傳遞的工作流，并將接收的工作流返給所述第一多生產者單消費者模型隊列的隊尾，得到第二多生產者單消費者模型隊列”；

若所述第一判斷結果為否，則將取出的工作流放入所述第二多生產者單消費者模型隊列，得到新的第二多生產者單消費者模型隊列，并將新的所述第二多生產者單消費者模型隊列作為新的所述第一多生產者單消費者模型隊列后，返回“接收網絡傳遞的工作流，并將接收的工作流返給所述第一多生產者單消費者模型隊列的隊尾，得到第二多生產者單消費者模型隊列”。

2.根據權利要求1所述的工作流調度執行單元控制方法，其特征在于，所述獲取第一調度執行單元注冊表，之前包括：

獲取調度執行單元狀態表和第二調度執行單元注冊表；所述調度執行單元狀態表中存儲有調度執行單元在連續N個可調節時間常數周期內發送的保活信號；所述?；钚盘柊ǎ赫{度執行單元標識、調度執行單元自測壓力、調度執行單元容量、調度執行單元遠程過程調用信息和調度執行單元遠程發送時間戳；

遍歷所述調度執行單元狀態表，并判斷所述調度執行單元狀態表中的調度執行單元是否被所述第二調度執行單元注冊表包含，得到第二判斷結果；

當所述第二判斷結果為是時，根據所述?；钚盘柵袛嗨稣{度執行單元是否為存活狀態，得到第三判斷結果；

當所述第三判斷結果為否時，刪除所述調度執行單元的信息，并向所述調度執行單元發送關閉命令后，將所述調度執行單元的標識保存至調度執行單元黑名單；

當所述第三判斷結果為是或所述第二判斷結果為否時，根據所述調度執行單元的信息更新所述第二調度執行單元注冊表中的調度執行單元信息或新增所述第二調度執行單元注冊表的表項，得到第一調度執行單元注冊表。

3.根據權利要求2所述的工作流調度執行單元控制方法，其特征在于，根據所述?；钚盘柵袛嗨稣{度執行單元是否為存活狀態，具體包括：

采用公式確定所述調度執行單元連續N個所述?；钚盘柕钠骄鶗r間間隔；

獲取調度執行單元進入死亡時間的預設時間常數；

判斷所述平均時間間隔是否大于所述預設時間常數；

當所述平均時間間隔大于所述預設時間常數時，判定所述調度執行單元死亡；

當所述平均時間間隔小于等于所述預設時間常數時，判定所述調度執行單元存活；

其中，X為調度執行單元，為平均時間間隔，TC_yi(X)為調度執行單元X在調度執行單元狀態表中第i個可調節時間常數周期與第i-1個可調節時間常數周期的時間差。