[發明專利]一種消費者隊列的調度方法及系統

在審

• 申請號: 201810044707.0
• 申請日: 2018-01-17
• 公開（公告）號: CN108234668A
• 公開（公告）日: 2018-06-29
• 發明（設計）人: 蘆正帥
• 申請（專利權）人: 北京網信云服信息科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/863
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王寶筠

1.一種消費者隊列的調度方法，其特征在于，包括：

當接收到對目標消費者隊列的調度請求時，獲取與所述調度請求對應的機器集群，所述機器集群包含至少一個消費者機器；

獲取所述機器集群中的消費者配置和消費者機器配置；

依據所述消費者配置和所述消費者機器配置確定每一個消費者機器的調度閾值；

依據所述調度閾值，將所述目標消費者隊列中的消費者調度給所述消費者機器。

2.根據權利要求1所述的方法，其特征在于，還包括：

當檢測到任意一個消費者機器的宕機指令時，獲取所述機器集群的消費者配置和所述機器集群中剩余的消費者機器的數量；

依據所述消費者配置和所述機器集群中剩余的消費者機器的數量，重新分配所述機器集群中每一個消費者的調度閾值。

3.根據權利要求1所述的方法，其特征在于，依據所述消費者配置和所述消費者機器配置確定每一個消費者機器的機器配置包括：

解析所述消費者配置中包含的消費者數量；

解析所述消費者機器配置中包含的消費者機器數量；

將所述消費者數量依據所述消費者機器數量進行平均分配，得到每一個消費者機器的調度閾值。

4.根據權利要求1所述的方法，其特征在于，還包括：

當檢測到消費者機器的新增指令時，獲取新增消費者機器對應的IP地址；

將所述IP地址加入到所述機器集群的配置中心。

5.根據權利要求1所述的方法，其特征在于，還包括：

當檢測到所述機器集群中的消費者機器宕機的數量與所述目標機器集群中消費者機器的總數的比值超過預設的閾值比時，停止對所述目標消費者隊列的調度。

6.一種消費者隊列的調度系統，其特征在于，包括：

第一獲取模塊，用于當接收到對目標消費者隊列的調度請求時，獲取與所述調度請求對應的機器集群，所述機器集群包含至少一個消費者機器；

第二獲取模塊，用于獲取所述機器集群中的消費者配置和消費者機器配置；

確定模塊，用于依據所述消費者配置和所述消費者機器配置確定每一個消費者機器的調度閾值；

調度模塊，用于依據所述調度閾值，將所述目標消費者隊列中的消費者調度給所述消費者機器。

7.根據權利要求6所述的系統，其特征在于，還包括：

第三獲取模塊，用于當檢測到任意一個消費者機器的宕機指令時，獲取所述機器集群的消費者配置和所述機器集群中剩余的消費者機器的數量；

分配模塊，用于依據所述消費者配置和所述機器集群中剩余的消費者機器的數量，重新分配所述機器集群中每一個消費者的調度閾值。

8.根據權利要求6所述的系統，其特征在于，所述確定模塊包括：

第一解析單元，用于解析所述消費者配置中包含的消費者數量；

第二解析單元，用于解析所述消費者機器配置中包含的消費者機器數量；

分配單元，用于將所述消費者數量依據所述消費者機器數量進行平均分配，得到每一個消費者機器的調度閾值。

9.根據權利要求6所述的系統，其特征在于，還包括：

第四獲取模塊，用于當檢測到消費者機器的新增指令時，獲取新增消費者機器對應的IP地址；

添加模塊，用于將所述IP地址加入到所述機器集群的配置中心。

10.根據權利要求1所述的方法，其特征在于，還包括：

停止模塊，用于當檢測到所述機器集群中的消費者機器宕機的數量與所述目標機器集群中消費者機器的總數的比值超過預設的閾值比時，停止對所述目標消費者隊列的調度。