[發明專利]MQTT消息中心引入規則引擎的方法

有效

• 申請號: 202011104396.6
• 申請日: 2020-10-15
• 公開（公告）號: CN112261101B
• 公開（公告）日: 2021-09-28
• 發明（設計）人: 余龍海;張帥;楊震泉
• 申請（專利權）人: 四川長虹電器股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 四川省成都市天策商標專利事務所 51213
• 代理人: 張秀敏

本發明公開了一種MQTT消息中心引入規則引擎的方法，包括以下步驟：定義數據結構描述規則；將數據結構定義完成后，通過圖形化界面添加和修改規則；設計規則加載方式；所有MQTT消息中心接收且轉發的數據和event事件數據都會回調不同的插件hook，判斷數據是否滿足相應的規則條件并響應動作，如果有處理結果輸出，規則將執行相應的動作。本發明使得系統的開發，維護和升級變得更容易。

技術領域

本發明涉及MQTT傳輸協議技術領域，特別是一種MQTT消息中心引入規則引擎的方法。

背景技術

MQTT協議作為物聯網的基本傳輸協議以來，經歷了不同版本的演化，包括有(3.0/5.0)等。為了支持最新的MQTT傳輸協議，為了方便不同協議版本的設備連接，消息中心的功能和服務都需要擴展。

MQTT服務功能需要在原來的代碼基礎上進行必要的擴展和更新、重新設計框架、保持向下兼容。這將導致程序開發的成本的增加，也為整個系統的獨立性和穩定性提出了挑戰。每次添加了新的功能和服務，需進行完整的單元，集成，性能測試。且每次新功能的發布都必須導致關停服務，重啟服務。對于有大量設備連接的消息服務系統而言，這種重啟會導致客戶使用體驗下降，以及集群軟硬件資源的巨大消耗。現今存在的消息中心規則引擎的方案很少，即使有也是JAVA+DROOLS的方式，這種方式僅支持XML、DRL文件格式，且加載需要大量的系統資源，這對于消息平臺的實時性和大并發交互有困難。

發明內容

為解決現有技術中存在的問題，本發明的目的是提供一種MQTT消息中心引入規則引擎的方法，本發明使得系統的開發，維護和升級變得更容易。

為實現上述目的，本發明采用的技術方案是：一種MQTT消息中心引入規則引擎的方法，包括以下步驟：

S1、定義數據結構描述規則；

S2、將數據結構定義完成后，通過圖形化界面添加和修改規則；

S3、設計規則加載方式；

S4、所有MQTT消息中心接收且轉發的數據和event事件數據都會回調不同的插件hook，判斷數據是否滿足相應的規則條件并響應動作，如果有處理結果輸出，規則將執行相應的動作。

作為本發明的進一步改進，在步驟S1中，定義四種數據類型構建SQL+JSON數據結構描述規則，四種數據類型包括：

①規則：包括采用SQL描述規則和采用JSON描述規則；

所述SQL描述規則由SQL語句和動作列表組成，所述動作列表包含一個或多個動作及其參數，所述SQL語句用于篩選或轉換消息中的數據，SQL描述規則的格式為：SELECT字段名FROM主題[WHERE條件]，其中：FROM子句將規則掛載到某個主題上；SELECT子句用于對數據進行變換，并選擇出感興趣的字段；WHERE子句用于對SELECT選擇出來的某個字段施加條件過濾；

所述JSON描述規則的格式為：規則:{SQL語句,動作列表:[{動作1,動作參數,綁定資源:{資源配置}},{動作2,動作參數,綁定資源:{資源配置}}]}；

②動作：SQL語句匹配通過之后，所執行的任務，動作定義了針對數據的操作；

③資源：通過資源類型為模板實例化出來的對象，保存了與資源相關的配置和系統資源；

④資源類型：資源類型是資源的靜態定義，描述了此類型資源需要的配置項。