[發明專利]聊天室的消息分發方法、消息分發系統及電子設備

有效

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

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

技術領域

本發明涉及通信技術領域，尤其是涉及一種聊天室的消息分發方法、消息分發系統及電子設備。

背景技術

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

發明內容

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

為了實現上述目的，本發明實施例采用的技術方案如下：

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

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

在一種實施方式中，通過客戶端接入的接入服務器將接收到的客戶端輸入的消息發送到邏輯服務器的步驟，包括：通過客戶端接入的接入服務器，根據預設的分發策略將接收到的客戶端輸入的消息發送到邏輯服務器。

在一種實施方式中，通過邏輯服務器將消息發送到至少一個消息隊列服務器的步驟，包括：根據消息隊列服務器的預設邏輯確定接收消息的至少一個目標消息隊列服務器和消息的存儲方式；其中，存儲方式包括隨機存儲和/或按消息的發送時間順序存儲；通過邏輯服務器將消息發送到目標消息隊列服務器，并根據存儲方式進行存儲。

在一種實施方式中，通過消息隊列服務器將消息發送到至少一個任務服務器的步驟，包括：根據目標消息隊列服務器獲取的任務服務器的數量，通過目標消息隊列服務器按照預設的分發策略將消息分發到至少一個任務服務器。

在一種實施方式中，上述方法還包括：當客戶端登陸直播間時，將客戶端的令牌發送至邏輯服務器；其中，令牌是由Java服務器在用戶注冊時發送給客戶端的；通過邏輯服務器調用遠程過程調用協議接口在Java服務器中查找令牌是否存在，如果存在，校驗通過允許客戶端登陸直播間。

在一種實施方式中，預設的分發策略包括以下中的一種或多種：加權輪詢策略、加權隨機策略、一致性哈希策略、最小連接數燈策略。