[發(fā)明專利]物聯(lián)網系統(tǒng)、MQTT消息傳輸?shù)膬?yōu)化方法及裝置

有效

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

1.一種MQTT消息傳輸?shù)膬?yōu)化方法，應用于MQTT代理服務器，其特征在于，包括：

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

提取處于所述第一消息緩存環(huán)中首位的第一緩存消息；

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

2.根據(jù)權利要求1所述的方法，其特征在于，所述根據(jù)設定存儲策略將所述訂閱消息哈希存儲到預設的訂閱關系數(shù)據(jù)庫中，包括：

分析提取所述訂閱消息的訂閱主題，獲取所述訂閱主題的第一層級信息；

將所述第一層級信息作為所述訂閱消息的關鍵信息；

在所述訂閱關系數(shù)據(jù)庫中查找與所述關鍵信息匹配的物聯(lián)網客戶端地址；

將所述訂閱消息哈希存儲到所述物聯(lián)網客戶端地址關聯(lián)的數(shù)據(jù)桶中。

3.根據(jù)權利要求1所述的方法，其特征在于，還包括：

如果所述第一緩存消息為物聯(lián)網客戶端發(fā)送的發(fā)布消息，則根據(jù)所述訂閱關系數(shù)據(jù)庫，確定訂閱所述發(fā)布消息的目標物聯(lián)網客戶端；

將所述發(fā)布消息發(fā)送至所述目標物聯(lián)網客戶端。

4.根據(jù)權利要求3所述的方法，其特征在于，所述根據(jù)所述訂閱關系數(shù)據(jù)庫，確定訂閱所述發(fā)布消息的目標物聯(lián)網客戶端，包括：

分析所述發(fā)布消息，確定所述發(fā)布消息對應的訂閱主題；

在所述訂閱關系數(shù)據(jù)庫中查找對應于所述訂閱主題的目標物聯(lián)網客戶端地址；

獲取所述目標物聯(lián)網客戶端地址對應的目標物聯(lián)網客戶端。

5.根據(jù)權利要求3所述的方法，其特征在于，在將所述發(fā)布消息發(fā)送至所述目標物聯(lián)網客戶端之前，還包括：

將所述發(fā)布消息及所述目標物聯(lián)網客戶端作為第二緩存消息；

根據(jù)第二消息緩存環(huán)的緩存狀態(tài)緩存所述第二緩存消息。

6.根據(jù)權利要求5所述的方法，其特征在于，所述根據(jù)第二消息緩存環(huán)的緩存狀態(tài)緩存所述第二緩存消息，包括：

如果所述緩存狀態(tài)為緩存空間均被占用，則將所述第二緩存消息覆蓋至所述第二消息緩存環(huán)的首位。

7.根據(jù)權利要求6所述的方法，其特征在于，還包括：

設定所述第一消息緩存環(huán)及所述第二消息緩存環(huán)處于循環(huán)檢查狀態(tài)，以實時接收待緩存的消息。

8.根據(jù)權利要求1所述的方法，其特征在于，還包括：

確定發(fā)送所述待緩存消息的物聯(lián)網客戶端是否為已標記的白名單客戶端；

若是，則接收所述待緩存消息。

9.根據(jù)權利要求1所述的方法，其特征在于，還包括：

如果接收的待緩存消息為任一物聯(lián)網客戶端發(fā)送的訂閱消息，則確定所述訂閱消息相對所述物聯(lián)網客戶端的處理優(yōu)先級；

如果所述處理優(yōu)先級屬于當前不處理范圍，則接收到所述訂閱消息對應的目標發(fā)布消息時，不再向所述物聯(lián)網客戶端發(fā)送所述目標發(fā)布消息。

10.一種MQTT消息傳輸?shù)膬?yōu)化裝置，其特征在于，包括：

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

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

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