[發(fā)明專利]高并發(fā)分布式消息推送系統(tǒng)及方法在審
| 申請(qǐng)?zhí)枺?/td> | 202010147053.1 | 申請(qǐng)日： | 2020-03-05 |
| 公開(kāi)（公告）號(hào)： | CN111371892A | 公開(kāi)（公告）日： | 2020-07-03 |
| 發(fā)明（設(shè)計(jì)）人： | 周海靜 | 申請(qǐng)（專利權(quán)）人： | 中國(guó)銀行股份有限公司 |
| 主分類號(hào)： | H04L29/08 | 分類號(hào)： | H04L29/08 |
| 代理公司： | 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127 | 代理人： | 薛平;谷敬麗 |
| 地址： | 100818 *** | 國(guó)省代碼： | 北京;11 |
| 權(quán)利要求書(shū)： | 查看更多 | 說(shuō)明書(shū)： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 并發(fā) 分布式 消息 推送 系統(tǒng) 方法 | ||
1.一種高并發(fā)分布式消息推送系統(tǒng)，其特征在于，包括：客戶端、業(yè)務(wù)服務(wù)器和消息處理中心服務(wù)器，所述業(yè)務(wù)服務(wù)器包括：業(yè)務(wù)接入模塊和多個(gè)業(yè)務(wù)服務(wù)模塊；
其中，所述客戶端通過(guò)所述業(yè)務(wù)接入模塊與各個(gè)業(yè)務(wù)服務(wù)模塊通信；各個(gè)業(yè)務(wù)服務(wù)模塊根據(jù)客戶端操作指令，生成一個(gè)或多個(gè)通知消息，存入Kafka消息隊(duì)列中；所述消息處理中心服務(wù)器從Kafka消息隊(duì)列中取出一個(gè)或多個(gè)通知消息，并根據(jù)各個(gè)通知消息的消息類型，調(diào)用不同的消息渠道發(fā)送各個(gè)通知消息。
2.如權(quán)利要求1所述的系統(tǒng)，其特征在于，所述消息處理中心服務(wù)器包括：消息接收模塊和消息處理模塊；
其中，所述消息接收模塊，用于從Kafka消息隊(duì)列中取出一個(gè)或多個(gè)通知消息，根據(jù)各個(gè)通知消息的消息類型，調(diào)用不同的消息渠道發(fā)送各個(gè)通知消息，并將發(fā)送成功或發(fā)送失敗的通知消息記錄到消息數(shù)據(jù)庫(kù)；
所述消息處理模塊，用于定時(shí)輪詢所述消息數(shù)據(jù)庫(kù)，查詢發(fā)送失敗的通知消息，并根據(jù)各個(gè)發(fā)送失敗的通知消息的消息類型，重新調(diào)用不同的消息渠道發(fā)送各個(gè)發(fā)送失敗的通知消息。
3.如權(quán)利要求2所述的系統(tǒng)，其特征在于，所述消息處理中心服務(wù)器還包括：消息通知模塊，與所述客戶端通信，用于從Kafka消息隊(duì)列中取出一個(gè)或多個(gè)通知消息，基于Websocket協(xié)議發(fā)送至所述客戶端。
4.如權(quán)利要求2所述的系統(tǒng)，其特征在于，所述消息處理中心服務(wù)器還包括：消息服務(wù)模塊，與所述消息數(shù)據(jù)庫(kù)連接，用于通過(guò)調(diào)用Dubbo接口的方式，提供消息查詢服務(wù)，所述消息查詢服務(wù)用于查詢所述消息數(shù)據(jù)庫(kù)中的一個(gè)或多個(gè)通知消息。
5.一種高并發(fā)分布式消息推送方法，其特征在于，包括：
通過(guò)Kafka消息隊(duì)列，接收業(yè)務(wù)服務(wù)器內(nèi)各個(gè)業(yè)務(wù)服務(wù)模塊生成的通知消息；
從Kafka消息隊(duì)列中取出一個(gè)或多個(gè)通知消息，并根據(jù)各個(gè)通知消息的消息類型，調(diào)用不同的消息渠道發(fā)送各個(gè)通知消息。
6.如權(quán)利要求5所述的方法，其特征在于，所述方法還包括：
將發(fā)送成功或發(fā)送失敗的通知消息記錄到消息數(shù)據(jù)庫(kù)；
定時(shí)輪詢所述消息數(shù)據(jù)庫(kù)，查詢發(fā)送失敗的通知消息，并根據(jù)各個(gè)發(fā)送失敗的通知消息的消息類型，重新調(diào)用不同的消息渠道發(fā)送各個(gè)發(fā)送失敗的通知消息。
7.如權(quán)利要求6所述的方法，其特征在于，所述方法還包括：
通過(guò)調(diào)用Dubbo接口的方式，提供消息查詢服務(wù)，所述消息查詢服務(wù)用于查詢所述消息數(shù)據(jù)庫(kù)中的一個(gè)或多個(gè)通知消息。
8.如權(quán)利要求5所述的方法，其特征在于，所述方法還包括：
從Kafka消息隊(duì)列中取出一個(gè)或多個(gè)通知消息，并基于Websocket協(xié)議發(fā)送至客戶端。
9.一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器、處理器及存儲(chǔ)在存儲(chǔ)器上并可在處理器上運(yùn)行的計(jì)算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)權(quán)利要求5至8任一項(xiàng)所述高并發(fā)分布式消息推送方法。
10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)存儲(chǔ)有執(zhí)行權(quán)利要求5至8任一項(xiàng)所述高并發(fā)分布式消息推送方法的計(jì)算機(jī)程序。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于中國(guó)銀行股份有限公司，未經(jīng)中國(guó)銀行股份有限公司許可，擅自商用是侵權(quán)行為。如果您想購(gòu)買(mǎi)此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請(qǐng)聯(lián)系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/202010147053.1/1.html，轉(zhuǎn)載請(qǐng)聲明來(lái)源鉆瓜專利網(wǎng)。
