[發(fā)明專利]一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 202011152400.6
• 申請(qǐng)日: 2020-10-23
• 公開（公告）號(hào): CN112261146B
• 公開（公告）日: 2022-05-24
• 發(fā)明（設(shè)計(jì)）人: 楊樹森;趙鵬;高遠(yuǎn)方;王路輝;王藝蒙;韓青;賈根龍
• 申請(qǐng)（專利權(quán)）人: 杭州卷積云科技有限公司
• 主分類號(hào): H04L67/06
• 分類號(hào): H04L67/06;H04L67/55;H04L67/566
• 代理公司: 西安通大專利代理有限責(zé)任公司 61200
• 代理人: 賀小停

1.一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)，其特征在于，包括消息通信服務(wù)模塊，文件傳輸服務(wù)模塊和應(yīng)用客戶端；

消息通信服務(wù)模塊，是在邊云協(xié)同基礎(chǔ)架構(gòu)之上用于對(duì)應(yīng)用客戶端之間發(fā)送的消息進(jìn)行轉(zhuǎn)發(fā)；

文件傳輸模塊，是在邊云協(xié)同基礎(chǔ)架構(gòu)之上用于對(duì)應(yīng)用客戶端之間發(fā)送的文件進(jìn)行轉(zhuǎn)發(fā)；

應(yīng)用客戶端，在邊云協(xié)同智能應(yīng)用使用，實(shí)現(xiàn)邊云協(xié)同智能應(yīng)用組件間通信的接口；

使用中心云消息訂閱發(fā)布服務(wù)和邊緣云消息訂閱發(fā)布服務(wù)在中心云和邊緣云之間建立橋接，使用橋接的方式，構(gòu)建中心云和邊緣云；若干節(jié)點(diǎn)共享同一個(gè)消息訂閱發(fā)布服務(wù)，實(shí)現(xiàn)應(yīng)用客戶端在中心云/邊緣云內(nèi)或者中心云和邊緣云之間的消息通信；

文件傳輸使用文件服務(wù)和文件管理服務(wù)作為中心云和邊緣云的文件存儲(chǔ)服務(wù)，利用MQTT協(xié)議和HTTP協(xié)議相結(jié)合實(shí)現(xiàn)中心云/邊緣云內(nèi)應(yīng)用客戶端間和跨邊緣云和中心云間應(yīng)用客戶端的文件傳輸；文件存儲(chǔ)服務(wù)提供數(shù)據(jù)傳輸、存儲(chǔ)和管理，并且根據(jù)文件服務(wù)特性，使用文件存儲(chǔ)服務(wù)進(jìn)行大包消息通信。

2.根據(jù)權(quán)利要求1所述的一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)，其特征在于，消息通信采用MQTT協(xié)議進(jìn)行各應(yīng)用客戶端之間的消息通信，在各應(yīng)用客戶端間進(jìn)行小包通信。

3.根據(jù)權(quán)利要求1所述的一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)，其特征在于，應(yīng)用客戶端，使用客戶端接口，應(yīng)用內(nèi)通信實(shí)現(xiàn)從中心云到邊緣云、從邊緣云到中心云、以及邊緣云/中心云內(nèi)部之間的通信傳輸。

4.根據(jù)權(quán)利要求3所述的一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)，其特征在于，通信傳輸分為消息通信和文件傳輸：消息通信是應(yīng)用內(nèi)各組件通過應(yīng)用客戶端，利用本地消息訂閱發(fā)布服務(wù)，實(shí)現(xiàn)應(yīng)用組件之間的消息通信；文件傳輸是應(yīng)用內(nèi)各組件通過應(yīng)用客戶端，利用本地消息訂閱發(fā)布服務(wù)，發(fā)送請(qǐng)求到文件管理服務(wù)，其向文件服務(wù)獲取上傳/下載鏈接，然后文件管理服務(wù)返回鏈接給請(qǐng)求應(yīng)用客戶端或發(fā)往目標(biāo)應(yīng)用客戶端讓其上傳/下載對(duì)應(yīng)文件。

5.一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)的操作方法，其特征在于，基于權(quán)利要求1至4任意一項(xiàng)所述的一種基于消息通信和文件傳輸?shù)倪呍茀f(xié)同通信系統(tǒng)，邊云協(xié)同通信架構(gòu)的應(yīng)用組件間客戶端消息通信包括如下步驟：

步驟1，應(yīng)用客戶端1發(fā)布特定主題的消息給消息訂閱發(fā)布服務(wù)；

步驟2，消息訂閱發(fā)布服務(wù)將消息路由至訂閱發(fā)布消息的應(yīng)用客戶端2；

步驟3，同樣，應(yīng)用客戶端2也可發(fā)布特定主題的消息給消息訂閱發(fā)布服務(wù)；

步驟4，消息訂閱發(fā)布服務(wù)將消息路由至訂閱發(fā)布消息的應(yīng)用客戶端1；

邊云協(xié)同通信框架的邊云間應(yīng)用客戶端消息通信包括如下步驟：

步驟1，應(yīng)用客戶端1發(fā)布特定主題的消息給邊緣云消息訂閱服務(wù)；

步驟2，邊緣云消息訂閱服務(wù)根據(jù)橋接規(guī)則轉(zhuǎn)發(fā)消息到中心云消息訂閱發(fā)布服務(wù)

步驟3，中心云訂閱發(fā)布服務(wù)將該消息路由至訂閱應(yīng)用客戶端1發(fā)送主題的應(yīng)用客戶端2；

步驟4，同樣，應(yīng)用客戶端1可選擇發(fā)布主題，發(fā)送消息至中心云消息訂閱發(fā)布服務(wù)；

步驟5，中心云消息訂閱發(fā)布服務(wù)根據(jù)橋接規(guī)則同步消息至邊緣云消息訂閱發(fā)布服務(wù)；

步驟6，邊緣云消息訂閱發(fā)布服務(wù)將消息路由至訂閱應(yīng)用客戶端1發(fā)布消息的主題的應(yīng)用客戶端2；

文件傳輸包括如下步驟：

步驟1，應(yīng)用客戶端1選擇發(fā)布主題，發(fā)送獲取putURL請(qǐng)求消息至中心云訂閱發(fā)布服務(wù)；

步驟2，中心云消息訂閱發(fā)布服務(wù)將該消息路由至訂閱了應(yīng)用客戶端1發(fā)布主題的中心云文件管理服務(wù)；

步驟3，中心云文件管理服務(wù)調(diào)用API向中心云文件服務(wù)請(qǐng)求putURL；

步驟4，中心云文件管理服務(wù)接收putURL信息；

步驟5，中心云文件管理服務(wù)選擇發(fā)布主題，發(fā)送putURL消息至中心云消息訂閱發(fā)布服務(wù)；

步驟6，中心云消息訂閱發(fā)布服務(wù)將消息路由至訂閱了中心云文件管理服務(wù)發(fā)布主題的應(yīng)用客戶端1；

步驟7，應(yīng)用客戶端1通過HTTP協(xié)議將文件傳輸至中心云文件服務(wù)；

步驟8，應(yīng)用客戶端1循環(huán)等待文件傳輸完畢；

步驟9，應(yīng)用客戶端1選擇發(fā)布主題，發(fā)送獲取getURL和接收方主題信息的請(qǐng)求消息至中心云消息訂閱發(fā)布服務(wù)；

步驟10，中心云消息訂閱發(fā)布服務(wù)將消息路由至訂閱了應(yīng)用客戶端1發(fā)布主題的中心云文件管理服務(wù)；

步驟11，中心云文件管理服務(wù)調(diào)用API向中心云文件服務(wù)請(qǐng)求getURL；

步驟12，中心云文件管理服務(wù)接收getURL信息；

步驟13，中心云文件管理服務(wù)選擇發(fā)布主題，發(fā)送putURL消息至中心云消息訂閱發(fā)布服務(wù)；

步驟14，中心云消息訂閱發(fā)布服務(wù)根據(jù)橋接規(guī)則將消息同步到邊緣云消息訂閱發(fā)布服務(wù)；

步驟15，邊緣云消息訂閱發(fā)布服務(wù)將消息路由至訂閱了中心云文件管理服務(wù)發(fā)布主題的邊緣云文件管理服務(wù)；

步驟16，邊緣云文件管理服務(wù)向中心云文件服務(wù)請(qǐng)求文件；

步驟17，中心云文件服務(wù)返回所需文件至邊緣云文件管理服務(wù)；

步驟18，邊緣云文件管理服務(wù)上傳文件至邊緣云文件服務(wù)；

步驟19，邊緣云文件管理服務(wù)循環(huán)等待文件傳輸完畢；

步驟20，邊緣云文件管理服務(wù)使用API向邊緣云文件服務(wù)請(qǐng)求getURL；

步驟21，邊緣云文件管理服務(wù)接收getURL信息；

步驟22，邊緣云文件管理服務(wù)選擇多個(gè)發(fā)布主題，發(fā)送多條getURL消息至邊緣云消息訂閱發(fā)布服務(wù)；

步驟23，邊緣云消息訂閱發(fā)布服務(wù)路將消息路由至訂閱了邊緣云文件管理服務(wù)發(fā)布主題的應(yīng)用客戶端；

步驟24，各應(yīng)用客戶端向邊緣云文件服務(wù)請(qǐng)求文件；

步驟25，邊緣云文件服務(wù)向各請(qǐng)求方返回文件。