[發明專利]基于MQTT協議的消息處理方法、裝置和計算機設備

在審

• 申請號: 201911405333.1
• 申請日: 2019-12-30
• 公開（公告）號: CN111182065A
• 公開（公告）日: 2020-05-19
• 發明（設計）人: 劉偉;陳斌;傅東生
• 申請（專利權）人: 深圳奇跡智慧網絡有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 毛丹

本申請涉及一種基于MQTT協議的消息處理方法、裝置、計算機設備和存儲介質。所述方法包括：獲取在頁面上通過觸發操作產生的設備控制消息，該設備控制消息攜帶第一消息標識和第一消息主題，將該設備控制消息發送至服務器，以使服務器將該設備控制消息發送至訂閱第一消息主題的設備；阻塞該設備控制消息對應的線程，接收服務器發送的設備響應消息，設備響應消息攜帶第二消息標識；將第一消息標識和第二消息標識進行匹配，當匹配成功時，解除設備控制消息對應的線程的阻塞狀態，解析設備響應消息，得到設備控制消息對應的執行結果。采用本方法能夠及時確認設備控制消息對應的執行結果。

技術領域

本申請涉及物聯網領域，特別是涉及一種基于MQTT協議的消息處理方法、裝置、計算機設備和存儲介質。

背景技術

物聯網是在互聯網基礎上的延伸和拓展的網絡，將各種設備與互聯網結合起來而形成的一個巨大的網絡，實現在任何時間、任何地點，人、機、物的互聯互通。各種設備與統一通信平臺之間需要基于通訊協議進行通信，MQTT(Message Queuing TelemetryTransport，消息隊列遙測傳輸)協議是一種常用的物聯網通訊協議。MQTT是一種基于客戶端和服務器的發布/訂閱式傳輸協議。

傳統技術中，設備與統一通信平臺通過MQTT協議進行通訊時，用戶通過統一通信平臺向服務器的指定主題發送設備控制命令，設備訂閱該指定主題，進而設備接收設備控制命令執行相應的動作。整個通訊過程中，在統一通信平臺上只有簡單的設備控制命令已發送提示，無法及時確認設備控制命令對應的操作結果。

發明內容

基于此，有必要針對上述技術問題，提供一種能夠及時確認設備控制消息對應的執行結果的基于MQTT協議的消息處理方法、裝置、計算機設備和存儲介質。

一種基于MQTT協議的消息處理方法，所述方法包括：

獲取在頁面上通過觸發操作產生的設備控制消息，所述設備控制消息攜帶第一消息標識和第一消息主題；

將所述設備控制消息發送至服務器，以使所述服務器將所述設備控制消息發送至訂閱所述第一消息主題的設備；

阻塞所述設備控制消息對應的線程；

接收所述服務器發送的設備響應消息，所述設備響應消息攜帶第二消息標識；

將所述第一消息標識和第二消息標識進行匹配，當匹配成功時，解除所述設備控制消息對應的線程的阻塞狀態，解析所述設備響應消息，得到所述設備控制消息對應的執行結果。

一種基于MQTT協議的消息處理裝置，所述裝置包括：

獲取模塊，用于獲取在頁面上通過觸發操作產生的設備控制消息，所述設備控制消息攜帶第一消息標識和第一消息主題；

發送模塊，用于將所述設備控制消息發送至服務器，以使所述服務器將所述設備控制消息發送至訂閱所述第一消息主題的設備；

阻塞模塊，用于阻塞所述設備控制消息對應的線程；

接收模塊，用于接收所述服務器發送的設備響應消息，所述設備響應消息攜帶第二消息標識；

匹配模塊，用于將所述第一消息標識和第二消息標識進行匹配，當匹配成功時，解除所述設備控制消息對應的線程的阻塞狀態，解析所述設備響應消息，得到所述設備控制消息對應的執行結果。

一種計算機設備，包括存儲器和處理器，所述存儲器存儲有計算機程序，所述處理器執行所述計算機程序時，使得所述處理器執行以下步驟：

獲取在頁面上通過觸發操作產生的設備控制消息，所述設備控制消息攜帶第一消息標識和第一消息主題；

將所述設備控制消息發送至服務器，以使所述服務器將所述設備控制消息發送至訂閱所述第一消息主題的設備；