大家好，我是程序員小哈，假期結束了，我們繼續分享嵌入式相關知識，喜歡的小伙伴，文末點贊，讓我看到哈。

今天我們來看一下，MQTT客戶端如何與OneNET服務器進行數據通信，發布者（Publish）、代理（Broker）（服務器）、訂閱者（Subscribe）他們三者之間是什么樣的關系。

OneNET平臺的主題

MQTT的服務器端管理著很多主題（topic），發布者是指對某個主題發布消息，訂閱者是指訂閱不同的主題。

發布者和訂閱者都屬于客戶端，一個客戶端既可以是發布者，也可以是訂閱者。

發布者針對某個主題發布了一條消息至服務器，服務器會分發給所有訂閱了該主題的訂閱者。

因此定閱與發布必須要有主題，主題相當于對發送給服務器端的消息進行了分類，只有客戶端定閱了某個主題后，才能收到相應主題的payload，才能進行通信。

一個客戶端可以向服務器訂閱多個主題。

這里阿里云物聯網平臺就是MQTT的服務器（Broker），手機上的云智能APP和我們做的控制板就屬于客戶端。

手機控制電燈開關，就是對設備屬性進行設置，手機APP端發布了一個控制燈動作的消息，控制板訂閱了這個消息，控制板就能收到服務器轉發來的這個消息，進而就能實現手機對控制板的控制。

控制板通過溫濕度傳感器獲取室內的溫濕度信息，控制板通過發布帶有溫濕度信息的消息至服務器，手機端因為訂閱了此主題的消息，手機端也就可以收到此消息了，對此消息進行解析，進而顯示到手機APP中，也就實現了控制板上的溫濕度數據的上傳，這就是對設備屬性的上報。

參考官方的文檔，我們得知OneNET平臺的主題格式如下：

其中， {pid} 由產品ID替換，我們上文創建的產品ID為：hg8zt6E3LP。{device-name} 設備名稱為：XiaoHaLED 。

下面我們使用 MQTT.fx 軟件充當客戶端，與OneNET服務器進行通信，我們看看如何發布和訂閱消息。

發布消息

MQTT傳輸的消息分為：主題（topic--區分不同消息）和負載（payload--消息內容）兩部分。

通過上面我們知道，如果設備的屬性要上報給服務器，那么其主題為：$sys/{pid}/{device-name}/thing/property/post

替換產品ID和設備名稱之后為：$sys/hg8zt6E3LP/XiaoHaLED/thing/property/post

{
  "id": "123",
  "version": "1.0",
  "params": {
    "Runtime": {
      "value": 1000
    }
  }
}

使用 MQTT.fx 軟件實現設備屬性上報，具體操作如下：

也可以同時改變多個參數：

{
 "id": "123",
 "version": "1.0",
 "params": {
  "Runtime": {
   "value": 1000
  },
  "PowerSwitch": {
   "value": true
  }
 }
}

使用 MQTT.fx 軟件實現設備多屬性上報，具體操作如下：

發布消息需要填寫 topic、payload和消息的服務質量等級。

MQTT.fx軟件右側的 QoS0、 QoS1等是消息服務質量等級。

MQTT協議中有三種消息發布服務質量:

QoS0：“至多一次”，消息發布完全依賴底層 TCP/IP 網絡。會發生消息丟失或重復的情況。此級別一般用于環境傳感器數據上傳，即使丟失一次數據也無所謂，因為一般傳感器數據的上傳都是周期性的。

QoS1：“至少一次”，確保消息到達，但消息重復可能會發生。

QoS2：“只有一次”，確保消息到達一次。這一級別可用于對消息丟失和重復不能容忍的場景，比如在計費系統中，此服務質量的消息因為系統開銷大，一般物聯網平臺都是不支持的。

OneNET平臺對協議特性支持如下：

MQTT的訂閱

通常客戶端與MQTT Broker建立連接之后，客戶端首先要對其感興趣的主題進行一下訂閱。

比如設備屬性設置，下行：$sys/{pid}/{device-name}/thing/property/set

替換產品ID和設備名稱之后為：$sys/hg8zt6E3LP/XiaoHaLED/thing/property/set

下面演示一下，使用MQTT.fx軟件訂閱設備屬性設置的主題，然后使用OneNET控制臺中的應用模擬器（模擬一個客戶端），當其改變某個屬性的時候，MQTT.fx軟件會同步收到此主題的消息內容，對此消息進行解析，就可以知道對設備屬性設置的指令的具體內容了。

總結

本文介紹了 MQTT協議 ，MQTT協議采用發布/訂閱（Publish/Subscribe）模式，該協議主要有三個角色：發布者（Publish）、代理（Broker）（服務器）、訂閱者（Subscribe）。

他們三者的關系如下圖所示：

由上圖我們可以看出來，消息傳遞的時候，并不是從消息的發布方直接送達到訂閱端，而是經過 MQTT Broker 進行消息的分發。

這種發布/訂閱消息模式，提供了一種一對多的消息分發機制，進而實現了應用程序的解耦。

發布者（Publish） 是發送消息的一方，可以為一個應用程序或一臺設備。

代理（Broker）（服務器） 是管理消息隊列的一方，位于消息發布者和訂閱者之間。云端（服務器端）通過主題（Topic）的方式管理各個物聯網設備的訂閱，實現將設備與設備之間消息進行轉發。

訂閱者（Subscribe） 是訂閱主題的一方，主要用于接收消息。

怎么樣？通過上面的描述，物聯網的通信過程你明白了嗎？