[發(fā)明專利]一種分布式高可用物聯(lián)網(wǎng)數(shù)據(jù)交互方法

在審

• 申請?zhí)枺?/td>: 201810260106.3
• 申請日: 2018-03-27
• 公開（公告）號: CN108595524A
• 公開（公告）日: 2018-09-28
• 發(fā)明（設(shè)計(jì)）人: 張明波;張皓;羅洪;張震;鐘偉;黃川;李金紅;秦偉;廖劍鋒;巨鵬
• 申請（專利權(quán)）人: 吉旗（成都）科技有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京權(quán)智天下知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11638
• 代理人: 張廷利

本發(fā)明公開了一種分布式高可用物聯(lián)網(wǎng)數(shù)據(jù)交互方法，本發(fā)明用于增強(qiáng)指令下發(fā)交互過程的可用性。保障指令在指定的時間內(nèi)可以下發(fā)到設(shè)備端，并得到下發(fā)結(jié)果給下發(fā)指令端。支持指令同步下發(fā)、異步下發(fā)以及對故障發(fā)送的重發(fā)機(jī)制。

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

本發(fā)明涉及數(shù)據(jù)交互技術(shù)領(lǐng)域，具體為一種分布式高可用物聯(lián)網(wǎng)數(shù)據(jù)交互方法。

背景技術(shù)

物聯(lián)網(wǎng)是新一代信息技術(shù)的重要組成部分，也是“信息化”時代的重要發(fā)展階段。顧名思義，物聯(lián)網(wǎng)就是物物相連的互聯(lián)網(wǎng)。這有兩層意思：其一，物聯(lián)網(wǎng)的核心和基礎(chǔ)仍然是互聯(lián)網(wǎng)，是在互聯(lián)網(wǎng)基礎(chǔ)上的延伸和擴(kuò)展的網(wǎng)絡(luò)；其二，其用戶端延伸和擴(kuò)展到了任何物品與物品之間，進(jìn)行信息交換和通信，也就是物物相息。物聯(lián)網(wǎng)通過智能感知、識別技術(shù)與普適計(jì)算等通信感知技術(shù)，廣泛應(yīng)用于網(wǎng)絡(luò)的融合中，也因此被稱為繼計(jì)算機(jī)、互聯(lián)網(wǎng)之后世界信息產(chǎn)業(yè)發(fā)展的第三次浪潮。物聯(lián)網(wǎng)是互聯(lián)網(wǎng)的應(yīng)用拓展，與其說物聯(lián)網(wǎng)是網(wǎng)絡(luò)，不如說物聯(lián)網(wǎng)是業(yè)務(wù)和應(yīng)用。因此，應(yīng)用創(chuàng)新是物聯(lián)網(wǎng)發(fā)展的核心，以用戶體驗(yàn)為核心的創(chuàng)新2.0是物聯(lián)網(wǎng)發(fā)展的靈魂。

本框架使用場景與物流智慧物聯(lián)網(wǎng)行業(yè)貼合緊密，具有一定受限性。

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

本發(fā)明的目的在于提供一種分布式高可用物聯(lián)網(wǎng)數(shù)據(jù)交互方法，以解決上述背景技術(shù)中提出的問題。

為實(shí)現(xiàn)上述目的，本發(fā)明提供如下技術(shù)方案：一種分布式高可用物聯(lián)網(wǎng)數(shù)據(jù)交互方法，包括消息中心、中間層、接收機(jī)三部分，其中，消息中心負(fù)責(zé)接收發(fā)送指令請求，并對發(fā)送信息進(jìn)行校驗(yàn)，根據(jù)發(fā)送的數(shù)據(jù)內(nèi)容生成數(shù)據(jù)庫記錄和RocketMQ消息，最終響應(yīng)處理結(jié)果給服務(wù)調(diào)用方；對于異步調(diào)用的提供了查詢處理結(jié)果的接口；

中間層包括MySQL數(shù)據(jù)庫、RocketMQ；其中MySQL數(shù)據(jù)庫負(fù)責(zé)存放消息記錄；RocketMQ存放請求、響應(yīng)的中間數(shù)據(jù)，達(dá)到解耦及提高可用性的目的；

接收機(jī)拿到RocketMQ中的請求數(shù)據(jù)然后生成指令報(bào)文到設(shè)備，并將結(jié)果存入MQ的響應(yīng)topic中。

優(yōu)選的，所述消息中心側(cè)的處理分為同步、異步；接收機(jī)側(cè)處理方式統(tǒng)一從RocketMQ獲取；指令下發(fā)同步流程如下：

A、dubbo接收下發(fā)指令請求；

B、校驗(yàn)指令下發(fā)的設(shè)備信息是否合法。如果非法則拋出異常，流程結(jié)束；

C、向發(fā)送消息topic放入消息；

D、在數(shù)據(jù)庫中創(chuàng)建一條記錄，記錄下發(fā)指令的內(nèi)容；

E、消費(fèi)者會根據(jù)接收機(jī)響應(yīng)的處理結(jié)果生成dubbo服務(wù)應(yīng)答數(shù)據(jù)；

F、返回處理結(jié)果。

優(yōu)選的，指令下發(fā)異步記錄流程如下：

A、dubbo接收下發(fā)指令請求；

B、校驗(yàn)指令下發(fā)的設(shè)備信息是否合法。如果非法則拋出異常，流程結(jié)束；

C、在數(shù)據(jù)庫中創(chuàng)建一條記錄，記錄下發(fā)指令的內(nèi)容；

D、返回?cái)?shù)據(jù)庫記錄id。

優(yōu)選的，指令下發(fā)異步執(zhí)行流程如下：

A、Job從數(shù)據(jù)庫獲取定時執(zhí)行的消息；

B、向發(fā)送消息topic放入消息；

C、消費(fèi)者從響應(yīng)topic中得到響應(yīng)數(shù)據(jù)，然后更新數(shù)據(jù)庫對應(yīng)記錄。

優(yōu)選的，指令下發(fā)補(bǔ)發(fā)重發(fā)流程如下：

A、Job從數(shù)據(jù)庫獲取定時執(zhí)行的消息；

B、向發(fā)送消息topic放入消息；