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

有效

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

本發明公開了一種基于消息中間件的業務消息處理方法和裝置，涉及計算機技術領域。該方法的一具體實施方式包括：在應用程序以單副本模式運行時，通過主節點應用程序從消息中間件中獲取多個業務消息進行業務處理，并構建處理完成的業務消息的數據狀態；將數據狀態以事務的形式發送至消息中間件存儲；若主節點應用程序出現故障，啟動備用節點應用程序，并獲取數據狀態以確定第一標注位置，備用節點應用程序重新獲取業務消息執行業務處理，并在備用節點應用程序中重新構建數據狀態，并將第一標注位置之后的處理完成的業務消息對應的數據狀態發送至消息中間件中進行存儲。該實施方式保證了不重不丟地處理業務消息，提高了業務消息處理的精確率和效率。

技術領域

本發明涉及計算機技術領域，尤其涉及一種基于消息中間件的業務消息處理方法和裝置。

背景技術

利用應用程序進行業務消息處理時，為保障業務消息的處理效率，通常會配置備用節點應用程序，在當前節點應用程序出現故障時，執行高可用切換，切換后由備用節點應用程序執行業務處理。

相關技術中由于應用程序在處理每條業務消息時，都會構建并維持一個數據狀態，一旦當前節點應用程序崩潰，備用節點應用程序需要從頭開始處理并重新構建數據狀態，但由于應用程序在構建數據狀態的同時，還需要向下游發送消息，在從頭重新開始處理時，本地存儲的數據狀態重新構建了，但是向下游發送的消息也會重復。如何在發生高可用切換時，重建并維護數據狀態，不重不丟地處理業務消息。

發明內容

有鑒于此，本發明實施例提供一種基于消息中間件的業務消息處理方法和裝置，能夠在主節點應用程序出現故障時，啟動備用節點應用程序，快速重建數據狀態，且并不存儲重復數據，保證了不重不丟地處理業務消息，提高了業務消息處理的精確率和效率，提升了用戶體驗。

為實現上述目的，根據本發明實施例的一個方面，提供了一種基于消息中間件的業務消息處理方法，應用于執行業務消息處理的有狀態應用程序；方法包括：

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

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

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

進一步地，若應用程序以多副本模式運行，在主節點應用程序從消息中間件中獲取多個業務消息的步驟之后，方法還包括：

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

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

進一步地，若應用程序以多副本模式運行，方法還包括：

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

進一步地，第一標注位置和第二標注位置以異步的形式進行廣播；方法還包括：

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

進一步地，控制備用節點應用程序的處理進度不超過主節點應用程序的處理進度的步驟，包括：