[發明專利]一種異步消息容量評估方法及系統

在審

• 申請號: 202211655239.3
• 申請日: 2022-12-22
• 公開（公告）號: CN115883425A
• 公開（公告）日: 2023-03-31
• 發明（設計）人: 何燕超
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: H04L43/0882
• 分類號: H04L43/0882;H04L67/02;H04L69/163;H04L67/141
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 黃水娜

1.一種異步消息容量評估方法，其特征在于，所述方法應用于異步消息系統，所述方法包括：

當接收到發送端發送的模擬消息時，確定訂閱關系；所述模擬消息表征異步消息系統的并發處理能力、異步消息系統的響應時間的指標、資源使用率指標和消息隊列的性能數據；所述訂閱關系為在發布訂閱消息模型下，接入所述異步消息系統的所述發送端的發送和接收端的接收的訂閱關系；

根據所述訂閱關系，模擬所述訂閱關系對應的訂閱場景；

在所述訂閱場景下，將所述模擬消息發送至接收端，使所述接收端對模型消息進行容量評估，得到評估結果。

2.根據權利要求1所述的方法，其特征在于，異步消息系統的響應時間的獲取過程，包括：

以所述發送端發送第一筆消息的時間確定為時間起點，以所述接收端接收到全部消息的時間確定為時間止點；

將所述時間起點和所述時間止點作為消息發送的時間周期；

在所述時間周期內，將所述發送端發送的全部消息確定為基數；

通過所述基數計算得到異步消息系統的響應時間。

3.根據權利要求1所述的方法，其特征在于，所述在所述訂閱場景下，將所述模擬消息發送至接收端，使所述接收端對模型消息進行容量評估，得到評估結果，包括：

在所述訂閱場景下，將所述模擬消息發送至接收端，使所述接收端對模型消息進行容量評估，得到不同并發下異步消息系統的性能數據；所述性能數據至少包括系統服務器CPU的資源使用率、內存使用率和消息隊列的情況；

當監測到消息隊列處于無堆積狀態，或所述系統服務器CPU的資源使用率在預設閾值范圍內，且所述內存使用率小于預設使用率時，得到表征未達到異步消息系統的容量瓶頸的評估結果；

當監測到消息隊列處于堆積狀態、所述系統服務器CPU的資源使用率不在所述預設閾值范圍內或所述內存使用率大于等于所述預設使用率的任一條件時，得到達到異步消息系統的容量瓶頸的評估結果。

4.一種異步消息容量評估方法，其特征在于，所述方法應用于發送端，所述方法包括：

將模擬消息發送至異步消息系統，使所述異步消息系統確定訂閱關系，并通過所述訂閱關系模擬所述訂閱關系對應的訂閱場景；所述模擬消息表征異步消息系統的并發處理能力和異步消息系統的響應時間的指標；所述訂閱關系為在發布訂閱消息模型下，接入所述異步消息系統的所述發送端和接收端的訂閱關系；

在所述訂閱場景下，通過所述異步消息系統按照所述訂閱關系，將所述模擬消息發送至所述接收端，使所述接收端通過對所述訂閱場景下的模擬消息進行容量評估，得到評估結果。

5.根據權利要求4所述的方法，其特征在于，將模擬消息發送至異步消息系統的過程，包括：

確定連接類型；所述連接類型至少包括HTTP長連接的連接類型或HTTP短連接的連接類型；所述HTTP長連接的連接類型為通過同一個TCP連接來發送和接收多個HTTP請求/應答的無中斷連接；所述HTTP短連接的連接類型為每通訊一次就建立一次連接，且任務結束后就中斷的連接；

根據所述連接類型與所述異步消息系統建立連接；

在與所述異步消息系統建立連接的情況下，從預定制消息參數表中讀取新的參數信息；

獲取所述參數信息對應的參數值，并通過所述參數值替換預設模板中的字段進行實例化，得到消息體；

將所述消息體確定為模擬消息，并將所述模擬消息發送至所述異步消息系統，并判斷所述連接類型；

若所述連接類型為所述HTTP長連接的連接類型，返回執行所述根據所述連接類型與所述異步消息系統建立連接這一步驟；

若所述連接類型為所述HTTP短連接的連接類型，關閉與所述異步消息系統之間的連接。

6.一種異步消息容量評估方法，其特征在于，所述方法應用于接收端，所述方法包括：

接收異步消息系統轉發的模擬消息并記錄；所述模擬消息在訂閱場景下，通過參數值替換預設模板中的字段進行實例化得到；所述訂閱場景由在發布訂閱消息模型下，通過所述異步消息系統對發送端的發送和所述接收端的接收的訂閱關系進行模擬得到；所述模擬消息表征異步消息系統的并發處理能力、異步消息系統的響應時間的指標、資源使用率指標和消息隊列的性能數據。