[發明專利]基于消息隊列的業務處理方法、裝置、設備及存儲介質

在審

• 申請號: 202011577513.0
• 申請日: 2020-12-28
• 公開（公告）號: CN112527534A
• 公開（公告）日: 2021-03-19
• 發明（設計）人: 李澤青
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/22;G06F21/62
• 代理公司: 北京市京大律師事務所 11321
• 代理人: 姚維

1.一種基于消息隊列的業務處理方法，其特征在于，所述基于消息隊列的業務處理方法包括：

獲取業務消息訪問請求，根據預設白名單列表和預設讀寫權限列表對所述業務消息訪問請求進行校驗，得到校驗結果，所述業務消息訪問請求具有唯一的業務消息標識；

當所述校驗結果為校驗失敗時，生成包含訪問權限存在異常的警示信息，對所述警示信息進行日志記錄，并向消息生產終端發送所述警示信息；

當所述校驗結果為校驗成功時，獲取目標消息隊列的消息消費狀態，若所述目標消息隊列的消息消費狀態為堵塞狀態，則生成并返回包含消息隊列存在異常的提示信息，并通過預設熔斷限流策略重新處理所述業務消息訪問請求；

在對所述業務消息訪問請求處理過程中，基于所述業務消息標識生成消息軌跡數據，并將所述消息軌跡數據發送至目標終端，以使得所述目標終端按照所述消息軌跡數據繪制并展示對應的消息軌跡點序列。

2.根據權利要求1所述的基于消息隊列的業務處理方法，其特征在于，所述獲取業務消息訪問請求，根據預設白名單列表和預設讀寫權限列表對所述業務消息訪問請求進行校驗，得到校驗結果，所述業務消息訪問請求具有唯一的業務消息標識，包括：

監聽并攔截業務消息訪問請求，對所述業務消息訪問請求進行參數解析，得到消息生產終端地址和目標業務系統編號，所述業務消息訪問請求具有唯一的業務消息標識；

判斷所述消息生產終端地址和所述目標業務系統編號是否存在于預設白名單列表中；

若所述消息生產終端地址或所述目標業務系統編號不存在于預設白名單列表中，則獲取校驗結果，并確定所述校驗結果為校驗失敗；

若所述消息生產終端地址和所述目標業務系統編號均存在于預設白名單列表中，則獲取目標消息主題和目標消息標簽，并判斷所述目標消息主題和所述目標消息標簽是否存在于預設讀寫權限列表中；

若所述目標消息主題或所述目標消息標簽不存在于預設讀寫權限列表中，則獲取校驗結果，并確定所述校驗結果為校驗失?。?/p>

若所述目標消息主題和所述目標消息標簽均存在于預設讀寫權限列表中，則獲取校驗結果，并確定所述校驗結果為校驗成功。

3.根據權利要求1所述的基于消息隊列的業務處理方法，其特征在于，所述當所述校驗結果為校驗成功時，獲取目標消息隊列的消息消費狀態，若所述目標消息隊列的消息消費狀態為堵塞狀態，則生成并返回包含消息隊列存在異常的提示信息，并通過預設熔斷限流策略重新處理所述業務消息訪問請求，包括：

當所述校驗結果為校驗成功時，根據所述業務消息標識確定目標消息隊列，獲取目標消息隊列的消息消費狀態，并判斷所述目標消息隊列的消息消費狀態是否為堵塞狀態，所述目標消息隊列用于存儲并處理所接收的業務消息訪問請求；

若所述目標消息隊列的消息消費狀態為堵塞狀態，則生成并返回包含消息隊列存在異常的提示信息，以使得所述消息生產終端按照所述提示消息重新發送所述業務消息訪問請求；

從預設數據配置表中讀取目標消息隊列的預設熔斷限流策略，通過所述預設熔斷限流策略熔斷所述目標消息隊列對消息生產終端的消息服務，并通過其他消息隊列對所述消息生產終端重新發送的業務消息訪問請求進行業務處理。

4.根據權利要求3所述的基于消息隊列的業務處理方法，其特征在于，所述若所述目標消息隊列的消息消費狀態為堵塞狀態，則生成并返回包含消息隊列存在異常的提示信息，以使得所述消息生產終端按照所述提示消息重新發送所述業務消息訪問請求，包括：

若所述目標消息隊列的消息消費狀態為堵塞狀態，則根據所述業務消息標識和結構化查詢語言語法規則生成查詢語句，執行所述查詢語句，得到目標消息隊列對應的隊列標識；

獲取堵塞錯誤碼和錯誤類型，按照所述隊列標識、所述堵塞錯誤碼和所述錯誤類型設置包含消息隊列存在異常的提示信息，并將所述提示信息推送至所述消息生產終端，以使得所述消息生產終端按照所述提示消息重新發送所述業務消息訪問請求。