[發明專利]基于SQL的消息隊列SDK訪問方法、系統及存儲介質

在審

• 申請號: 202211663233.0
• 申請日: 2022-12-23
• 公開（公告）號: CN115941619A
• 公開（公告）日: 2023-04-07
• 發明（設計）人: 葉智偉;廖少波
• 申請（專利權）人: 天翼云科技有限公司
• 主分類號: H04L47/62
• 分類號: H04L47/62;H04L9/40
• 代理公司: 浙江千克知識產權代理有限公司 33246
• 代理人: 汪丹琪

1.基于SQL的消息隊列SDK訪問方法，其特征在于，

包括以下步驟：

接收包含SQL請求的網絡報文；

解釋所述SQL請求，生成對應的消息隊列SDK的調用語句；

提交所述調用語句至所述消息隊列SDK，獲得調用結果；

編碼所述調用結果，生成所述網絡報文的響應報文。

2.根據權利要求1所述的基于SQL的消息隊列SDK訪問方法，其特征在于，

所述網絡報文還包括用戶驗證報文，所述用戶驗證報文包括用戶登錄名及密碼，接收所述網絡報文后，首先驗證用戶登錄名及密碼，若驗證通過，則繼續執行，反之，若驗證不通過，則生成登錄驗證失敗的響應報文。

3.根據權利要求1所述的基于SQL的消息隊列SDK訪問方法，其特征在于，

生成對應的消息隊列SDK的調用語句的方法包括：

建立SQL關鍵字與調用語句的轉換對照表；

依據所述轉換對照表獲得SQL請求的SQL關鍵字對應的調用語句；

提取所述SQL請求的參數，并填入所述調用語句，即完成調用語句的生成。

4.根據權利要求1所述的基于SQL的消息隊列SDK訪問方法，其特征在于，

提交所述調用語句至消息隊列SDK的方法包括：

建立消息服務集群和消息隊列集群，所述消息服務集群包括若干個消息服務器，所述消息隊列集群包括若干個消息隊列分片，所述消息隊列分片由所述消息隊列SDK調用；

所述消息服務集群的每個消息服務器均分配至少一個消息隊列分片；

所述消息服務集群的消息服務器接收所述調用語句，并將收到的調用語句加入所分配的一個消息隊列分片中。

5.根據權利要求4所述的基于SQL的消息隊列SDK訪問方法，其特征在于，

所述消息服務集群分配消息隊列分片的方法包括：

所述消息服務集群的消息服務器周期性投票選舉出周期內的Leader服務器；

所述Leader服務器生成所述消息隊列分片的分配方案。

6.根據權利要求5所述的基于SQL的消息隊列SDK訪問方法，其特征在于，

所述Leader服務器根據消息隊列SDK負載，動態調整所述消息隊列分片的分配方案，動態調整所述消息隊列分片的分配方案的方法包括：

所述Leader服務器監控消息隊列SDK的負載率；

根據所述消息隊列SDK的負載率，得出每個消息服務器所對應的消息隊列SDK的平均負載率，記為消息服務器的平均負載率；

平均負載率高于預設閾值的消息服務器記為高負載消息服務器，平均負載率最低的且分配兩個以上消息隊列分片的消息服務器記為富余消息服務器，從富余消息服務器的消息隊列分片中任選一個消息隊列分片分配給高負載消息服務器。

7.根據權利要求6所述的基于SQL的消息隊列SDK訪問方法，其特征在于，

消息隊列SDK的負載率包括運行消息隊列SDK的服務器的CPU使用率、消息隊列SDK的TPS及消息隊列SDK的網絡流量，所述消息隊列SDK平均負載率為每個消息服務器所對應的消息隊列SDK的平均CPU使用率、平均TPS及平均網絡流量，所述CPU使用率、所述TPS及所述網絡流量分別設置有閾值，若所述平均CPU使用率、所述平均TPS或所述平均網絡流量超過對應的閾值，則判定平均負載率高于預設閾值，反之，若所述平均CPU使用率、所述平均TPS及所述平均網絡流量均未超過對應的閾值，則判定平均負載率低于預設閾值。