[發(fā)明專利]一種用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201911377949.2
• 申請日: 2019-12-27
• 公開（公告）號: CN113051083A
• 公開（公告）日: 2021-06-29
• 發(fā)明（設計）人: 江竟敏;張鵬;應機;閆大強
• 申請（專利權）人: 浙江金融資產(chǎn)交易中心股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 浙江專橙律師事務所 33313
• 代理人: 邢萬里

1.一種用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)，其特征在于，包括：

消息生成模塊，其包含n個子系統(tǒng)，數(shù)量n根據(jù)需要設定，用于從消息表中查詢待發(fā)送消息，以及從數(shù)據(jù)庫中獲取待發(fā)送的匯總消息，并對消息進行解析、驗證和拆分明細后發(fā)送到消息隊列服務器；

內(nèi)部管理模塊，其包含n個子系統(tǒng)，用于維護基礎參數(shù)和數(shù)據(jù)字典，提供發(fā)送消息的頁面入口，提供消息發(fā)送的查詢?nèi)肟冢瑑?nèi)部管理模塊內(nèi)部配置消息通道，使用自定義簽名和約定簽名兩種模式，根據(jù)消息業(yè)務類型選擇對應模式的消息發(fā)送通道；

消息處理模塊，其包含n個子系統(tǒng)，用于從消息隊列服務器中獲取待發(fā)送的消息明細情況，調(diào)用消息發(fā)送接口進行消息發(fā)送，內(nèi)部第三方消息需求系統(tǒng)調(diào)用接口，在所述內(nèi)部管理模塊上獲取待發(fā)送消息，并根據(jù)消息類型調(diào)用對應的消息接口，發(fā)送消息；

其中，所述三大模塊，都包括消息高并發(fā)處理系統(tǒng)，其采用異步處理消息隊列服務器機制，用于高并發(fā)的消息發(fā)送，根據(jù)業(yè)務實際并發(fā)量對服務器進行橫行擴展；包括消息隊列服務器服務器，用于緩存待發(fā)送的消息；還包括消息通道切換系統(tǒng)，其用于對接多個消息通道，并根據(jù)消息發(fā)送失敗率動態(tài)切換消息通道；所述消息通道切換系統(tǒng)還包括可達性驗證機制，用于實現(xiàn)通道智能管理。

2.根據(jù)權利要求1所述的用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)，其特征在于，其內(nèi)部管理模塊維護的基礎參數(shù)包括：消息類型、模板、用戶群組、黑名單等涉及維護過程的關鍵信息；消息隊列服務器使用主從模式，當消息隊列服務器性能不能滿足要求時，通過增加消息隊列服務器節(jié)點，部署集群模式恢復解決性能問題；通過在內(nèi)部管理子系統(tǒng)的頁面上發(fā)送消息；消息生成模塊實時查詢待發(fā)送消息；消息處理模塊實時從消息隊列服務器中獲取待發(fā)送的消息，并根據(jù)消息類型調(diào)用對應的消息接口進行消息發(fā)送；消息生成模塊和消息處理模塊采用橫向擴展模式，根據(jù)實際業(yè)務量部署節(jié)點。

3.根據(jù)權利要求2所述的用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)，其特征在于，除了通過在內(nèi)部管理模塊的內(nèi)部管理子系統(tǒng)的頁面上發(fā)送消息，也可以通過系統(tǒng)提供的接口進行聯(lián)機發(fā)送，消息發(fā)送請求接收后進行數(shù)據(jù)校驗，然后存入數(shù)據(jù)庫，后續(xù)的消息發(fā)送的過程為異步處理的過程；消息生成模塊實時查詢待發(fā)送消息：消息生成模塊的消息生成子系統(tǒng)啟動定時任務，實現(xiàn)實時從數(shù)據(jù)庫中獲取待發(fā)送消息，對消息做解析后發(fā)送到消息隊列服務器中；消息處理模塊實時從消息隊列服務器中獲取待發(fā)送的消息：消息處理模塊的消息處理子系統(tǒng)實時從數(shù)據(jù)庫中獲取消息，根據(jù)消息的類型選擇對應的消息發(fā)送程序，進行消息發(fā)送，消息處理子系統(tǒng)根據(jù)并發(fā)情況進行橫向擴展，部署滿足業(yè)務量要求數(shù)量的節(jié)點；每種類型的消息使用同一個消息隊列服務器，實現(xiàn)各種消息類型的隔離性與高可用性。

4.根據(jù)權利要求1所述用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)，其特征在于，實現(xiàn)高并發(fā)處理消息的過程，包括如下步驟：

1.1實現(xiàn)消息發(fā)送異步：消息生成子系統(tǒng)實時從消息表中查詢待發(fā)送消息，并將消息發(fā)送到消息隊列服務器；

1.2消息隊列服務器接收待發(fā)送消息，緩存待發(fā)送的消息；

1.3消息處理子系統(tǒng)實時從消息隊列服務器中獲取待發(fā)送消息，并根據(jù)消息類型調(diào)用對應消息接口，進行消息發(fā)送；

1.4消息生成子系統(tǒng)和消息處理子系統(tǒng)支持橫向擴展，根據(jù)實際業(yè)務量部署節(jié)點。