[發明專利]基于消息隊列的同步調用方法、系統及計算機設備

在審

• 申請號: 202011605930.1
• 申請日: 2020-12-30
• 公開（公告）號: CN112685190A
• 公開（公告）日: 2021-04-20
• 發明（設計）人: 李澤青
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F9/52
• 分類號: G06F9/52;G06F9/54
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 李翔宇

1.一種基于消息隊列的同步調用方法，應用于一發送端，其特征在于，包括：

將當前消息發送至服務器，并將所述當前消息對應的當前線程根據消息ID進行上鎖以阻塞當前線程執行；其中，所述當前消息中包括消息頭和消息體，所述消息頭中包括用于標識是否為同步調用的標識值，及發送端連接信息和發送端實體信息；

接收服務器所發送與所述當前消息對應的回包消息；其中，所述回包消息中包括回包消息頭和回包消息體；

將所述回包消息與所述當前消息進行合并，得到合并消息；以及

獲取所述回包消息對應的消息ID及回包消息接收時間，根據回包消息接收時間與當前消息對應的發送時間之間的時間間隔進行對應的目標操作。

2.根據權利要求1所述的基于消息隊列的同步調用方法，其特征在于，所述獲取所述回包消息對應的消息ID及回包消息接收時間，根據回包消息接收時間與當前消息對應的發送時間之間的時間間隔進行對應的目標操作，包括：

判斷回包消息接收時間與當前消息對應的發送時間之間的時間間隔是否超出預設的等待超時時間閾值；

若回包消息接收時間與當前消息對應的發送時間之間的時間間隔未超出所述等待超時時間閾值，對所述當前線程進行解鎖；

若回包消息接收時間與當前消息對應的發送時間之間的時間間隔超出所述等待超時時間閾值，將所述回包消息進行忽略，并進行錯誤告警提示。

3.根據權利要求1所述的基于消息隊列的同步調用方法，其特征在于，所述將所述回包消息與所述當前消息進行合并，得到合并消息，包括：

將所述回包消息的回包消息頭與所述當前消息的當前消息的消息頭進行合并，并將所述所述回包消息的回包消息體與所述當前消息的當前消息的消息體進行合并，得到合并消息。

4.根據權利要求3所述的基于消息隊列的同步調用方法，其特征在于，所述將所述回包消息與所述當前消息進行合并，得到合并消息之后，還包括：

獲取所述合并消息的主題信息，將所述合并信息根據主題信息發送至服務器對應的PublishMessage接口以進行主題發布。

5.一種基于消息隊列的同步調用方法，應用于一服務器，其特征在于，包括：

接收用戶端發送的當前消息，解析所述當前消息中包括的消息頭和消息體，將所述當前消息進行本地持久化以存儲至預設的存儲區域；

將所述當前消息發送至消費者隊列；

接收消費端發送的與所述當前消息對應的回包消息，將所述回包消息進行解析得到回包消息頭和回包消息體，并將所述回包消息進行本地持久化以存儲至預設的存儲區域；

獲取所述回包消息頭中包括的發送端連接信息，根據所述發送端連接信息與對應的發送端建立連接，將所述回包消息發送至所述發送端；以及

接收發送端根據所述回包消息發送的合并消息，將所述合并消息存儲在對應的主題。

6.根據權利要求5所述的基于消息隊列的同步調用方法，其特征在于，還包括：

若接收到消費端的消費指令，將所述消費者隊列中當前排名位于首位的消息發送至消費端。

7.根據權利要求6所述的基于消息隊列的同步調用方法，其特征在于，所述根據所述發送端連接信息與對應的發送端建立連接，包括：

根據所述發送端連接信息在本地的長連接列表中搜索獲取到目標發送端的目標連接信息，與所述目標連接信息對應的發送端建立連接。

8.一種基于消息隊列的同步調用系統，其特征在于，包括服務器以及至少一發送端，所述發送端用于執行如權利要求1-4任一項所述的基于消息隊列的同步調用方法，所述服務器端用于執行如權利要求5-7任一項所述的基于消息隊列的同步調用方法。

9.一種計算機設備，所述計算機設備包括存儲器以及與所述存儲器相連的處理器；所述存儲器用于存儲計算機程序；所述處理器用于運行所述存儲器中存儲的計算機程序，以執行如權利要求1-4任一項所述基于消息隊列的同步調用方法的步驟或是執行如權利要求5-7任一項所述基于消息隊列的同步調用方法的步驟。

10.一種計算機可讀存儲介質，其特征在于，所述存儲介質存儲有計算機程序，所述計算機程序包括程序指令，所述程序指令當被處理器執行時可實現如權利要求1-4中任一項所述基于消息隊列的同步調用方法的步驟，或者是實現如權利要求5-7中任一項所述基于消息隊列的同步調用方法的步驟。