[發明專利]分布式資源調度方法、調度節點及接入節點

有效

• 申請號: 201610874061.X
• 申請日: 2016-09-30
• 公開（公告）號: CN107885594B
• 公開（公告）日: 2020-06-12
• 發明（設計）人: 顏克洲;李雅卿
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54
• 代理公司: 北京德琦知識產權代理有限公司 11018
• 代理人: 郭曼;王琦

1.一種分布式資源調度方法，其特征在于，應用于調度節點，所述方法包括：

獲取至少一個資源節點的工作隊列狀態信息，具體為：接收每個接入節點發送的狀態監測消息，所述狀態監測消息攜帶有接入節點在一定時間間隔內獲取到的至少一個資源節點的工作隊列狀態信息；根據所述狀態監測消息獲取至少一個資源節點的工作隊列狀態信息；

針對每個接入節點，根據業務請求消息和所述工作隊列狀態信息執行資源調度，以為接入節點中待處理的每個業務分配至少一個資源節點并生成調度結果，具體為：根據工作隊列的長度從至少一個資源節點中確定出空閑的資源節點；預先設置接入節點中各個業務的優先級；根據優先級從高到低的排序，依次輪詢每個接入節點的各個業務，為每個業務分配M_j個空閑的資源節點；其中，所述業務請求消息攜帶有一個接入節點的J個業務的請求隊列中任務請求的個數，第j個業務的業務請求個數為M_j，j＝1,2，…，J，所述工作隊列狀態信息包括一資源節點的工作隊列的長度；

向接入節點發送所述調度結果，以使該接入節點根據所述調度結果向所分配的至少一個資源節點發送至少一個任務請求，且所分配的至少一個資源節點在處理完接收到的任務請求之后，向該接入節點返回攜帶有該至少一個資源節點的工作隊列狀態信息的請求處理確認消息。

2.根據權利要求1所述的方法，其中，所述接入節點為視頻接入節點，所述調度節點為視頻控制機，所述資源節點為視頻工作機。

3.根據權利要求1所述的方法，其中，所述狀態監測消息為心跳包，接入節點在所述心跳包中攜帶該接入節點在一定時間間隔內獲取到的至少一個資源節點的工作隊列狀態信息。

4.根據權利要求3所述的方法，其中，所述接入節點在發送完畢所述心跳包后，清空本地所存儲的所述至少一個資源節點的工作隊列狀態信息。

5.根據權利要求1所述的方法，進一步包括：

所述工作隊列狀態信息包括一資源節點生成工作隊列狀態信息時的時間戳；

當獲取到一資源節點的工作隊列狀態信息時，根據時間戳的先后順序更新所記錄的該資源節點的工作隊列狀態信息。

6.一種分布式資源調度方法，其特征在于，應用于接入節點，所述方法包括：

接入節點生成至少一個業務的請求隊列；

所述接入節點每隔預定的時間間隔分別向每個調度節點發送狀態監測消息，所述狀態監測消息攜帶有所述接入節點在一定時間間隔內獲取到的至少一個資源節點的工作隊列狀態信息；

一在線的調度節點根據所述狀態監測消息獲取所述工作隊列狀態信息，并向所述接入節點反饋狀態監測確認消息；

所述接入節點接收到所述狀態監測確認消息時，確認該調度節點在線，并根據接收到所述狀態監測確認消息的時刻，對所有在線的調度節點按照時間先后順序進行排序，根據排序結果向第1個在線的調度節點發送業務請求消息，若第1個在線的調度節點無法正常工作或者故障，則向下一個在線的調度節點發送業務請求消息；當接收到一在線的調度節點反饋的業務請求確認消息時，將該調度節點作為最終的調度節點；

所述最終的調度節點根據所述業務請求消息和所述工作隊列狀態信息執行資源調度，為所述接入節點中待處理的每個業務分配至少一個資源節點并生成調度結果；及，

所述接入節點從所述最終的調度節點接收所述調度結果，并根據所述調度結果向所分配的至少一個資源節點發送至少一個任務請求；

所分配的資源節點在處理完接收到的任務請求之后，向所述接入節點返回攜帶有該資源節點的工作隊列狀態信息的請求處理確認消息。

7.根據權利要求6所述的方法，其中，所述接入節點為視頻接入節點，所述調度節點為視頻控制機，所述資源節點為視頻工作機。