[發(fā)明專利]一種聊天數(shù)據(jù)收發(fā)方法

有效

• 申請(qǐng)?zhí)枺?/td>: 202110288024.1
• 申請(qǐng)日: 2021-03-18
• 公開（公告）號(hào): CN112671937B
• 公開（公告）日: 2021-06-01
• 發(fā)明（設(shè)計(jì)）人: 徐新明
• 申請(qǐng)（專利權(quán)）人: 杭州金線連科技有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L29/06
• 代理公司: 浙江千克知識(shí)產(chǎn)權(quán)代理有限公司 33246
• 代理人: 汪丹琪

一種聊天數(shù)據(jù)收發(fā)方法，涉及通信領(lǐng)域。方法應(yīng)用于包括認(rèn)證服務(wù)器、Web服務(wù)器集群、zookeeper服務(wù)器、通信服務(wù)器集群、消息隊(duì)列服務(wù)器集群、注冊(cè)中心的雙通道聊天系統(tǒng)，方法包括聊天數(shù)據(jù)發(fā)送流程：Web服務(wù)器接收到發(fā)送端通過Restful接口發(fā)送的聊天數(shù)據(jù)時(shí)，將聊天數(shù)據(jù)打包并通過zookeeper服務(wù)器發(fā)送給空閑的通信服務(wù)器，該通信服務(wù)器解包向收件人信道發(fā)送聊天數(shù)據(jù)，還請(qǐng)求注冊(cè)中心查找收件人連接的其他通信服務(wù)器，并經(jīng)消息隊(duì)列服務(wù)器轉(zhuǎn)發(fā)聊天數(shù)據(jù)包給其他通信服務(wù)器，其他通信服務(wù)器解包并向收件人信道發(fā)送聊天數(shù)據(jù)；及聊天接收流程：當(dāng)接收端及其登錄的通信服務(wù)器信息在注冊(cè)中心注冊(cè)后，接收端等待登錄的通信服務(wù)器發(fā)送的聊天數(shù)據(jù)。本發(fā)明收發(fā)模式安全且實(shí)時(shí)性好。

技術(shù)領(lǐng)域

本發(fā)明涉及通信技術(shù)領(lǐng)域，尤其涉及一種聊天數(shù)據(jù)收發(fā)方法。

背景技術(shù)

現(xiàn)有聊天系統(tǒng)中，聊天推送服務(wù)部署在一臺(tái)單獨(dú)的服務(wù)器上，通過TCP服務(wù)對(duì)外提供端口和連接支持，所有需要聊天服務(wù)的客戶端也通過TCP協(xié)議連接到該聊天服務(wù)器上，即采用TCP雙工通信實(shí)現(xiàn)信息的發(fā)送與接收。由于TCP連接的設(shè)計(jì)，一旦建立連接，之后的通信無需再攜帶狀態(tài)信息，可以直接發(fā)送。如有用戶惡意大量發(fā)送垃圾數(shù)據(jù)，會(huì)給服務(wù)器帶來極大壓力。另外，連接數(shù)量受制于服務(wù)器的空閑端口，無法連接大量用戶。

發(fā)明內(nèi)容

本發(fā)明針對(duì)現(xiàn)有技術(shù)存在的問題，提出了一種基于雙通道聊天系統(tǒng)實(shí)現(xiàn)的聊天數(shù)據(jù)收發(fā)方法，能連接大量用戶，信息發(fā)送、接收實(shí)時(shí)性、安全性高。

本發(fā)明是通過以下技術(shù)方案得以實(shí)現(xiàn)的：

一種聊天數(shù)據(jù)收發(fā)方法，應(yīng)用于包括認(rèn)證服務(wù)器、Web服務(wù)器集群、zookeeper服務(wù)器 、通信服務(wù)器集群、消息隊(duì)列服務(wù)器集群、注冊(cè)中心的雙通道聊天系統(tǒng)，方法包括：

聊天數(shù)據(jù)發(fā)送流程：

Web服務(wù)器接收到發(fā)送端通過Restful接口發(fā)送的聊天數(shù)據(jù)時(shí)，將聊天數(shù)據(jù)按照發(fā)件人信息、收件人信息、信息體的模式封裝打包成聊天數(shù)據(jù)包，繼而將聊天數(shù)據(jù)包通過zookeeper服務(wù)器發(fā)送給空閑的通信服務(wù)器；

接收到聊天數(shù)據(jù)包的通信服務(wù)器對(duì)聊天數(shù)據(jù)包解包，之后按照收件人信息查找在本通信服務(wù)器上的收件人信道并向收件人信道發(fā)送聊天數(shù)據(jù)；

接收到聊天數(shù)據(jù)包的通信服務(wù)器請(qǐng)求注冊(cè)中心查找收件人連接的其他通信服務(wù)器，該通信服務(wù)器發(fā)送聊天數(shù)據(jù)包給對(duì)應(yīng)的消息隊(duì)列服務(wù)器，由該消息隊(duì)列服務(wù)器轉(zhuǎn)發(fā)聊天數(shù)據(jù)包給其他通信服務(wù)器；

其他通信服務(wù)器所對(duì)應(yīng)的消息隊(duì)列服務(wù)器監(jiān)聽到轉(zhuǎn)發(fā)的聊天數(shù)據(jù)包后，其他通信服務(wù)器對(duì)各自接收到的聊天數(shù)據(jù)包解包，之后按照收件人信息查找其他通信服務(wù)器上的收件人信道并向收件人信道發(fā)送聊天數(shù)據(jù)；

聊天數(shù)據(jù)接收流程：

當(dāng)接收端及其登錄的通信服務(wù)器信息在注冊(cè)中心注冊(cè)后，接收端與登錄的通信服務(wù)器建立收件人信道連接，接收端等待接收登錄的通信服務(wù)器發(fā)送的聊天數(shù)據(jù)。

本發(fā)明將用戶的信息發(fā)送與接收分開實(shí)現(xiàn)，發(fā)送端采用restful接口發(fā)布聊天數(shù)據(jù)，繼而通過Web服務(wù)器將聊天數(shù)據(jù)包發(fā)送給通信服務(wù)器，接收端采用通信服務(wù)器TCP服務(wù)接收聊天數(shù)據(jù)。在此方式下實(shí)現(xiàn)雙通道模式，保證了發(fā)送與接收的實(shí)時(shí)性。本發(fā)明采用了分布式的通信服務(wù)器集群，可突破單服務(wù)器連接上限，能夠?qū)崿F(xiàn)單客戶端發(fā)送，多客戶端（即用戶可登陸多個(gè)通信服務(wù)器）接收。

作為優(yōu)選，所述聊天數(shù)據(jù)包括發(fā)送端加密的身份識(shí)別碼、用戶ID、包含發(fā)件人信息、收件人信息、信息體的聊天信息。

作為優(yōu)選，所述聊天數(shù)據(jù)發(fā)送流程還包括，在發(fā)送端通過Restful接口發(fā)送聊天數(shù)據(jù)前，認(rèn)證服務(wù)器對(duì)登陸的發(fā)送端進(jìn)行加密運(yùn)算，基于用戶ID、發(fā)送端身份識(shí)別碼的有效期、認(rèn)證服務(wù)器名稱加密獲得發(fā)送端加密的身份識(shí)別碼。