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

在審

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

本發(fā)明公開了一種用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)，包括：消息生成模塊，用于從消息表中查詢待發(fā)送消息，從數(shù)據(jù)庫中獲取待發(fā)送的匯總消息，并對消息進(jìn)行解析、驗證和拆分明細(xì)；內(nèi)部管理模塊，用于維護(hù)基礎(chǔ)參數(shù)和數(shù)據(jù)字典，提供發(fā)送消息頁面入口，提供消息發(fā)送查詢?nèi)肟?；消息處理模塊，用于從消息隊列服務(wù)器中獲取待發(fā)送消息明細(xì)，調(diào)用具體類型的消息發(fā)送接口進(jìn)行消息發(fā)送，并且提供接口供內(nèi)部第三方系統(tǒng)調(diào)用。本發(fā)明的消息系統(tǒng)基于消息隊列服務(wù)器異步機(jī)制，支持高并發(fā)的消息發(fā)送，系統(tǒng)根據(jù)業(yè)務(wù)實際并發(fā)量對服務(wù)器進(jìn)行橫行擴(kuò)展，可根據(jù)消息發(fā)送失敗率動態(tài)切換消息通道，實現(xiàn)高效發(fā)送短信、站內(nèi)信、郵件、APP Push和服務(wù)號等五種常用的消息類型。

技術(shù)領(lǐng)域

本發(fā)明屬于通信技術(shù)領(lǐng)域，具體涉及一種用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)。

背景技術(shù)

隨著互聯(lián)網(wǎng)技術(shù)的發(fā)展，互聯(lián)網(wǎng)金融也逐漸興起，但同時面對安全性差、業(yè)務(wù)擴(kuò)展能力不強，維護(hù)成本高以及在高并發(fā)的情況下的系統(tǒng)故障等問題。隨著通信技術(shù)的不斷發(fā)展和成熟，移動業(yè)務(wù)逐漸覆蓋到各行各業(yè)的信息化應(yīng)用中，在互聯(lián)網(wǎng)金融中，通過通信技術(shù)提高了金融企業(yè)中業(yè)務(wù)平臺和運營商之間的有效交互，進(jìn)而提高了金融企業(yè)的業(yè)務(wù)效率。一般情況下，企業(yè)消息平臺都有短信、服務(wù)號推送、站內(nèi)信、APP推送、郵件等消息發(fā)送需求，企業(yè)就需要構(gòu)建維護(hù)自己的消息信息業(yè)務(wù)系統(tǒng)。

隨著移動通信業(yè)務(wù)中的消息信息業(yè)務(wù)日益普及，其業(yè)務(wù)量迅速發(fā)展，所以消息的應(yīng)用系統(tǒng)必須在當(dāng)前的硬件基礎(chǔ)措施上，有效利用軟件系統(tǒng)資源來推送消息信息業(yè)務(wù)，但在硬件基礎(chǔ)措施一定的情況下，如何使用軟件系統(tǒng)把大量的消息信息在最短的時間內(nèi)推送到手機(jī)用戶并和相關(guān)運營商完成信息交互成為消息信息應(yīng)用實時性的關(guān)鍵。

應(yīng)用消息信息業(yè)務(wù)系統(tǒng)的互聯(lián)網(wǎng)分布式系統(tǒng)架構(gòu)的設(shè)計中，必須要考慮的技術(shù)因素之一是如何實現(xiàn)高并發(fā)，高并發(fā)通常指通過設(shè)計，保證系統(tǒng)能夠同時并行處理大量請求。高并發(fā)相關(guān)常用的指標(biāo)有響應(yīng)時間(Response Time)，吞吐量(Throughput)，每秒查詢率QPS(Query Per Second)，并發(fā)用戶數(shù)等。理論上，實現(xiàn)高并發(fā)的方法主要有兩種：垂直擴(kuò)展(Scale Up)與水平擴(kuò)展(Scale Out)。垂直擴(kuò)展是指提升單機(jī)處理的能力。垂直擴(kuò)展的方式有兩種：(1)增強單機(jī)硬件性能，例如：增加CPU核數(shù)、升級更好的網(wǎng)卡、升級更好的硬盤、擴(kuò)充硬盤容量和擴(kuò)充系統(tǒng)內(nèi)存；(2)提升單機(jī)架構(gòu)性能，例如：使用異步來增加單服務(wù)吞吐量。水平擴(kuò)展是指，只增加服務(wù)器的數(shù)量，就能線性擴(kuò)充系統(tǒng)的性能。高并發(fā)的設(shè)計在不同的企業(yè)中可根據(jù)實際應(yīng)用場景提出不同的方案。

在實際短信發(fā)送場景的應(yīng)用中，企業(yè)用戶使用的手機(jī)號碼歸屬各運營商的比重不一，在移動、電信和聯(lián)通這幾家運營商都有各企業(yè)的用戶。同時，有的企業(yè)與消息服務(wù)運營商開通了全網(wǎng)通協(xié)議，有的僅開通了本網(wǎng)通協(xié)議。在這種情況下，企業(yè)消息平臺需根據(jù)企業(yè)用戶使用的手機(jī)號碼類型的比重，對應(yīng)選擇與運營商消息對接的消息通道數(shù)、消息通道流量的比重。目前，有的企業(yè)的消息平臺根據(jù)路由算法、消息通道壓力、消息發(fā)送效率、消息通道流量、消息通道發(fā)送消息類型和消息通道服務(wù)協(xié)議，智能選擇消息發(fā)送通道進(jìn)行消息發(fā)送，從而提升消息平臺處理性能及運維的自動化管理，但由于技術(shù)的限制，消息平臺的通道切換的方案仍需根據(jù)實際應(yīng)用場景不斷完善。

發(fā)明內(nèi)容

本發(fā)明基于上述背景和現(xiàn)有技術(shù)存在的問題，擬設(shè)計一種用于金融資產(chǎn)交易的高并發(fā)消息處理系統(tǒng)，其能夠基于消息隊列服務(wù)器(MQ)異步機(jī)制，支持異步處理高并發(fā)的消息發(fā)送。本發(fā)明還有一個目的是通過動態(tài)切換消息通道的方法，提高消息發(fā)送的效率，以便實現(xiàn)消息高并發(fā)。

為了實現(xiàn)本發(fā)明的這些目的和其它優(yōu)點，提供了一種用于金融資產(chǎn)交易的高并發(fā)消息系統(tǒng)，其組成如下：

消息生成模塊，其包含n個子系統(tǒng)，數(shù)量n根據(jù)需要設(shè)定，用于從消息表中查詢待發(fā)送消息，以及從數(shù)據(jù)庫中獲取待發(fā)送的匯總消息，并對消息進(jìn)行解析(解析是指對表中的一條消息記錄進(jìn)行處理，得出真實的消息內(nèi)容)、驗證和拆分明細(xì)后發(fā)送到消息隊列服務(wù)器；