[發明專利]消息調度控制方法及其相應的裝置、設備、介質

在審

• 申請號: 202110886743.3
• 申請日: 2021-08-03
• 公開（公告）號: CN113687928A
• 公開（公告）日: 2021-11-23
• 發明（設計）人: 黃育才
• 申請（專利權）人: 廣州華多網絡科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 廣州利能知識產權代理事務所(普通合伙) 44673
• 代理人: 王增鑫

1.一種消息調度控制方法，其特征在于，包括如下步驟：

持續獲取每秒請求總量及其每請求的平均執行時長，所述每秒請求總量通過持續統計從消息隊列調度給下游服務的消息線程的總量而獲得，所述平均執行時長為根據每秒請求總量計算出的每請求的平均值；

監聽每秒請求總量的變動，當每秒請求總量超過所述下游服務的每秒請求閾值時，控制當前消息線程處于延緩執行的緩釋狀態，且使當前消息線程的釋放時長根據每秒請求總量的增減狀態的維持而相應延長或縮短；

統計當前消息線程相對應的前方阻塞量，根據前方阻塞量與所述平均執行時長的乘積計算當前消息線程對應的預期排隊時長；

監聽預期排隊時長的變動，當當前消息線程的預期排隊時長超過預設延遲閾值時，控制當前消息線程處于等待同步執行的活躍狀態，將其釋放時長歸零，且，在當前消息線程連續多次處于活躍狀態時，將當前消息線程交付異步執行。

2.根據權利要求1所述的消息調度控制方法，其特征在于，所述消息隊列中的每個所述的消息線程均作為所述的當前消息線程獨立執行本方法的各個步驟。

3.根據權利要求1所述的消息調度控制方法，其特征在于，監聽每秒請求總量的變動，當每秒請求總量超過所述下游服務的每秒請求閾值時，控制當前消息線程處于延緩執行的緩釋狀態，且使當前消息線程的釋放時長根據每秒請求總量的增減狀態的維持而相應延長或縮短，包括如下步驟：

監聽獲取每次統計產生的每秒請求總量，比較每秒請求總量與所述下游服務的每秒請求閾值之間的差值；

當每秒請求總量超過所述每秒請求閾值時，將當前消息線程的釋放時長置為極限執行時長與所述平均執行時長的差值而使當前消息線程進入緩釋狀態，且使當前消息線程的釋放時長根據每秒請求總量的增長狀態的維持而相應延長，所述極限執行時長為根據每秒請求閾值計算出的每請求的平均值；

當每秒請求總量低于所述每秒請求閾值的一定范圍且所述釋放時長未歸零時，使當前消息線程的釋放時長根據每秒請求總量的減少狀態的維持而相應縮短而使當前消息線程持續處于緩釋狀態。

4.根據權利要求3所述的消息調度控制方法，其特征在于，當每秒請求總量超過所述每秒請求閾值時執行的步驟中，包括如下步驟：

當每秒請求總量首次超過所述每秒請求閾值時，將預先被初始化為零值的所述釋放時長置為極限執行時長與所述平均執行時長的差值而使當前消息線程進入緩釋狀態；

當每秒請求總量連續超過所述每秒請求閾值時，將所述釋放時長累加預設定值實現微調，以使當前消息線程的釋放時長根據每秒請求總量的增長狀態的維持而相應延長。

5.根據權利要求4所述的消息調度控制方法，其特征在于，當每秒請求總量低于所述每秒請求閾值的一定范圍且所述釋放時長未歸零時執行的步驟中，將所述釋放時長累減所述預設定值實現微調，以使當前消息線程的釋放時長根據每秒請求總量的減少狀態的維持而相應縮短。

6.根據權利要求1至5中任意一項所述的消息調度控制方法，其特征在于，監聽預期排隊時長的變動，當當前消息線程的預期排隊時長超過預設延遲閾值時，控制當前消息線程處于等待同步執行的活躍狀態，將其釋放時長歸零，且，在當前消息線程連續多次處于活躍狀態時，將當前消息線程交付異步執行，包括如下步驟：

監聽獲取每次計算所得的預期排隊時長；

判斷所述預期排隊時長是否超過預設延遲閾值，當判定為超過時，將當前消息線程的釋放時長歸零而使當前消息線程處于等待同步執行的活躍狀態；

判斷所述預期排隊時長是否連續多次超過所述預設延遲閾值，若是，將當前消息線程交付用于異步消費消息線程的任務線程池以實現異步執行。

7.根據權利要求6中所述的消息調度控制方法，其特征在于，本方法還包括如下步驟：

監測所述任務線程池中的消息線程總量；

當任務線程池中的消息線程總量大于預設上限后，阻塞向其中添加所述的消息線程；

當持續多次任務線程池中的消息線程總量歸零且所述每秒請求總量低于所述每秒請求閾值時，銷毀該任務線程池。