什么是MQTT？

MQTT（消息隊列遙測傳輸）是一種輕量級消息傳遞協議，非常適合物聯網連接設備的通信。

MQTT有三個組件：代理，發布者和訂閱者。一個受歡迎的在線經紀人是Mosquitto。代理是一個中間實體，負責處理設備之間的通信。發布者是發送消息的設備。訂閱者監聽發布者發送的消息。

MQTT中還有一個重要的事情，那就是主題。不同設備之間的通信需要一個主題。例如，設備A想要向設備B發送消息。為此，兩者之間應該存在共同點，這就是主題?？梢园阉胂蟪梢粋€電話號碼。

CloudMQTT

CloudMQTT是一種提供免費MQTT通信的代理服務對于一定數量的設備。

設置MQTT

創建帳戶

轉到右上角的控制面板

點擊“創建”按鈕

在“名稱”字段中輸入CMQTT

開同一頁面，在管理用戶中添加用戶：

名稱：pi

密碼：pi

點擊“保存”

再次在同一頁面上，添加：

用戶：pi

主題：pi

點擊“保存”

現在，在頂部欄中，點擊“WebSocket UI”

您將看到一個頁面所有傳感器數據將顯示在哪里

將下面的代碼上傳到Arduino

下面的代碼是一個帶有虛擬字符串的示例代碼傳感器的位置。您可以使用來自傳感器的值替換字符串。

String sensorsData=“”;

String randSensorsData=“”;

void setup（） {

// put your setup code here， to run once：

Serial.begin（9600）;

pinMode（A0，INPUT）;//temperature sensor

pinMode（A1，INPUT）;//windspeed sensor

pinMode（A2，INPUT）;//wind direction sensor

pinMode（A3，INPUT）;//rain fall sensor

pinMode（A4，INPUT）;///barometric pressure sensor

}

void loop（） {

// put your main code here， to run repeatedly：

sensorsData=String（“-”）+String（“S1=”）+String（analogRead（A0））+String（“，”）+String（“S2=”）+String（analogRead（A1））+String（“，”）+String（“S3=”）+String（analogRead（A2））+String（“，”）+String（“S4=”）+String（analogRead（A3））+String（“，”）+String（“S5=”）+String（analogRead（A4））+String（“+”）;

randSensorsData=String（“-”）+String（“S1=”）+String（random（100））+String（“，”）+String（“S2=”）+String（random（200））+String（“，”）+String（“S3=”）+String（random（125））+String（“，”）+String（“S4=”）+String（random（500））+String（“，”）+String（“S5=”）+String（random（50））+String（“+”）;

Serial.println（sensorsData）;

Serial.println（randSensorsData）;

delay（200）;

}

此代碼使用Arduino的模擬引腳從傳感器獲取值，并傳遞給Raspberry Pi進行處理和MQTT通信。上面的代碼使用隨機函數生成隨機值來模擬模擬引腳。

傳感器應連接到A0，A1，A2，A3，A4引腳

Serial.println（randSensorsData）;

此行發送隨機數據以檢查服務器

您還可以檢查WebSocket中顯示的隨機數據UI

打開python 2.7并在其中編寫以下代碼：

import paho.mqtt.client as mqtt

import time

data=”Hello from Raspberry Pi！”

while True：

print（data）

try：

client=mqtt.Client（）

client.username_pw_set（“hgztvlwh”，“qDz_-oAWSfBR”）#replace with your user name and password

client.connect（“m13.cloudmqtt.com”，13017，60）

client.publish（“pi”，data）#pi is topic

time.sleep（1）

except KeyboardInterrupt：

print（“end”）

client.disconnect（）

現在使用python 2.7運行代碼

您會看到傳感器數據每秒都會在CloudMQTT的WebScoket UI中顯示。

在這里，您將看到從Raspberry Pi發送的數據。