[發明專利]基于MQTT和RocketMQ開發的物聯網平臺管理系統

有效

• 申請號: 202110573823.3
• 申請日: 2021-05-25
• 公開（公告）號: CN113347028B
• 公開（公告）日: 2022-08-09
• 發明（設計）人: 趙廣斌;馮寶丹;趙陽;王海勇
• 申請（專利權）人: 吉遞（中國）能源科技有限公司
• 主分類號: H04L41/04
• 分類號: H04L41/04;H04L67/01;H04L67/568
• 代理公司: 嘉興啟帆專利代理事務所(普通合伙) 33253
• 代理人: 程開生

本發明公開了基于MQTT和RocketMQ開發的物聯網平臺管理系統，通過服務端模塊將前端模塊和設備終端模塊進行信息交互處理，所述服務端模塊包括業務應用模塊和設備應用模塊，所述業務應用模塊與所述前端模塊進行信息傳輸，所述設備應用模塊和所述設備終端模塊進行信息傳輸。本發明公開的基于MQTT和RocketMQ開發的物聯網平臺管理系統，其采用MQTT協議與設備終端模塊鏈接，由MQTT服務器負責管理鏈接，并通過與RocketMQ的結合進行設備消息的轉儲，結合后實現了設備消息與業務應用的解耦，從而避免因設備消息并發而導致的系統故障，減少了宕機的風險。

技術領域

本發明屬于物聯網平臺管理技術領域，具體涉及一種基于MQTT(Message QueuingTelemetry Transport，消息隊列遙測傳輸)和RocketMQ開發的物聯網平臺管理系統。

背景技術

目前業內常見的物聯開發技術方案普遍采用Netty(開源框架)進行設備的鏈接管理，該方案是基于TCP的長鏈接協議。由Netty服務端進行管理設備的長鏈接，但是存在一些問題：

1、Netty應用在部署集群后結合redis或其他數據中間件進行設備鏈接ID和服務器的對應關系存儲。

2、Netty應用和業務應用耦合度高，不利于業務解耦。

3、開發人員需要不斷維護netty應用，開發成本較高。

4、設備消息并發量高會導致系統故障，宕機。

因此，針對上述問題，予以進一步改進。

發明內容

本發明的主要目的在于提供基于MQTT和RocketMQ開發的物聯網平臺管理系統，其采用MQTT協議與設備終端模塊鏈接，由MQTT服務器負責管理鏈接，并通過與RocketMQ的結合進行設備消息的轉儲，結合后實現了設備消息與業務應用的解耦，從而避免因設備消息并發而導致的系統故障，減少了宕機的風險。

本發明的另一目的在于提供基于MQTT和RocketMQ開發的物聯網平臺管理系統，在物聯網系統的開發過程中，開發人員無需關注設備鏈接管理的工作，只需要開發RocketMQ的消費服務進行消費設備消息即可，大大減輕了開發工作量，提升開發工作效率，而且基于此方案也完美的解決了MQTT本身的廣播協議帶來的集群部署產生的重復消費的問題。

為達到以上目的，本發明提供種基于MQTT和RocketMQ開發的物聯網平臺管理系統，通過服務端模塊將前端模塊和設備終端模塊進行信息交互處理，所述服務端模塊包括業務應用模塊和設備應用模塊，所述業務應用模塊與所述前端模塊進行信息傳輸，所述設備應用模塊和所述設備終端模塊進行信息傳輸，所述業務應用模塊和所述設備應用模塊之間根據業務指令的種類進行同步信息交互(直接通過服務接口以供設備應用模塊調用，執行動作，沒有延遲)或異步信息交互(通過RocketMQ作為中間處理件進行執行動作，會有一定的延遲，適合于升級軟件包等行為)，其中：

所述設備應用模塊通過MQTT協議與所述設備終端模塊進行第一鏈接，并且通過MQTT服務器負責管理第一鏈接，并且通過與RocketMQ進行結合，對設備終端模塊上發的消息進行轉儲，以實現業務應用模塊和設備終端模塊上發的消息之間的解耦(從而避免因設備消息并發而導致的系統故障，減少了宕機的風險)；

所述業務應用模塊獲取業務指令后通過所述設備應用模塊下發消息對所述設備終端模塊進行執行動作。

作為上述技術方案的進一步優選的技術方案，所述業務應用模塊包括業務能力單元和業務服務單元，其中：

所述業務能力單元將獲取的業務指令通過業務服務單元進行業務校驗，并且業務校驗通過所述業務能力單元后生成第一信息(包括綁定信息、請求消息ID和回調方法等)。

作為上述技術方案的進一步優選的技術方案，業務校驗包括用戶服務校驗、商戶服務校驗和設備服務校驗。