[發(fā)明專(zhuān)利]一種渠道消息通知的方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202011555871.1
• 申請(qǐng)日: 2020-12-24
• 公開(kāi)（公告）號(hào): CN114675981A
• 公開(kāi)（公告）日: 2022-06-28
• 發(fā)明（設(shè)計(jì)）人: 曾小虎;劉小瓏;姚連洲;張大志
• 申請(qǐng)（專(zhuān)利權(quán)）人: 廣東飛企互聯(lián)科技股份有限公司
• 主分類(lèi)號(hào): G06F9/54
• 分類(lèi)號(hào): G06F9/54
• 代理公司: 廣州駿思知識(shí)產(chǎn)權(quán)代理有限公司 44425
• 代理人: 潘桂生

1.一種渠道消息通知的方法，其特征在于，包括：

S1：消息中心系統(tǒng)將收到的消息同步至Kafaka消息隊(duì)列中；

S2：消息中心系統(tǒng)存儲(chǔ)分解后的消息，將消息的發(fā)送通知發(fā)送到Kafaka消息隊(duì)列中，其中，所述分解后的消息包括發(fā)送消息的渠道和最終用戶ID；

S3：消息中心系統(tǒng)根據(jù)預(yù)先記錄的渠道的類(lèi)型和用戶ID在線狀態(tài)發(fā)送對(duì)應(yīng)的分解消息到Kafaka消息隊(duì)列中；

S4：Kafaka消息隊(duì)列將分解后的消息根據(jù)相應(yīng)的渠道的類(lèi)型和用戶ID在線狀態(tài)發(fā)送給用戶。

2.根據(jù)權(quán)利要求1所述的一種渠道消息通知的方法，其特征在于，所述消息中心系統(tǒng)將收到的消息同步至Kafaka消息隊(duì)列中，包括：

消息中心系統(tǒng)的API中心接收到業(yè)務(wù)渠道的原始消息，根據(jù)消息規(guī)范進(jìn)行校驗(yàn)，原始消息校驗(yàn)通過(guò)后，發(fā)送原始消息到Kafaka消息隊(duì)列中。

3.根據(jù)權(quán)利要求1所述的一種渠道消息通知的方法，其特征在于，所述消息中心系統(tǒng)存儲(chǔ)分解后的消息，將消息的發(fā)送通知發(fā)送到Kafaka消息隊(duì)列中，包括：

當(dāng)Kafaka消息隊(duì)列收到原始消息時(shí)，Kafaka消息隊(duì)列將原始消息發(fā)送到消息中心系統(tǒng)中的消息分解服務(wù)，根據(jù)消息中心系統(tǒng)中的數(shù)據(jù)庫(kù)預(yù)存的渠道的類(lèi)型列表和用戶ID列表，消息分解服務(wù)對(duì)原始消息進(jìn)行拆解，從所述原始消息中拆解獲得發(fā)送消息的渠道和最終用戶ID，消息分解服務(wù)先存儲(chǔ)原始消息和拆解消息到數(shù)據(jù)庫(kù)，再將消息的發(fā)送通知發(fā)送到Kafaka消息隊(duì)列中。

4.根據(jù)權(quán)利要求1所述的一種渠道消息通知的方法，其特征在于，所述消息中心系統(tǒng)根據(jù)記錄的渠道的類(lèi)型和用戶ID在線狀態(tài)發(fā)送分解消息到Kafaka消息隊(duì)列中，包括：

當(dāng)Kafaka消息隊(duì)列收到消息的發(fā)送通知時(shí)，Kafaka消息隊(duì)列發(fā)送消息的發(fā)送通知到消息中心系統(tǒng)中的消息調(diào)度服務(wù)；消息調(diào)度服務(wù)通過(guò)消息中心系統(tǒng)的API中心獲取消息中心系統(tǒng)的數(shù)據(jù)庫(kù)的分解消息和在線的用戶，來(lái)判斷發(fā)送消息的渠道的類(lèi)型和所述用戶ID在線狀態(tài)；當(dāng)用戶在線時(shí)，消息調(diào)度服務(wù)發(fā)送渠道用戶相應(yīng)渠道分解信息到Kafaka的消息隊(duì)列中，并記錄消息發(fā)送狀態(tài)為已發(fā)送；非在線渠道用戶則記錄相應(yīng)渠道分解消息狀態(tài)為未發(fā)送，消息調(diào)度服務(wù)等待用戶上線后再發(fā)送消息。

5.根據(jù)權(quán)利要求1所述的一種渠道消息通知的方法，其特征在于，所述Kafaka消息隊(duì)列將分解后的消息根據(jù)渠道的類(lèi)型和用戶ID在線狀態(tài)發(fā)送給用戶，包括：

當(dāng)Kafaka消息隊(duì)列收到相應(yīng)渠道訂閱的分解消息時(shí)，Kafaka消息隊(duì)列把分解消息發(fā)送給發(fā)送服務(wù)，發(fā)送服務(wù)把分解消息發(fā)送給用戶，發(fā)送成功則更新發(fā)送狀態(tài)為已成功；當(dāng)消息中心系統(tǒng)判斷是用戶是離線狀態(tài)時(shí)，則記錄渠道用戶ID為離線狀態(tài)，記錄消息狀態(tài)為發(fā)送失敗，消息等待用戶上線后再發(fā)送。

6.一種渠道消息通知的裝置，其特征在于，包括：

消息接收模塊，用于將收到的消息同步至Kafaka消息隊(duì)列中；

消息分解服務(wù)模塊，用于存儲(chǔ)分解后的消息，將消息的發(fā)送通知發(fā)送到Kafaka消息隊(duì)列中；

消息調(diào)度服務(wù)模塊，用于根據(jù)預(yù)先記錄的渠道的類(lèi)型和用戶ID在線狀態(tài)發(fā)送對(duì)應(yīng)的分解消息到Kafaka消息隊(duì)列中；

消息發(fā)送服務(wù)模塊，用于把Kafaka消息隊(duì)列中分解后的消息根據(jù)相應(yīng)的渠道的類(lèi)型和用戶ID在線狀態(tài)發(fā)送給用戶。

7.根據(jù)權(quán)利要求6所述的一種渠道消息通知的裝置，其特征在于，消息接收模塊，包括：

API中心單元，用于接收到業(yè)務(wù)渠道的原始消息，根據(jù)消息規(guī)范對(duì)原始消息進(jìn)行校驗(yàn)；

Kafaka單元，用于運(yùn)行Kafaka消息對(duì)列，接收發(fā)送消息。

8.根據(jù)權(quán)利要求6所述的一種渠道消息通知的裝置，其特征在于，消息分解服務(wù)模塊，包括：

數(shù)據(jù)庫(kù)單元，用于存儲(chǔ)原始消息和拆解消息；

消息分解服務(wù)單元，用于根據(jù)消息中心系統(tǒng)中的數(shù)據(jù)庫(kù)預(yù)存的渠道的類(lèi)型列表和用戶ID列表，對(duì)原始消息進(jìn)行拆解，從所述原始消息中拆解獲得發(fā)送消息的渠道和最終用戶ID。