[發(fā)明專利]聊天室的消息分發(fā)方法、消息分發(fā)系統(tǒng)及電子設(shè)備

有效

• 申請?zhí)枺?/td>: 202011250536.0
• 申請日: 2020-11-10
• 公開（公告）號: CN112436997B
• 公開（公告）日: 2023-03-03
• 發(fā)明（設(shè)計）人: 羅斌;常賽賽
• 申請（專利權(quán)）人: 杭州米絡(luò)星科技（集團(tuán)）有限公司
• 主分類號: H04L51/04
• 分類號: H04L51/04;H04L9/40;H04L12/18
• 代理公司: 北京超凡宏宇專利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 安衛(wèi)靜

本發(fā)明提供了一種聊天室的消息分發(fā)方法、消息分發(fā)系統(tǒng)及電子設(shè)備，該方法應(yīng)用于消息分發(fā)系統(tǒng)，消息分發(fā)系統(tǒng)包括多個接入服務(wù)器、邏輯服務(wù)器、至少一個消息隊列服務(wù)器和多個任務(wù)服務(wù)器；包括：通過客戶端接入的接入服務(wù)器將接收到的客戶端輸入的消息發(fā)送到邏輯服務(wù)器；其中，消息攜帶有標(biāo)識，標(biāo)識包括接收消息的客戶端接入的接入服務(wù)器對應(yīng)的服務(wù)器身份；通過邏輯服務(wù)器將消息發(fā)送到至少一個消息隊列服務(wù)器；通過消息隊列服務(wù)器將消息發(fā)送到至少一個任務(wù)服務(wù)器；通過任務(wù)服務(wù)器將接收到的消息分發(fā)至標(biāo)識對應(yīng)的接入服務(wù)器，以使接入服務(wù)器將消息發(fā)送到目標(biāo)客戶端。本發(fā)明可以避免在數(shù)據(jù)量過大時，消息分發(fā)失敗的問題。

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

本發(fā)明涉及通信技術(shù)領(lǐng)域，尤其是涉及一種聊天室的消息分發(fā)方法、消息分發(fā)系統(tǒng)及電子設(shè)備。

背景技術(shù)

隨著互聯(lián)網(wǎng)技術(shù)的高速發(fā)展，聊天室作為一種新興的通信方式，在平時的休閑娛樂和工作中都得到了廣泛的應(yīng)用。對于直播聊天室，用戶每發(fā)送一條消息，該消息會通過服務(wù)器分發(fā)至聊天室中的其他用戶。現(xiàn)有技術(shù)中，通常是客戶端通過接入服務(wù)器將消息(攜帶有標(biāo)識)上傳到與該接入服務(wù)器對應(yīng)連接的hub(多端口轉(zhuǎn)發(fā)器)服務(wù)器，該hub服務(wù)器將該消息發(fā)送至logic服務(wù)器(邏輯服務(wù)器)，logic服務(wù)器接收到消息后，根據(jù)該消息攜帶的標(biāo)識將該消息發(fā)至對應(yīng)的hub服務(wù)器，最后對應(yīng)的hub服務(wù)器將該消息發(fā)送到目標(biāo)客戶端所對應(yīng)的接入服務(wù)器。但是，采用上述方式進(jìn)行消息分發(fā)時，當(dāng)數(shù)據(jù)量過大時，例如超過hub服務(wù)器容量，會導(dǎo)致消息分發(fā)失敗。

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

有鑒于此，本發(fā)明的目的在于提供一種聊天室的消息分發(fā)方法、消息分發(fā)系統(tǒng)及電子設(shè)備，以避免了在數(shù)據(jù)量過大時，消息分發(fā)失敗的問題。

為了實(shí)現(xiàn)上述目的，本發(fā)明實(shí)施例采用的技術(shù)方案如下：

第一方面，本發(fā)明實(shí)施例提供了一種聊天室的消息分發(fā)方法，方法應(yīng)用于消息分發(fā)系統(tǒng)，消息分發(fā)系統(tǒng)包括多個接入服務(wù)器、邏輯服務(wù)器、至少一個消息隊列服務(wù)器和多個任務(wù)服務(wù)器；包括：通過客戶端接入的接入服務(wù)器將接收到的客戶端輸入的消息發(fā)送到邏輯服務(wù)器；其中，消息攜帶有標(biāo)識，標(biāo)識包括接收消息的客戶端接入的接入服務(wù)器對應(yīng)的服務(wù)器身份；通過邏輯服務(wù)器將消息發(fā)送到至少一個消息隊列服務(wù)器；通過消息隊列服務(wù)器將消息發(fā)送到至少一個任務(wù)服務(wù)器；通過任務(wù)服務(wù)器將接收到的消息分發(fā)至標(biāo)識對應(yīng)的接入服務(wù)器，以使接入服務(wù)器將消息發(fā)送到目標(biāo)客戶端。

在一種實(shí)施方式中，上述方法還包括：當(dāng)客戶端登陸直播間時，通過邏輯服務(wù)器生成會話標(biāo)識；其中，會話標(biāo)識包括客戶端的秘鑰和客戶端接入的接入服務(wù)器的服務(wù)器身份。

在一種實(shí)施方式中，通過客戶端接入的接入服務(wù)器將接收到的客戶端輸入的消息發(fā)送到邏輯服務(wù)器的步驟，包括：通過客戶端接入的接入服務(wù)器，根據(jù)預(yù)設(shè)的分發(fā)策略將接收到的客戶端輸入的消息發(fā)送到邏輯服務(wù)器。

在一種實(shí)施方式中，通過邏輯服務(wù)器將消息發(fā)送到至少一個消息隊列服務(wù)器的步驟，包括：根據(jù)消息隊列服務(wù)器的預(yù)設(shè)邏輯確定接收消息的至少一個目標(biāo)消息隊列服務(wù)器和消息的存儲方式；其中，存儲方式包括隨機(jī)存儲和/或按消息的發(fā)送時間順序存儲；通過邏輯服務(wù)器將消息發(fā)送到目標(biāo)消息隊列服務(wù)器，并根據(jù)存儲方式進(jìn)行存儲。

在一種實(shí)施方式中，通過消息隊列服務(wù)器將消息發(fā)送到至少一個任務(wù)服務(wù)器的步驟，包括：根據(jù)目標(biāo)消息隊列服務(wù)器獲取的任務(wù)服務(wù)器的數(shù)量，通過目標(biāo)消息隊列服務(wù)器按照預(yù)設(shè)的分發(fā)策略將消息分發(fā)到至少一個任務(wù)服務(wù)器。

在一種實(shí)施方式中，上述方法還包括：當(dāng)客戶端登陸直播間時，將客戶端的令牌發(fā)送至邏輯服務(wù)器；其中，令牌是由Java服務(wù)器在用戶注冊時發(fā)送給客戶端的；通過邏輯服務(wù)器調(diào)用遠(yuǎn)程過程調(diào)用協(xié)議接口在Java服務(wù)器中查找令牌是否存在，如果存在，校驗(yàn)通過允許客戶端登陸直播間。

在一種實(shí)施方式中，預(yù)設(shè)的分發(fā)策略包括以下中的一種或多種：加權(quán)輪詢策略、加權(quán)隨機(jī)策略、一致性哈希策略、最小連接數(shù)燈策略。