[發明專利]一種分布式高可用物聯網數據交互方法在審
| 申請號: | 201810260106.3 | 申請日: | 2018-03-27 |
| 公開(公告)號: | CN108595524A | 公開(公告)日: | 2018-09-28 |
| 發明(設計)人: | 張明波;張皓;羅洪;張震;鐘偉;黃川;李金紅;秦偉;廖劍鋒;巨鵬 | 申請(專利權)人: | 吉旗(成都)科技有限公司 |
| 主分類號: | G06F17/30 | 分類號: | G06F17/30 |
| 代理公司: | 北京權智天下知識產權代理事務所(普通合伙) 11638 | 代理人: | 張廷利 |
| 地址: | 610000 四川省*** | 國省代碼: | 四川;51 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 物聯網數據 指令 可用 交互過程 指令下發 重發機制 可用性 設備端 發送 | ||
1.一種分布式高可用物聯網數據交互方法,其特征在于:包括消息中心(1)、中間層(2)、接收機(3)三部分,其中,消息中心(1)負責接收發送指令請求,并對發送信息進行校驗,根據發送的數據內容生成數據庫記錄和RocketMQ消息,最終響應處理結果給服務調用方;對于異步調用的提供了查詢處理結果的接口;
中間層(2)包括MySQL數據庫、RocketMQ;其中MySQL數據庫負責存放消息記錄;RocketMQ存放請求、響應的中間數據,達到解耦及提高可用性的目的;
接收機(3)拿到RocketMQ中的請求數據然后生成指令報文到設備,并將結果存入MQ的響應topic中。
2.根據權利要求1所述的一種分布式高可用物聯網數據交互方法,其特征在于:所述消息中心側的處理分為同步、異步;接收機側處理方式統一從RocketMQ獲取;指令下發同步流程如下:
A、dubbo接收下發指令請求;
B、校驗指令下發的設備信息是否合法。如果非法則拋出異常,流程結束;
C、向發送消息topic放入消息;
D、在數據庫中創建一條記錄,記錄下發指令的內容;
E、消費者會根據接收機響應的處理結果生成dubbo服務應答數據;
F、返回處理結果。
3.根據權利要求1所述的一種分布式高可用物聯網數據交互方法,其特征在于:指令下發異步記錄流程如下:
A、dubbo接收下發指令請求;
B、校驗指令下發的設備信息是否合法。如果非法則拋出異常,流程結束;
C、在數據庫中創建一條記錄,記錄下發指令的內容;
D、返回數據庫記錄id。
4.根據權利要求1所述的一種分布式高可用物聯網數據交互方法,其特征在于:指令下發異步執行流程如下:
A、Job從數據庫獲取定時執行的消息;
B、向發送消息topic放入消息;
C、消費者從響應topic中得到響應數據,然后更新數據庫對應記錄。
5.根據權利要求1所述的一種分布式高可用物聯網數據交互方法,其特征在于:指令下發補發重發流程如下:
A、Job從數據庫獲取定時執行的消息;
B、向發送消息topic放入消息;
C、更新數據庫對應記錄重試信息,如重試次數;
D、消費者從響應topic中得到響應數據,然后更新數據庫對應記錄。
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于吉旗(成都)科技有限公司,未經吉旗(成都)科技有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/201810260106.3/1.html,轉載請聲明來源鉆瓜專利網。





