[發(fā)明專利]一種消費者隊列的調(diào)度方法及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201810044707.0
• 申請日: 2018-01-17
• 公開（公告）號: CN108234668A
• 公開（公告）日: 2018-06-29
• 發(fā)明（設(shè)計）人: 蘆正帥
• 申請（專利權(quán)）人: 北京網(wǎng)信云服信息科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/863
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

本發(fā)明公開了一種消費者隊列的調(diào)度方法，包括：當接收到對目標消費者隊列的調(diào)度請求時，獲取與所述調(diào)度請求對應(yīng)的機器集群，所述機器集群包含至少一個消費者機器；獲取所述機器集群中的消費者配置和消費者機器配置；依據(jù)所述消費者配置和所述消費者機器配置確定每一個消費者機器的調(diào)度閾值；依據(jù)所述調(diào)度閾值，將所述目標消費者隊列中的消費者調(diào)度給所述消費者機器。上述的調(diào)度方法，由于每次產(chǎn)生調(diào)度請求中的消費者者隊列的消費者的數(shù)量都是變化的，為了適應(yīng)消費者數(shù)量的變化，都會優(yōu)先調(diào)整每一個消費者機器的調(diào)度閾值，避免了調(diào)整調(diào)度閾值的方式不靈活、耗時長，導(dǎo)致消費者隊列的調(diào)度的效率低的問題。

技術(shù)領(lǐng)域

本發(fā)明涉及調(diào)度配置領(lǐng)域，尤其涉及一種消費者隊列的調(diào)度方法及系統(tǒng)。

背景技術(shù)

如今，伴隨著互聯(lián)網(wǎng)技術(shù)的飛速發(fā)展，產(chǎn)生了大量的消費者請求，所述消費者請求存儲在消費者隊列中，依據(jù)機器集群對所述消費者隊列的每一個消費者請求進行調(diào)度。所述機器集群包含多個消費者機器，每一個消費者機器都可以處理預(yù)設(shè)的調(diào)度閾值的消費者請求，所述調(diào)度閾值是預(yù)先寫入消費者機器配置文件的一個固定值，對所述調(diào)度閾值的調(diào)整只能通過修改配置文件的方式。

發(fā)明人對現(xiàn)有的消費者隊列的調(diào)度過程進行研究發(fā)現(xiàn)，由于消費者隊列的消費者請求的數(shù)量是變化的時，固定的調(diào)度閾值不能滿足消費者隊列不斷的變化，需要不斷的修改配置文件調(diào)整所述調(diào)度閾值，所述調(diào)度閾值的調(diào)整方式不靈活，耗時長，導(dǎo)致消費者隊列的調(diào)度的效率低。

發(fā)明內(nèi)容

有鑒于此，本發(fā)明提供一種消費者隊列的調(diào)度方法及系統(tǒng)，用以解決現(xiàn)有技術(shù)中由于消費者隊列的消費者請求的數(shù)量是變化的時，固定的調(diào)度閾值不能滿足消費者隊列不斷的變化，需要不斷的修改配置文件調(diào)整所述調(diào)度閾值，所述調(diào)度閾值的調(diào)整方式不靈活，耗時長，導(dǎo)致消費者隊列的調(diào)度的效率低的問題，具體方案如下：

一種消費者隊列的調(diào)度方法，包括：

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

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

依據(jù)所述消費者配置和所述消費者機器配置確定每一個消費者機器的調(diào)度閾值；

依據(jù)所述調(diào)度閾值，將所述目標消費者隊列中的消費者調(diào)度給所述消費者機器。

上述的方法，優(yōu)選的，還包括：

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

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

上述的方法，優(yōu)選的，依據(jù)所述消費者配置和所述消費者機器配置確定每一個消費者機器的機器配置包括：

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

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

將所述消費者數(shù)量依據(jù)所述消費者機器數(shù)量進行平均分配，得到每一個消費者機器的調(diào)度閾值。

上述的方法，優(yōu)選的，還包括：

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

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

上述的方法，優(yōu)選的，還包括：

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

一種消費者隊列的調(diào)度系統(tǒng)，包括：