[發明專利]一種用于可靠交易的消息處理方法及裝置

有效

• 申請號: 202011220870.1
• 申請日: 2020-11-05
• 公開（公告）號: CN112291254B
• 公開（公告）日: 2023-05-05
• 發明（設計）人: 請求不公布姓名
• 申請（專利權）人: 中國人民銀行清算總中心
• 主分類號: H04L69/22
• 分類號: H04L69/22;G06F9/54;H04L67/10;H04L67/562
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 黨曉林;周永君

1.一種用于可靠交易的消息處理方法，其特征在于，包括：

解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將所述消息報文路由至第二消息中間件；消息網關的啟動命令將會觸發主控程序的啟動，并將配置文件中的內容寫入到自動創建的共享內存中，根據log4j2配置設定的等級進行日志的輸出，同時，主控程序將根據配置文件并生成相應個數的進程；

通過線程輪詢的方式獲取可讀隊列深度，并根據獲取結果派生線程處理所述可讀隊列中的消息報文，并將處理后的消息報文路由至第二消息中間件。

2.根據權利要求1所述的用于可靠交易的消息處理方法，其特征在于，所述解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將所述消息報文路由至第二消息中間件，包括：

從第一消息中間件的源隊列中獲取所述消息報文；

利用樹結構對所述消息報文的名稱進行分隔和解析；

根據所述適配規則和過濾規則將分隔得到的所述消息報文的字段路由至第二消息中間件的隊列中。

3.根據權利要求2所述的用于可靠交易的消息處理方法，其特征在于，還包括：

根據預先配置的文件生成相應個數的進程用于處理所述消息報文。

4.根據權利要求3所述的用于可靠交易的消息處理方法，其特征在于，所述通過線程輪詢的方式獲取可讀隊列深度，并根據獲取結果派生線程處理所述可讀隊列中的消息報文，包括：

獲取可讀隊列深度；

若所述可讀隊列中的消息報文數量不為0，派生線程處理可讀隊列中的消息報文，派生的所述線程的數量不超過預設值。

5.根據權利要求1所述的用于可靠交易的消息處理方法，其特征在于，還包括：

當消息報文發送失敗時，將所述消息報文放至預先建立的錯誤隊列中并嘗試重新發送。

6.一種用于可靠交易的消息處理裝置，其特征在于，包括：

解析單元，用于解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將所述消息報文路由至第二消息中間件；消息網關的啟動命令將會觸發主控程序的啟動，并將配置文件中的內容寫入到自動創建的共享內存中，根據log4j2配置設定的等級進行日志的輸出，同時，主控程序將根據配置文件并生成相應個數的進程；

輪詢處理單元，用于通過線程輪詢的方式獲取可讀隊列深度，并根據獲取結果派生線程處理所述可讀隊列中的消息報文，并將處理后的消息報文路由至第二消息中間件。

7.根據權利要求6所述的用于可靠交易的消息處理裝置，其特征在于，所述解析單元包括：

消息報文獲取模塊，用于從第一消息中間件的源隊列中獲取所述消息報文；

分隔解析模塊，用于利用樹結構對所述消息報文的名稱進行分隔和解析；

路由模塊，用于根據所述適配規則和過濾規則將分隔得到的所述消息報文的字段路由至第二消息中間件的隊列中。

8.根據權利要求7所述的用于可靠交易的消息處理裝置，其特征在于，還包括：

進程生成單元，用于根據預先配置的文件生成相應個數的進程用于處理所述消息報文。

9.根據權利要求8所述的用于可靠交易的消息處理裝置，其特征在于，所述輪詢處理單元包括：

隊列深度獲取模塊，用于獲取可讀隊列深度；

輪詢模塊，用于若所述可讀隊列中的消息報文數量不為0，派生線程處理可讀隊列中的消息報文，所述派生線程數量不超過預設值。

10.根據權利要求6所述的用于可靠交易的消息處理裝置，其特征在于，還包括：

失敗重試模塊，用于當消息報文發送失敗時，將所述消息報文放至預先建立的錯誤隊列中并嘗試重新發送。