[發(fā)明專利]基于MQTT協(xié)議的消息處理方法、裝置和計算機設(shè)備

在審

• 申請?zhí)枺?/td>: 201911405333.1
• 申請日: 2019-12-30
• 公開（公告）號: CN111182065A
• 公開（公告）日: 2020-05-19
• 發(fā)明（設(shè)計）人: 劉偉;陳斌;傅東生
• 申請（專利權(quán)）人: 深圳奇跡智慧網(wǎng)絡(luò)有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 廣州華進聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 毛丹

1.一種基于MQTT協(xié)議的消息處理方法，所述方法包括：

獲取在頁面上通過觸發(fā)操作產(chǎn)生的設(shè)備控制消息，所述設(shè)備控制消息攜帶第一消息標(biāo)識和第一消息主題；

將所述設(shè)備控制消息發(fā)送至服務(wù)器，以使所述服務(wù)器將所述設(shè)備控制消息發(fā)送至訂閱所述第一消息主題的設(shè)備；

阻塞所述設(shè)備控制消息對應(yīng)的線程；

接收所述服務(wù)器發(fā)送的設(shè)備響應(yīng)消息，所述設(shè)備響應(yīng)消息攜帶第二消息標(biāo)識；

將所述第一消息標(biāo)識和第二消息標(biāo)識進行匹配，當(dāng)匹配成功時，解除所述設(shè)備控制消息對應(yīng)的線程的阻塞狀態(tài)，解析所述設(shè)備響應(yīng)消息，得到所述設(shè)備控制消息對應(yīng)的執(zhí)行結(jié)果。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述獲取在頁面上通過觸發(fā)操作產(chǎn)生的設(shè)備控制消息之前，所述方法還包括：

獲取終端標(biāo)識；

將所述終端標(biāo)識作為第二消息主題發(fā)送至所述服務(wù)器，訂閱所述第二消息主題，以使所述服務(wù)器在接收攜帶所述第二消息主題的設(shè)備響應(yīng)消息時，將所述設(shè)備響應(yīng)消息發(fā)送至所述終端標(biāo)識對應(yīng)的終端。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將所述第一消息標(biāo)識和第二消息標(biāo)識進行匹配，當(dāng)匹配成功時，解除所述設(shè)備控制消息對應(yīng)的線程的阻塞狀態(tài)，解析所述設(shè)備響應(yīng)消息，得到所述設(shè)備控制消息對應(yīng)的執(zhí)行結(jié)果之后，所述方法還包括：

根據(jù)所述執(zhí)行結(jié)果確定設(shè)備響應(yīng)狀態(tài)，根據(jù)所述設(shè)備響應(yīng)狀態(tài)生成展示信息，所述展示信息的展示方式包括視頻、圖像、語音中的至少一種，所述設(shè)備響應(yīng)狀態(tài)包括響應(yīng)成功狀態(tài)、響應(yīng)失敗狀態(tài)和無響應(yīng)狀態(tài)。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將所述第一消息標(biāo)識和第二消息標(biāo)識進行匹配之前，所述方法還包括：

獲取所述設(shè)備控制消息的過期時間，獲取當(dāng)前時間；

當(dāng)所述當(dāng)前時間大于所述過期時間時，解除所述設(shè)備控制消息對應(yīng)的線程的阻塞狀態(tài)。

5.一種基于MQTT協(xié)議的消息處理方法，所述方法包括：

接收服務(wù)器發(fā)送的設(shè)備控制消息，所述設(shè)備控制消息攜帶第一消息標(biāo)識，所述設(shè)備控制消息對應(yīng)的線程是由發(fā)送所述設(shè)備控制消息至服務(wù)器的終端阻塞；

存儲所述第一消息標(biāo)識；

根據(jù)所述設(shè)備控制消息執(zhí)行對應(yīng)的操作，得到執(zhí)行結(jié)果；

根據(jù)所述執(zhí)行結(jié)果和所述第一消息標(biāo)識生成設(shè)備響應(yīng)消息，所述設(shè)備響應(yīng)消息攜帶第二消息主題；

將所述設(shè)備響應(yīng)消息發(fā)送至服務(wù)器，以使服務(wù)器將所述設(shè)備響應(yīng)結(jié)果發(fā)送至訂閱所述第二消息主題的終端，以使所述終端收到所述設(shè)備響應(yīng)消息后解除所述設(shè)備控制消息的阻塞狀態(tài)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述接收服務(wù)器發(fā)送的設(shè)備控制消息之前，所述方法還包括：

獲取設(shè)備標(biāo)識；

將所述設(shè)備標(biāo)識作為第一消息主題發(fā)送至所述服務(wù)器，訂閱所述第一消息主題，以使所述服務(wù)器在接收攜帶所述第一消息主題的設(shè)備控制消息時，將所述設(shè)備控制消息發(fā)送至所述設(shè)備標(biāo)識對應(yīng)的設(shè)備。

7.一種基于MQTT協(xié)議的消息處理裝置，其特征在于，所述裝置包括：

獲取模塊，用于獲取在頁面上通過觸發(fā)操作產(chǎn)生的設(shè)備控制消息，所述設(shè)備控制消息攜帶第一消息標(biāo)識和第一消息主題；

發(fā)送模塊，用于將所述設(shè)備控制消息發(fā)送至服務(wù)器，以使所述服務(wù)器將所述設(shè)備控制消息發(fā)送至訂閱所述第一消息主題的設(shè)備；

阻塞模塊，用于阻塞所述設(shè)備控制消息對應(yīng)的線程；

接收模塊，用于接收所述服務(wù)器發(fā)送的設(shè)備響應(yīng)消息，所述設(shè)備響應(yīng)消息攜帶第二消息標(biāo)識；

匹配模塊，用于將所述第一消息標(biāo)識和第二消息標(biāo)識進行匹配，當(dāng)匹配成功時，解除所述設(shè)備控制消息對應(yīng)的線程的阻塞狀態(tài)，解析所述設(shè)備響應(yīng)消息，得到所述設(shè)備控制消息對應(yīng)的執(zhí)行結(jié)果。