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

有效

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

1.一種聊天室的消息分發(fā)方法，所述方法應(yīng)用于消息分發(fā)系統(tǒng)，所述消息分發(fā)系統(tǒng)包括多個(gè)接入服務(wù)器、邏輯服務(wù)器、至少一個(gè)消息隊(duì)列服務(wù)器和多個(gè)任務(wù)服務(wù)器；其特征在于，包括：

通過客戶端接入的所述接入服務(wù)器將接收到的所述客戶端輸入的消息發(fā)送到所述邏輯服務(wù)器；其中，所述消息攜帶有標(biāo)識，所述標(biāo)識包括接收所述消息的客戶端接入的所述接入服務(wù)器對應(yīng)的服務(wù)器身份；

通過所述邏輯服務(wù)器將所述消息發(fā)送到至少一個(gè)所述消息隊(duì)列服務(wù)器；

通過所述消息隊(duì)列服務(wù)器將所述消息發(fā)送到至少一個(gè)所述任務(wù)服務(wù)器；其中，所述消息隊(duì)列服務(wù)器向多個(gè)所述任務(wù)服務(wù)器發(fā)送數(shù)據(jù)傳輸請求，所述任務(wù)服務(wù)器在接收到所述數(shù)據(jù)傳輸請求后根據(jù)自身的狀態(tài)確定是否響應(yīng)該數(shù)據(jù)傳輸請求，如果響應(yīng)則向所述消息隊(duì)列發(fā)送應(yīng)答信息，所述消息隊(duì)列服務(wù)器根據(jù)接收到應(yīng)答信息將所述消息發(fā)送至應(yīng)答消息對應(yīng)的所述任務(wù)服務(wù)器；

通過所述任務(wù)服務(wù)器將接收到的所述消息分發(fā)至所述標(biāo)識對應(yīng)的所述接入服務(wù)器，以使所述接入服務(wù)器將所述消息發(fā)送到目標(biāo)客戶端。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

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

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，通過所述邏輯服務(wù)器將所述消息發(fā)送到至少一個(gè)所述消息隊(duì)列服務(wù)器的步驟，包括：

根據(jù)所述消息隊(duì)列服務(wù)器的預(yù)設(shè)邏輯確定接收所述消息的至少一個(gè)目標(biāo)消息隊(duì)列服務(wù)器和所述消息的存儲方式；其中，所述存儲方式包括隨機(jī)存儲和/或按所述消息的發(fā)送時(shí)間順序存儲；

通過所述邏輯服務(wù)器將所述消息發(fā)送到所述目標(biāo)消息隊(duì)列服務(wù)器，并根據(jù)所述存儲方式進(jìn)行存儲。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述通過所述消息隊(duì)列服務(wù)器將所述消息發(fā)送到至少一個(gè)所述任務(wù)服務(wù)器的步驟，包括：

根據(jù)所述目標(biāo)消息隊(duì)列服務(wù)器獲取的所述任務(wù)服務(wù)器的數(shù)量，通過所述目標(biāo)消息隊(duì)列服務(wù)器按照預(yù)設(shè)的分發(fā)策略將所述消息分發(fā)到至少一個(gè)所述任務(wù)服務(wù)器。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

當(dāng)所述客戶端登陸直播間時(shí)，將所述客戶端的令牌發(fā)送至所述邏輯服務(wù)器；其中，所述令牌是由Java服務(wù)器在用戶注冊時(shí)發(fā)送給所述客戶端的；

通過所述邏輯服務(wù)器調(diào)用遠(yuǎn)程過程調(diào)用協(xié)議接口在所述Java服務(wù)器中查找所述令牌是否存在，如果存在，校驗(yàn)通過允許所述客戶端登陸直播間。

6.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述預(yù)設(shè)的分發(fā)策略包括以下中的一種或多種：加權(quán)輪詢策略、加權(quán)隨機(jī)策略、一致性哈希策略、最小連接數(shù)燈策略。

7.一種消息分發(fā)系統(tǒng)，其特征在于，包括多個(gè)接入服務(wù)器、邏輯服務(wù)器、至少一個(gè)消息隊(duì)列服務(wù)器和多個(gè)任務(wù)服務(wù)器；

所述接入服務(wù)器用于將接收到的客戶端輸入的消息發(fā)送到所述邏輯服務(wù)器；其中，所述消息攜帶有標(biāo)識，所述標(biāo)識包括接收所述消息的客戶端接入的所述接入服務(wù)器對應(yīng)的服務(wù)器身份；

所述邏輯服務(wù)器用于將所述消息發(fā)送到至少一個(gè)所述消息隊(duì)列服務(wù)器；

所述消息隊(duì)列服務(wù)器用于將所述消息發(fā)送到至少一個(gè)所述任務(wù)服務(wù)器；其中，所述消息隊(duì)列服務(wù)器向多個(gè)所述任務(wù)服務(wù)器發(fā)送數(shù)據(jù)傳輸請求，所述任務(wù)服務(wù)器在接收到所述數(shù)據(jù)傳輸請求后根據(jù)自身的狀態(tài)確定是否響應(yīng)該數(shù)據(jù)傳輸請求，如果響應(yīng)則向所述消息隊(duì)列發(fā)送應(yīng)答信息，所述消息隊(duì)列服務(wù)器根據(jù)接收到應(yīng)答信息將所述消息發(fā)送至應(yīng)答消息對應(yīng)的所述任務(wù)服務(wù)器；

所述任務(wù)服務(wù)器用于將接收到的所述消息分發(fā)至所述標(biāo)識對應(yīng)的所述接入服務(wù)器，以使所述接入服務(wù)器將所述消息發(fā)送到目標(biāo)客戶端。

8.一種電子設(shè)備，其特征在于，包括處理器和存儲器，所述存儲器存儲有能夠被所述處理器執(zhí)行的計(jì)算機(jī)可執(zhí)行指令，所述處理器執(zhí)行所述計(jì)算機(jī)可執(zhí)行指令以實(shí)現(xiàn)權(quán)利要求1至6任一項(xiàng)所述的方法的步驟。

9.一種計(jì)算機(jī)可讀存儲介質(zhì)，所述計(jì)算機(jī)可讀存儲介質(zhì)上存儲有計(jì)算機(jī)程序，其特征在于，所述計(jì)算機(jī)程序被處理器運(yùn)行時(shí)執(zhí)行上述權(quán)利要求1至6任一項(xiàng)所述的方法的步驟。