[發(fā)明專利]群聊優(yōu)化方法及相關(guān)產(chǎn)品

在審

• 申請(qǐng)?zhí)枺?/td>: 202010212510.0
• 申請(qǐng)日: 2020-03-24
• 公開（公告）號(hào): CN111541555A
• 公開（公告）日: 2020-08-14
• 發(fā)明（設(shè)計(jì)）人: 鐘鑫
• 申請(qǐng)（專利權(quán)）人: 中國(guó)平安人壽保險(xiǎn)股份有限公司
• 主分類號(hào): H04L12/18
• 分類號(hào): H04L12/18;H04L29/08;H04L29/06
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 熊永強(qiáng);彭程

1.一種群聊優(yōu)化方法，其特征在于，包括：

第一服務(wù)器接收目標(biāo)第二服務(wù)器發(fā)送的群聊消息，所述群聊消息是目標(biāo)客戶端發(fā)送給第三服務(wù)器，并由所述第三服務(wù)器轉(zhuǎn)發(fā)給所述目標(biāo)第二服務(wù)器的，所述目標(biāo)客戶端為加入同一群聊組的多個(gè)客戶端中的一個(gè)，所述目標(biāo)第二服務(wù)器是所述第三服務(wù)器從與所述群聊組對(duì)應(yīng)的服務(wù)器集群中為所述客戶端分配的服務(wù)器，所述服務(wù)器集群包括至少一個(gè)第二服務(wù)器；

所述第一服務(wù)器通過消息隊(duì)列向所述服務(wù)器集群廣播所述群聊消息，以使所述服務(wù)器集群中的各個(gè)第二服務(wù)器向所述多個(gè)客戶端中各自對(duì)應(yīng)的客戶端發(fā)送所述群聊消息。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述第一服務(wù)器通過消息隊(duì)列向所述服務(wù)器集群廣播所述群聊消息之前，所述方法還包括：

所述第一服務(wù)器創(chuàng)建所述消息隊(duì)列，得到所述消息隊(duì)列的用戶名、密碼、訪問路徑以及端口號(hào)；

所述第一服務(wù)器遍歷所述服務(wù)器集群中的各個(gè)第二服務(wù)器，向各個(gè)第二服務(wù)器發(fā)送所述消息隊(duì)列的用戶名、密碼、訪問路徑以及端口號(hào)，以使各個(gè)第二服務(wù)器使用所述消息隊(duì)列的用戶名、密碼、訪問路徑以及端口號(hào)加入所述消息隊(duì)列。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述第一服務(wù)器接收目標(biāo)第二服務(wù)器發(fā)送的群聊消息之后，所述方法還包括：

第一服務(wù)器獲取接收到的群聊消息對(duì)應(yīng)的第一消息數(shù)量；

所述第一服務(wù)器獲取發(fā)布到所述消息隊(duì)列中的群聊消息的第二消息數(shù)量；

如所述第一消息數(shù)量和所述第二消息數(shù)量不一致，所述第一服務(wù)器向所述目標(biāo)第二服務(wù)器發(fā)送重發(fā)提示，所述重發(fā)提示用于指示所述目標(biāo)第二服務(wù)器向所述第一服務(wù)器發(fā)送所述群聊消息。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述第一服務(wù)器獲取接收到的群聊消息對(duì)應(yīng)的第一消息數(shù)量之后，所述方法還包括：

第一服務(wù)器對(duì)接收到的群聊消息進(jìn)行關(guān)鍵詞識(shí)別，得到與該群聊消息對(duì)應(yīng)的第一關(guān)鍵詞組；

所述第一服務(wù)器向所述目標(biāo)第二服務(wù)器發(fā)送重發(fā)提示之前，所述方法還包括：

所述第一服務(wù)器對(duì)發(fā)布到所述消息隊(duì)列中的群聊消息進(jìn)行關(guān)鍵詞識(shí)別，得到與該群聊消息對(duì)應(yīng)的第二關(guān)鍵詞組；

所述第一服務(wù)器確定所述第一關(guān)鍵詞組和所述第二關(guān)鍵詞組的匹配度；

如所述匹配度小于第一閾值，所述第一服務(wù)器確定消息丟失，執(zhí)行向所述目標(biāo)第二服務(wù)器發(fā)送重發(fā)提示的操作；

如所述匹配值大于所述第一閾值，所述第一服務(wù)器確定消息未丟失，不執(zhí)行向所述目標(biāo)第二服務(wù)器發(fā)送重發(fā)提示的操作，并通過所述消息隊(duì)列發(fā)布消費(fèi)提示，所述消費(fèi)提示用于指示所述服務(wù)器集群中的各個(gè)第二服務(wù)器從所述消息隊(duì)列中消費(fèi)所述群聊消息。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述第一服務(wù)器接收目標(biāo)第二服務(wù)器發(fā)送的群聊消息之后，所述方法還包括：

所述第一服務(wù)器對(duì)所述群聊消息添加時(shí)間戳，所述時(shí)間戳用于記錄所述群聊消息發(fā)布到所述消息隊(duì)列的發(fā)布時(shí)刻；

所述第一服務(wù)器獲取所述服務(wù)器集群中的各個(gè)第二服務(wù)器從所述消息隊(duì)列中消費(fèi)所述群聊消息的消費(fèi)時(shí)刻；

所述第一服務(wù)器根據(jù)所述時(shí)間戳以及各個(gè)第二服務(wù)器的消費(fèi)時(shí)刻確定各個(gè)第二服務(wù)器的消費(fèi)時(shí)長(zhǎng)，如消費(fèi)時(shí)長(zhǎng)大于第二閾值，確定該第二服務(wù)器異常，向該第二服務(wù)器發(fā)送異常提示，所述異常提示用于指示從所述服務(wù)器集群中重新為該第二服務(wù)器對(duì)應(yīng)的客戶端分配服務(wù)器。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述第一服務(wù)器接收目標(biāo)第二服務(wù)器發(fā)送的群聊消息之后，所述方法還包括：

第一服務(wù)器對(duì)所述群聊消息中的各個(gè)子消息按照預(yù)設(shè)條件進(jìn)行排序，得到對(duì)各個(gè)子消息的排序結(jié)果，所述預(yù)設(shè)條件包括字節(jié)長(zhǎng)度或重要程度；

所述第一服務(wù)器對(duì)各個(gè)子消息的排序結(jié)果將各個(gè)子消息依次發(fā)布到所述消息隊(duì)列。

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

在接收到所述服務(wù)器集群中的各個(gè)第二服務(wù)器反饋的確認(rèn)字符時(shí)，所述第一服務(wù)器從所述消息隊(duì)列中刪除所述群聊消息，以釋放所述消息隊(duì)列的緩存。