[發(fā)明專利]一種基于MQTT數(shù)據(jù)交互的方法、終端及服務(wù)端

有效

• 申請(qǐng)?zhí)枺?/td>: 201911313404.5
• 申請(qǐng)日: 2019-12-19
• 公開（公告）號(hào): CN111131426B
• 公開（公告）日: 2022-05-10
• 發(fā)明（設(shè)計(jì)）人: 王磊
• 申請(qǐng)（專利權(quán)）人: 浙江百應(yīng)科技有限公司
• 主分類號(hào): H04L67/56
• 分類號(hào): H04L67/56;H04L67/562;H04L67/145;H04L9/40
• 代理公司: 杭州浙言專利代理事務(wù)所(普通合伙) 33370
• 代理人: 易朝暉

本發(fā)明公開了一種基于MQTT數(shù)據(jù)交互的方法，方法包括：終端對(duì)獲取的信息進(jìn)行編碼，指定QOS后將編碼后的信息上傳至MQTT服務(wù)器；MQTT服務(wù)器根據(jù)指定的QOS將終端上傳的信息推送到與MQTT服務(wù)器連接的服務(wù)端；服務(wù)端對(duì)消息進(jìn)行解碼，校驗(yàn)消息的topic是否需要處理；如果是，服務(wù)端提交消息至業(yè)務(wù)線程池進(jìn)行業(yè)務(wù)邏輯處理。

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

本發(fā)明涉及通信領(lǐng)域，尤其涉及一種基于MQTT數(shù)據(jù)交互的方法、終端及服務(wù)端。

背景技術(shù)

現(xiàn)有基于Http協(xié)議建立的終端與服務(wù)端數(shù)據(jù)交互過程中，終端會(huì)存在很頻繁的GPS位置上報(bào)，且Http的三次握手建立連接和四次揮手關(guān)閉連接對(duì)于服務(wù)端來說也是一筆很大的開銷，服務(wù)端可能因?yàn)榫W(wǎng)絡(luò)原因無法接收到終端上報(bào)的數(shù)據(jù)，更嚴(yán)重可能導(dǎo)致故障，高可用性無法保證。

而基于MQ中間件的長(zhǎng)連接通信建立的終端與服務(wù)端數(shù)據(jù)交互過程中，雖然MQ避免了連接建立和關(guān)閉的開銷，其可用性也有所保證，但是MQ適合于連接數(shù)少，單個(gè)連接吞吐量大的場(chǎng)景，其更多是用于服務(wù)端應(yīng)用之間的解耦和削峰填谷等。對(duì)于終端這類一般是連接數(shù)多，單個(gè)連接吞吐量小的場(chǎng)景需要一種更加輕量級(jí)的消息隊(duì)列。

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

本發(fā)明要解決的技術(shù)問題，在于提供一種基于MQTT數(shù)據(jù)交互的方法、終端及服務(wù)端，保證數(shù)據(jù)交互的高可用性，且滿足連接數(shù)量多、單個(gè)連接吞吐量小的應(yīng)用場(chǎng)景。

第一方面，本發(fā)明提供一種基于MQTT數(shù)據(jù)交互的方法，所述方法包括：

終端對(duì)獲取的信息進(jìn)行編碼，指定QOS后將所述編碼后的信息上傳至MQTT服務(wù)器；

所述MQTT服務(wù)器根據(jù)指定的QOS將所述終端上傳的信息推送到與所述MQTT服務(wù)器連接的服務(wù)端；

所述服務(wù)端對(duì)所述消息進(jìn)行解碼，校驗(yàn)所述消息的topic是否需要處理；

如果是，所述服務(wù)端提交所述消息至業(yè)務(wù)線程池進(jìn)行業(yè)務(wù)邏輯處理。

在上述方案中，在所述終端對(duì)獲取的信息進(jìn)行編碼之前，將所述終端注冊(cè)到所述MQTT服務(wù)器上。

在上述方案中，將所述終端注冊(cè)到所述MQTT服務(wù)器上的方法包括：

所述終端通過AES加密后，發(fā)送加密后的信息請(qǐng)求服務(wù)端；

所述服務(wù)端通過AES解密獲取所述終端的信息；

服務(wù)端根據(jù)所述終端的信息查詢BD判斷所述終端是否已經(jīng)注冊(cè)；

如果否，所述服務(wù)端請(qǐng)求MQTT服務(wù)器，所述服務(wù)端將所述MQTT服務(wù)器生成的密鑰信息返回給所述終端；

如果是，所述服務(wù)端直接返回連接所述MQTT服務(wù)器的密鑰信息；

所述終端接收所述MQTT服務(wù)器生成的密鑰信息緩存在本地，所述終端根據(jù)緩存在本地的密鑰信息與所述MQTT服務(wù)器連接。

在上述方案中，所述方法還包括：

所述終端定時(shí)向所述MQTT服務(wù)器發(fā)送心跳包，所述MQTT服務(wù)器定時(shí)發(fā)送所述心跳包至所述服務(wù)端。

在上述方案中，所述方法還包括：

所述MQTT服務(wù)器未能接受所述終端上傳的消息時(shí)，根據(jù)所述指定的QOS控制重試機(jī)制。

在上述方案中，所述信息包括實(shí)時(shí)定位、短信、微信、通話記錄、應(yīng)用權(quán)限中的任意一種或多種。

在上述方案中，所述方法還包括：

所述服務(wù)端將所述MQTT服務(wù)器上傳的消息記錄于數(shù)據(jù)庫(kù)中。

第二方面，本發(fā)明提供一種終端，包括：