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

有效

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

本發明提供了一種用于可靠交易的消息處理方法及裝置，方法包括：解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將消息報文路由至第二消息中間件；通過線程輪詢的方式獲取可讀隊列深度，并根據獲取結果派生線程處理可讀隊列中的消息報文，并將處理后的消息報文路由至第二消息中間件。本申請以多進程的方式進行線程派生，用多線程高效地處理報文收發，同時運營線程池統一管理派生出的線程，提高了報文分發效率。另外，利用樹結構的方式解析消息類型，并在配置文件中以過濾規則、適配規則兩種規則完成消息轉發后的分類放置，使得消息能夠被合理分類，達到了統一管理處理后消息的目的。

技術領域

本申請屬于消息系統處理技術領域，具體地講，涉及一種用于可靠交易的消息處理方法及裝置。

背景技術

網關又被稱為網間連接器、協議轉換器。普遍意義上的網關在網絡層以上實現網絡互連(廣域網與局域網)，適用于兩個具有不同的兩個高層協議的網絡，是復雜的網絡互聯設備。而實際上，網關亦可以使用于不同的通信協議、數據格式或語言，甚至具有異種體系結構的系統間。

在分布式服務架構中，各系統間存在大量的消息交互，簡單處理這些消息的方式即搭建一個消息中間件的集群，如Kafka、rabbitmq等，但是通過搭建消息中間件的集群的處理方式并不十分高效可靠。

發明內容

本申請提供了一種用于可靠交易的消息處理方法及裝置，以至少解決當前臨時處理消息的消息中間件的集群不適合可靠地長期處理大量消息的問題。

根據本申請的一個方面，提供了一種用于可靠交易的消息處理方法，包括：

解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將消息報文路由至第二消息中間件；

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

在一實施例中，解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將消息報文路由至第二消息中間件，包括：

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

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

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

在一實施例中，用于可靠交易的消息處理方法還包括：

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

在一實施例中，通過線程輪詢的方式獲取可讀隊列深度，并根據獲取結果派生線程處理可讀隊列中的消息報文，包括：

獲取可讀隊列深度；

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

在一實施例中，用于可靠交易的消息處理方法還包括：

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

根據本申請的另一個方面，還提供了一種用于可靠交易的消息處理裝置，包括：

解析單元，用于解析從第一消息中間件接收到的消息報文，并根據預先設置的適配規則和過濾規則將消息報文路由至第二消息中間件；

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

在一實施例中，解析單元包括：