[發明專利]物聯網系統、MQTT消息傳輸的優化方法及裝置

有效

• 申請號: 201811024738.6
• 申請日: 2018-09-04
• 公開（公告）號: CN109274730B
• 公開（公告）日: 2021-07-23
• 發明（設計）人: 袁啟勇;尹啟房;周建
• 申請（專利權）人: 上海聯寓智能科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/58
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發明公開了物聯網系統、MQTT消息傳輸的優化方法及裝置，該方法包括：如果監測到第一消息緩存環的緩存空間均被占用，則將接收的待緩存消息覆蓋緩存至所述第一消息緩存環的首位；提取處于所述第一消息緩存環中首位的第一緩存消息；如果所述第一緩存消息為物聯網客戶端發送的訂閱消息，則根據設定存儲策略將所述訂閱消息哈希存儲到預設的訂閱關系數據庫中。上述方案解決了現有技術當業務量達到百萬級別以上或請求頻率過高時不能達到增量業務要求的問題，提高了消息處理的能力，突破了百萬連接的瓶頸，達到了增量業務的持續擴展要求。

技術領域

本發明實施例涉及物聯網通信技術領域，尤其涉及一種物聯網系統、MQTT(Message Queuing Telemetry Transport，消息隊列遙測傳輸)消息傳輸的優化方法及裝置。

背景技術

隨著物聯網(Internet of Things，IOT)的普及和商業化，物聯網復雜通信環境的消息協議至關重要。MQTT協議是國際商業機器公司(International Business MachinesCorporation，IBM)開發的一個即時通訊協議，是目前物聯網消息傳輸推薦的協議。MQTT協議擁有很小的傳輸消耗和協議數據交換，可以最大限度的減少網絡流量，為物聯網客戶端保持更低的電量消耗和更高效的通訊效果。

基于MQTT協議的方案支持百萬級物聯網客戶端，但也僅僅止于此。對于業務量更高，瞬間網絡請求峰值波動等情況，都沒有很好的解決方案，這樣就導致當業務量達到百萬級別以上，或請求頻率過高時，會觸及到MQTT協議性能的瓶頸，不能達到增量業務的要求。

發明內容

本發明提供一種物聯網系統、MQTT消息傳輸的優化方法及裝置，以實現在千萬級物聯網設備、高并發的網絡請求中能持續提供有效的增量業務服務的要求。

第一方面，本發明實施例提供了一種物聯網系統，包括：至少兩個物聯網客戶端、至少一個消息隊列遙測傳輸協議MQTT代理服務器以及服務注冊中心，

其中，所述服務注冊中心，分別與各所述至少兩個物聯網客戶端以及各所述MQTT代理服務器建立連接，用于對各所述MQTT代理服務器運行狀態進行監控，并將處于在線狀態的在線MQTT代理服務器指定給至少兩個待通信的物聯網客戶端，以使所述至少兩個待通信的物聯網客戶端通過所述在線MQTT代理服務器進行消息傳輸。

第二方面，本發明實施例還提供了一種MQTT消息傳輸的優化方法，應用于MQTT代理服務器，該優化方法包括：

如果監測到第一消息緩存環的緩存空間均被占用，則將接收的待緩存消息覆蓋緩存至所述第一消息緩存環的首位；

提取處于所述第一消息緩存環中首位的第一緩存消息；

如果所述第一緩存消息為物聯網客戶端發送的訂閱消息，則根據設定存儲策略將所述訂閱消息哈希存儲到預設的訂閱關系數據庫中。

第三方面，本發明實施例還提供了一種MQTT消息傳輸的優化裝置，包括：

覆蓋緩存模塊，用于如果監測到第一消息緩存環的緩存空間均被占用，則將接收的待緩存消息覆蓋緩存至所述第一消息緩存環的首位；

提取模塊，用于提取處于所述第一消息緩存環中首位的第一緩存消息；

存儲模塊，用于如果所述第一緩存消息為物聯網客戶端發送的訂閱消息，則根據設定存儲策略將所述訂閱消息哈希存儲到預設的訂閱關系數據庫中。

第四方面，本發明實施例還提供了一種MQTT代理服務器，包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序；

所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如第二方面所述的MQTT消息傳輸的優化方法。