[發(fā)明專利]一種精簡(jiǎn)的分布式長連接的數(shù)據(jù)傳輸方法及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110432355.8
• 申請(qǐng)日: 2021-04-21
• 公開（公告）號(hào): CN113132487A
• 公開（公告）日: 2021-07-16
• 發(fā)明（設(shè)計(jì)）人: 周聰偉;張友明;劉金鋒
• 申請(qǐng)（專利權(quán)）人: 深圳市樂唯科技開發(fā)有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L12/803;G06F9/54
• 代理公司: 深圳市海盛達(dá)知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44540
• 代理人: 趙雪佳

1.一種精簡(jiǎn)的分布式長連接的數(shù)據(jù)傳輸方法，其特征在于，包括如下步驟：

步驟1：約定長連接客戶端和服務(wù)器端數(shù)據(jù)格式，包括消息的類型；

步驟2：客戶端通過長連接連接到服務(wù)器后，后端服務(wù)器維護(hù)一個(gè)長連接用戶在線列表；

步驟3：增加一個(gè)消息隊(duì)列rabbitmq，用來對(duì)接消息的發(fā)送端和接收端；

步驟4：客戶端發(fā)送的消息，通過nginx到長連接實(shí)際處理模塊，長連接實(shí)際處理模塊按業(yè)務(wù)處理完成后，直接返回給前端用戶；

步驟5：后端業(yè)務(wù)處理模塊要發(fā)消息給用戶時(shí)，先判斷用戶是否在線，如果用戶在線，就將消息發(fā)到消息隊(duì)列，由各長連接實(shí)際業(yè)務(wù)處理模塊按規(guī)則進(jìn)行路由轉(zhuǎn)發(fā)，如果用戶不在線，需要離線緩存的消息，用緩存進(jìn)行存儲(chǔ)，用數(shù)據(jù)庫進(jìn)行持久化；然后繼續(xù)執(zhí)行步驟4，完成數(shù)據(jù)發(fā)送和接受過程。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)傳輸方法，其特征在于，在所述步驟1中，消息的類型包括單條消息、房間消息和廣播消息三種類型；在所述步驟2中，后端服務(wù)器維護(hù)一個(gè)長連接用戶在線用戶列表，該列表用redis進(jìn)行存儲(chǔ)。

3.根據(jù)權(quán)利要求1所述的數(shù)據(jù)傳輸方法，其特征在于，在所述步驟3中，具體還包括：

步驟S1：配置好rabbitmq對(duì)應(yīng)的消息隊(duì)列名稱、賬號(hào)、密碼和相應(yīng)的路由器；

步驟S2：長連接模塊連接rabbitmq路由器的接收端，并維持一個(gè)本節(jié)點(diǎn)的在線用戶列表，后端業(yè)務(wù)模塊連接到rabbitmq的發(fā)送端。

4.根據(jù)權(quán)利要求2所述的數(shù)據(jù)傳輸方法，其特征在于，在所述步驟5中，各長連接實(shí)際業(yè)務(wù)處理模塊，按單條消息、房間消息和廣播消息的規(guī)則進(jìn)行路由轉(zhuǎn)發(fā)。

5.根據(jù)權(quán)利要求4所述的數(shù)據(jù)傳輸方法，其特征在于，在所述步驟5中，按單條消息進(jìn)行路由轉(zhuǎn)發(fā)時(shí)，各長連接實(shí)際處理模塊在線列表會(huì)判斷該用戶是否存在，如果是，則發(fā)送該消息，然后返回步驟4，否則直接返回步驟4；

在所述步驟5中，按房間消息進(jìn)行路由轉(zhuǎn)發(fā)時(shí)，向本節(jié)點(diǎn)該房間所有用戶發(fā)送消息，然后返回步驟4；

在所述步驟5中，按廣播消息進(jìn)行路由轉(zhuǎn)發(fā)時(shí)，向本節(jié)點(diǎn)所有用戶發(fā)送消息，然后返回步驟4。

6.一種精簡(jiǎn)的分布式長連接的數(shù)據(jù)傳輸系統(tǒng)，包括：

數(shù)據(jù)格式單元：用于約定長連接客戶端和服務(wù)器端數(shù)據(jù)格式，包括消息的類型；

在線列表模單元：用于客戶端通過長連接連接到服務(wù)器后，后端服務(wù)器維護(hù)一個(gè)長連接用戶在線列表；

消息隊(duì)列單元：用于增加一個(gè)消息隊(duì)列rabbitmq，用來對(duì)接消息的發(fā)送端和接收端；

長連接實(shí)際處理單元：用于將客戶端發(fā)送的消息，通過nginx到長連接實(shí)際處理模塊，長連接實(shí)際處理模塊按業(yè)務(wù)處理完成后，直接返回給前端用戶；

后端業(yè)務(wù)處理單元：用于后端業(yè)務(wù)處理模塊要發(fā)消息給用戶時(shí)，先判斷用戶是否在線，如果用戶在線，就將消息發(fā)到消息隊(duì)列，由各長連接實(shí)際業(yè)務(wù)處理模塊按規(guī)則進(jìn)行路由轉(zhuǎn)發(fā)，如果用戶不在線，需要離線緩存的消息，用緩存進(jìn)行存儲(chǔ)，用數(shù)據(jù)庫進(jìn)行持久化；然后繼續(xù)執(zhí)行步驟4，完成數(shù)據(jù)發(fā)送和接受過程。

7.根據(jù)權(quán)利要求6所述的數(shù)據(jù)傳輸系統(tǒng)，其特征在于，在所述數(shù)據(jù)格式單元中，消息的類型包括單條消息、房間消息和廣播消息三種類型；在所述在線列表模單元中，后端服務(wù)器維護(hù)一個(gè)長連接用戶在線用戶列表，該列表用redis進(jìn)行存儲(chǔ)。

8.根據(jù)權(quán)利要求6所述的數(shù)據(jù)傳輸系統(tǒng)，其特征在于，在所述消息隊(duì)列單元中，具體還包括：

配置模塊：用于配置好rabbitmq對(duì)應(yīng)的消息隊(duì)列名稱、賬號(hào)、密碼和相應(yīng)的路由器；

對(duì)接模塊：用于長連接模塊連接rabbitmq路由器的接收端，并維持一個(gè)本節(jié)點(diǎn)的在線用戶列表，后端業(yè)務(wù)模塊連接到rabbitmq的發(fā)送端。

9.根據(jù)權(quán)利要求7所述的數(shù)據(jù)傳輸系統(tǒng)，其特征在于，在所述后端業(yè)務(wù)處理單元中，各長連接實(shí)際業(yè)務(wù)處理模塊，按單條消息、房間消息和廣播消息的規(guī)則進(jìn)行路由轉(zhuǎn)發(fā)。

10.根據(jù)權(quán)利要求9所述的數(shù)據(jù)傳輸系統(tǒng)，其特征在于，在所述后端業(yè)務(wù)處理單元中，按單條消息進(jìn)行路由轉(zhuǎn)發(fā)時(shí)，各長連接實(shí)際處理模塊在線列表會(huì)判斷該用戶是否存在，如果是，則發(fā)送該消息，然后返回長連接實(shí)際處理單元，否則直接返回長連接實(shí)際處理單元；

在所述后端業(yè)務(wù)處理單元中，按房間消息進(jìn)行路由轉(zhuǎn)發(fā)時(shí)，向本節(jié)點(diǎn)該房間所有用戶發(fā)送消息，然后返回長連接實(shí)際處理單元；

在所述后端業(yè)務(wù)處理單元中，按廣播消息進(jìn)行路由轉(zhuǎn)發(fā)時(shí)，向本節(jié)點(diǎn)所有用戶發(fā)送消息，然后返回長連接實(shí)際處理單元。