[發(fā)明專利]消息調(diào)度控制方法及其相應(yīng)的裝置、設(shè)備、介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110886743.3
• 申請日: 2021-08-03
• 公開（公告）號: CN113687928A
• 公開（公告）日: 2021-11-23
• 發(fā)明（設(shè)計）人: 黃育才
• 申請（專利權(quán)）人: 廣州華多網(wǎng)絡(luò)科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 廣州利能知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44673
• 代理人: 王增鑫

本申請公開一種消息調(diào)度控制方法及其相應(yīng)的裝置、設(shè)備、介質(zhì)，該方法包括：持續(xù)獲取消息隊列的下游服務(wù)的每秒請求總量及其每請求的平均執(zhí)行時長；監(jiān)聽每秒請求總量超過下游服務(wù)的每秒請求閾值時，控制當(dāng)前消息線程處于緩釋狀態(tài)，且使當(dāng)前消息線程的釋放時長根據(jù)每秒請求總量的增減狀態(tài)的維持而相應(yīng)延長或縮短；統(tǒng)計當(dāng)前消息線程相對應(yīng)的前方阻塞量，根據(jù)前方阻塞量與所述平均執(zhí)行時長的乘積計算當(dāng)前消息線程對應(yīng)的預(yù)期排隊時長；監(jiān)聽當(dāng)當(dāng)前消息線程的預(yù)期排隊時長超過預(yù)設(shè)延遲閾值時，控制當(dāng)前消息線程處于活躍狀態(tài)，將當(dāng)前消息線程交付異步執(zhí)行。本申請實現(xiàn)當(dāng)消息線程消費過快時自動降低消費速率保護下游服務(wù)，當(dāng)消費太慢時自動提升消費速度。

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

本申請實施例涉及互聯(lián)網(wǎng)任務(wù)調(diào)度技術(shù)，尤其涉及一種消息調(diào)度控制方法及其相應(yīng)的裝置、設(shè)備、介質(zhì)。

背景技術(shù)

互聯(lián)網(wǎng)應(yīng)用中經(jīng)常使用消息隊列作為中間件，一般用來實現(xiàn)服務(wù)解耦，流量削峰和異步化處理等功能。但是實際應(yīng)用中，當(dāng)生產(chǎn)大量時消費端經(jīng)常遇到兩方面的問題：一是消費太快，導(dǎo)致的結(jié)果是給下游服務(wù)造成巨大請求的壓力，甚至壓垮下游服務(wù)。下游服務(wù)也包括系統(tǒng)內(nèi)部使用的數(shù)據(jù)庫、文件系統(tǒng)等等。二是消費太慢，消息出現(xiàn)嚴(yán)重堆積，消息得不到及時消費，對業(yè)務(wù)的實時性造成影響。

當(dāng)前的業(yè)界主要的消息中間件，其消費端的配置參數(shù)都是靜態(tài)配置的，消費者啟動后不能進行動態(tài)變更，更無法隨著消息量變化按照系統(tǒng)管理者的意圖實現(xiàn)動態(tài)控制。因此，目前常見的消息隊列的消費端沒有動態(tài)控制消息消費速度的技術(shù)，以至于當(dāng)出現(xiàn)消息堆積時，只能修改配置參數(shù)重啟服務(wù)，或者通過節(jié)點擴縮容方式去解決消費太快或太慢的問題，這將導(dǎo)致部署成本的增加。

因此，根據(jù)本申請人的理解，針對消息隊列的任務(wù)調(diào)度機制，影響到互聯(lián)網(wǎng)后臺的響應(yīng)效率及部署成本，理想的狀態(tài)是實現(xiàn)消息隊列根據(jù)下游服務(wù)的負(fù)載情況進行均衡調(diào)度，期望可以由此實現(xiàn)消費的動態(tài)控制，盡可能快速便捷地解決消費太快或者消費太慢帶來的系統(tǒng)問題。

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

本申請的目的是針對現(xiàn)有技術(shù)中存在的至少部分不足或為滿足現(xiàn)有技術(shù)的至少部分需求而提供一種消息調(diào)度控制方法及其相應(yīng)的裝置、計算機設(shè)備及存儲介質(zhì)。

為解決上述技術(shù)問題，本申請采用的一個技術(shù)方案是：

本申請?zhí)峁┮环N消息調(diào)度控制方法，包括如下步驟：

持續(xù)獲取每秒請求總量及其每請求的平均執(zhí)行時長，所述每秒請求總量通過持續(xù)統(tǒng)計從消息隊列調(diào)度給下游服務(wù)的消息線程的總量而獲得，所述平均執(zhí)行時長為根據(jù)每秒請求總量計算出的每請求的平均值；

監(jiān)聽每秒請求總量的變動，當(dāng)每秒請求總量超過所述下游服務(wù)的每秒請求閾值時，控制當(dāng)前消息線程處于延緩執(zhí)行的緩釋狀態(tài)，且使當(dāng)前消息線程的釋放時長根據(jù)每秒請求總量的增減狀態(tài)的維持而相應(yīng)延長或縮短；

統(tǒng)計當(dāng)前消息線程相對應(yīng)的前方阻塞量，根據(jù)前方阻塞量與所述平均執(zhí)行時長的乘積計算當(dāng)前消息線程對應(yīng)的預(yù)期排隊時長；

監(jiān)聽預(yù)期排隊時長的變動，當(dāng)當(dāng)前消息線程的預(yù)期排隊時長超過預(yù)設(shè)延遲閾值時，控制當(dāng)前消息線程處于等待同步執(zhí)行的活躍狀態(tài)，將其釋放時長歸零，且，在當(dāng)前消息線程連續(xù)多次處于活躍狀態(tài)時，將當(dāng)前消息線程交付異步執(zhí)行。

較佳的實施例中，所述消息隊列中的每個所述的消息線程均作為所述的當(dāng)前消息線程獨立執(zhí)行本方法的各個步驟。

具體化的實施例中，監(jiān)聽每秒請求總量的變動，當(dāng)每秒請求總量超過所述下游服務(wù)的每秒請求閾值時，控制當(dāng)前消息線程處于延緩執(zhí)行的緩釋狀態(tài)，且使當(dāng)前消息線程的釋放時長根據(jù)每秒請求總量的增減狀態(tài)的維持而相應(yīng)延長或縮短，包括如下步驟：

監(jiān)聽獲取每次統(tǒng)計產(chǎn)生的每秒請求總量，比較每秒請求總量與所述下游服務(wù)的每秒請求閾值之間的差值；