[發明專利]一種聊天室進程的數據處理方法及系統

有效

• 申請號: 201910996327.1
• 申請日: 2019-10-18
• 公開（公告）號: CN110620673B
• 公開（公告）日: 2022-03-22
• 發明（設計）人: 方嘉銘
• 申請（專利權）人: 網易（杭州）網絡有限公司
• 主分類號: H04L12/18
• 分類號: H04L12/18;H04L67/1008;G06F9/50
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 莎日娜

1.一種聊天室進程的數據處理方法，其特征在于，所述聊天室進程具有對應的負載值，所述的方法包括：

創建運行分布式一致性協議的多組服務進程；所述多組服務進程包括分布式協調服務進程組，中心服務進程組，聊天服務進程組和網關服務進程組；

采用所述中心服務進程組監聽所述分布式協調服務進程組存儲的負載值，并在所述存儲的負載值滿足預設條件時生成聊天室創建請求；

采用所述聊天服務進程組響應所述聊天室創建請求創建聊天室進程；

采用所述網關服務進程組當接收到注冊請求時，依據所述存儲的負載值確定目標聊天室進程；

其中，所述采用所述網關服務進程組當接收到注冊請求時，依據所述存儲的負載值確定目標聊天室進程，包括：

采用所述網關服務進程組當接收到注冊請求時，依據所述存儲的負載值從所述聊天服務進程組中，確定用戶數量較多且未達到預設用戶數量上限值的聊天服務進程，作為目標聊天室進程。

2.根據權利要求1所述的方法，其特征在于，還包括：

采用所述聊天服務進程組檢測所述聊天室進程的實時負載值，當所述實時負載值超過第一預設閾值時，更新所述分布式協調服務進程組存儲的負載值。

3.根據權利要求1所述的方法，其特征在于，所述注冊請求攜帶用戶標識，所述方法還包括：

采用所述聊天服務進程組提取所述聊天室進程中的用戶標識，并將與所述用戶標識對應的用戶添加到所述目標聊天室進程中。

4.根據權利要求1所述的方法，其特征在于，所述采用所述網關服務進程組當接收到注冊請求時，依據所述存儲的負載值確定目標聊天室進程，還包括：

遞增所述存儲的負載值生成中間值，并判斷所述中間值是否超過第二預設閾值，若所述中間值不超過所述第二預設閾值，則將用戶注冊到所述目標聊天室進程；

若所述中間值超過所述第二預設閾值，則向所述網關服務進程組返回失敗的消息，并丟棄所述注冊請求。

5.根據權利要求1所述的方法，其特征在于，還包括：

采用所述網關服務進程組接收聊天消息，將所述聊天消息廣播到與所述聊天消息的聊天室標識對應的聊天室進程中。

6.一種聊天室進程的數據處理系統，其特征在于，所述聊天室進程具有對應的負載值，包括：

進程創建模塊，用于創建運行分布式一致性協議的多組服務進程；所述多組服務進程包括分布式協調服務進程組，中心服務進程組，聊天服務進程組和網關服務進程組；

聊天室創建請求生成模塊，用于采用所述中心服務進程組監聽所述分布式協調服務進程組存儲的負載值，并在所述存儲的負載值滿足預設條件時生成聊天室創建請求；

聊天室進程創建模塊，用于采用所述聊天服務進程組響應所述聊天室創建請求創建聊天室進程；

目標聊天室進程確定模塊，用于采用所述網關服務進程組當接收到注冊請求時，依據所述存儲的負載值確定目標聊天室進程；

其中，所述目標聊天室進程確定模塊，具體用于：

采用所述網關服務進程組當接收到注冊請求時，依據所述存儲的負載值從所述聊天服務進程組中，確定用戶數量較多且未達到預設用戶數量上限值的聊天服務進程，作為目標聊天室進程。

7.根據權利要求6所述的系統，其特征在于，還包括：

負載值更新模塊，用于采用所述聊天服務進程組檢測所述聊天室進程的實時負載值，當所述實時負載值超過第一預設閾值時，更新所述分布式協調服務進程組存儲的負載值。

8.根據權利要求6所述的系統，其特征在于，所述注冊請求攜帶用戶標識，還包括：

用戶添加模塊，用于采用所述聊天服務進程組提取所述聊天室進程中的用戶標識，并將與所述用戶標識對應的用戶添加到所述目標聊天室進程中。