[發(fā)明專利]一種聊天室消息分發(fā)方法、裝置及電子設(shè)備

有效

• 申請(qǐng)?zhí)枺?/td>: 201810039033.5
• 申請(qǐng)日: 2018-01-16
• 公開(kāi)（公告）號(hào): CN108418743B
• 公開(kāi)（公告）日: 2020-10-02
• 發(fā)明（設(shè)計(jì)）人: 石鵬
• 申請(qǐng)（專利權(quán)）人: 北京奇藝世紀(jì)科技有限公司
• 主分類號(hào): H04L12/58
• 分類號(hào): H04L12/58;H04L12/26;H04L12/18;H04L29/08
• 代理公司: 北京柏杉松知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11413
• 代理人: 項(xiàng)京;馬敬

1.一種聊天室消息分發(fā)方法，其特征在于，應(yīng)用于服務(wù)器，所述方法包括：

確定已接收的聊天消息的消息并發(fā)量，并判斷所述消息并發(fā)量是否大于或等于預(yù)設(shè)并發(fā)量閾值；

在所述消息并發(fā)量大于或等于所述預(yù)設(shè)并發(fā)量閾值時(shí)，將所述已接收的聊天消息存儲(chǔ)在預(yù)設(shè)哈希表中；

識(shí)別存儲(chǔ)在所述預(yù)設(shè)哈希表中滿足預(yù)設(shè)條件的聊天消息，并將所識(shí)別出的滿足預(yù)設(shè)條件的聊天消息對(duì)應(yīng)的聊天室標(biāo)識(shí)信息存儲(chǔ)在預(yù)設(shè)待推送隊(duì)列中，所述預(yù)設(shè)條件為：所述預(yù)設(shè)哈希表中，任一聊天室對(duì)應(yīng)的聊天消息總條數(shù)小于或等于預(yù)設(shè)聊天室消息條數(shù)閾值；或者，任一聊天室的消息推送等待時(shí)長(zhǎng)小于或等于預(yù)設(shè)等待時(shí)長(zhǎng)閾值；

按照預(yù)設(shè)輪詢周期，輪詢所述預(yù)設(shè)待推送隊(duì)列，并按照所述預(yù)設(shè)待推送隊(duì)列中的聊天室標(biāo)識(shí)信息，從所述預(yù)設(shè)哈希表中獲取與各聊天室標(biāo)識(shí)信息對(duì)應(yīng)的聊天消息，并將所獲取的聊天消息發(fā)送至對(duì)應(yīng)的用戶終端。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述判斷所述消息并發(fā)量是否大于或等于預(yù)設(shè)并發(fā)量閾值之后，所述方法還包括：

在所述消息并發(fā)量小于所述預(yù)設(shè)并發(fā)量閾值時(shí)，將所述已接收的聊天消息發(fā)送至對(duì)應(yīng)的用戶終端。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將所述已接收的聊天消息存儲(chǔ)在預(yù)設(shè)哈希表中，包括：

針對(duì)每條聊天消息，以該聊天消息所屬的聊天室標(biāo)識(shí)信息為關(guān)鍵字，以該聊天消息為與該關(guān)鍵字對(duì)應(yīng)的鍵值，將該聊天消息存儲(chǔ)在預(yù)設(shè)哈希表中。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，在將所述已接收的聊天消息存儲(chǔ)在預(yù)設(shè)哈希表中之后，所述方法還包括：

識(shí)別存儲(chǔ)在所述預(yù)設(shè)哈希表中不滿足預(yù)設(shè)條件的聊天消息，將所述不滿足預(yù)設(shè)條件的聊天消息發(fā)送至對(duì)應(yīng)的用戶終端。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將所識(shí)別出的滿足預(yù)設(shè)條件的聊天消息對(duì)應(yīng)的聊天室標(biāo)識(shí)信息存儲(chǔ)在預(yù)設(shè)待推送隊(duì)列中，包括：

將所識(shí)別出的滿足預(yù)設(shè)條件的聊天消息對(duì)應(yīng)的聊天室標(biāo)識(shí)信息取模，得到取模后的聊天室標(biāo)識(shí)信息；

將所述取模后的聊天室標(biāo)識(shí)信息存儲(chǔ)在預(yù)設(shè)待推送隊(duì)列中。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述按照預(yù)設(shè)輪詢周期，輪詢所述預(yù)設(shè)待推送隊(duì)列，并按照所述預(yù)設(shè)待推送隊(duì)列中的聊天室標(biāo)識(shí)信息，從所述預(yù)設(shè)哈希表中獲取與各聊天室標(biāo)識(shí)信息對(duì)應(yīng)的聊天消息，并將所獲取的聊天消息發(fā)送至對(duì)應(yīng)的用戶終端，包括：

按照預(yù)設(shè)輪詢周期，以預(yù)設(shè)并行度輪詢所述預(yù)設(shè)待推送隊(duì)列中的各聊天室標(biāo)識(shí)信息；

從所述預(yù)設(shè)哈希表中，獲取與所述各聊天室標(biāo)識(shí)信息對(duì)應(yīng)的聊天消息，并將與任一聊天室標(biāo)識(shí)信息對(duì)應(yīng)的聊天消息，發(fā)送至與該聊天室標(biāo)識(shí)信息對(duì)應(yīng)的用戶終端。

7.根據(jù)權(quán)利要求1-6任一項(xiàng)所述的方法，其特征在于，所述將所獲取的聊天消息發(fā)送至對(duì)應(yīng)的用戶終端包括：

對(duì)所獲取的聊天消息進(jìn)行序列化和壓縮，得到壓縮后的聊天消息，并將所述壓縮后的聊天消息發(fā)送至對(duì)應(yīng)的用戶終端。