[發明專利]一種基于消息中間件的業務消息處理方法和裝置

有效

• 申請號: 202310111779.3
• 申請日: 2023-02-09
• 公開（公告）號: CN116028245B
• 公開（公告）日: 2023-10-13
• 發明（設計）人: 侯德才;柳兆飛;史夢潔;詹廷蔚;楊歡;王勇;周慶良
• 申請（專利權）人: 中國證券登記結算有限責任公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 李召春;楊倩

1.一種基于消息中間件的業務消息處理方法，其特征在于，應用于執行業務消息處理的有狀態應用程序；所述方法包括：

在所述應用程序以單副本模式運行時，通過主節點應用程序從消息中間件中獲取多個業務消息，根據所述業務消息的業務類型進行業務處理，并構建處理完成的業務消息的數據狀態；其中，所述數據狀態指示了處理完成的業務消息對應的第一標注位置和歷史處理結果；

將處理完成的業務消息對應的所述數據狀態，以事務的形式發送至所述消息中間件中進行存儲；

若所述主節點應用程序出現故障，啟動備用節點應用程序，并利用所述備用節點應用程序獲取處理完成的業務消息對應的數據狀態，以確定所述第一標注位置，所述備用節點應用程序重新獲取所述業務消息，執行業務處理，并在所述備用節點應用程序中重新構建所述數據狀態，并將所述第一標注位置之后的處理完成的業務消息對應的數據狀態發送至所述消息中間件中進行存儲。

2.根據權利要求1所述的基于消息中間件的業務消息處理方法，其特征在于，若所述應用程序以多副本模式運行，在所述主節點應用程序從所述消息中間件中獲取多個業務消息的步驟之后，所述方法還包括：

確定所述多個業務消息組成的業務消息隊列中第一個業務消息對應的第二標注位置，根據所述業務消息的類型進行業務處理，將業務處理結果寫入消息中間件，并以異步方式構建處理完成的業務消息的數據狀態；

對所述第一標注位置和所述第二標注位置進行廣播。

3.根據權利要求2所述的基于消息中間件的業務消息處理方法，其特征在于，若所述應用程序以多副本模式運行，所述方法還包括：

在所述主節點應用程序執行業務處理時，其余備用節點應用程序分別執行相應的業務處理，并獲取所述主節點應用程序廣播的所述第一標注位置和所述第二標注位置，以控制所述備用節點應用程序的處理進度不超過所述主節點應用程序的處理進度。

4.根據權利要求2所述的基于消息中間件的業務消息處理方法，其特征在于，所述第一標注位置和所述第二標注位置以異步的形式進行廣播；所述方法還包括：

根據處理完成的業務消息所對應的數量和/或處理時長，確定所述廣播的頻率。

5.根據權利要求3所述的基于消息中間件的業務消息處理方法，其特征在于，所述控制備用節點應用程序的處理進度不超過所述主節點應用程序的處理進度的步驟，包括：

根據所述廣播指示的第一標記位置，全部備用節點應用程序分別從所述消息中間件中獲取業務消息進行業務處理，構建處理完成的業務消息的數據狀態，并確保所述處理完成的業務消息的標記位置不超過所述廣播指示的第一標記位置；其中，所述備用節點應用程序構建的數據狀態只進行本地存儲。

6.根據權利要求5所述的基于消息中間件的業務消息處理方法，其特征在于，所述方法還包括：

若所述主節點應用程序出現故障，通過ZooKeeper框架從其余備用節點應用程序中選舉出目標節點應用程序；

所述目標節點應用程序向所述消息中間件寫入指示了目標節點應用程序編號的目標消息；

所述目標節點應用程序從所述消息中間件中獲取所述第二標注位置之后的業務消息，并對所述業務消息進行處理，直至獲取到所述目標消息，以確定故障發生時，處理完成的業務消息的數據狀態。

7.根據權利要求1所述的基于消息中間件的業務消息處理方法，其特征在于，設置業務消息批量獲取數量閾值；所述從消息中間件中獲取業務消息的步驟包括：

根據所述業務消息批量獲取數量閾值，從所述消息中間件中獲取相應的業務消息。