Blog

ESP訂閱了room/lamp topic，以接收Node-RED應用程序在該主題上發布的消息，來開啟或關閉燈泡。

該程式碼順便也註釋了您需要進行更改的位置。您需要使用自己的SSID，密碼和Home Assistant IP地址編輯程式碼。

該程式碼還與其他DHT感測器兼容-您只需要取消註釋並註釋正確的程式碼行即可選擇您的感測器。

/*****
 Terry Lee
 完整的程式碼及專案說明請參閱:
 
Home
 
*****/

#include <ESP8266WiFi.h> 
#include <PubSubClient.h>
#include "DHT.h"

// 無論您使用的DHT感測器類型是哪一個，請將您使用的那個型號解開
#define DHTTYPE DHT11   // DHT 11
//#define DHTTYPE DHT21   // DHT 21 (AM2301)
//#define DHTTYPE DHT22   // DHT 22  (AM2302), AM2321

// 更改下面的憑據，您的ESP8266才可以連接到您的路由器
const char* ssid = "YourSSID";
const char* password = "SSID Password";

// 將變數值更改為HomeAssistant IP地址，以便連接到MQTT Broker
const char* mqtt_server = "mqtt server ip";
// 若MQTT Broker有設定認證請輸入自己設定的帳密
const char* mqtt_user = "MQTT User";
const char* mqtt_password = "MQTT Password";

// 初始化espClient。如果您在家庭自動化系統中運行多個ESP，則應更改每個espClient變數名稱
WiFiClient espClient;
PubSubClient client(espClient);

// DHT Sensor - GPIO 5 = D1 on ESP-12E NodeMCU board
const int DHTPin = D1;

// Lamp - LED - GPIO 4 = D2 on ESP-12E NodeMCU board
const int lamp = D2;

// 初始化 DHT sensor.
DHT dht(DHTPin, DHTTYPE);

// 輔助計時器變數
long now = millis();
long lastMeasure = 0;

// 不要更改下面的功能。此功能將ESP8266連接到路由器
void setup_wifi() {
  delay(10);
  // 我們首先連接到WiFi網絡
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.print("WiFi connected - ESP IP address: ");
  Serial.println(WiFi.localIP());
}

// 當某些設備向esp8266訂閱的主題發布消息時，會執行此功能
// 更改下面的函數以將邏輯增加到程序，因此當設備將消息發佈到主題時您的ESP8266實際上可以配合執行相關作業
void callback(String topic, byte* message, unsigned int length) {
  Serial.print("Message arrived on topic: ");
  Serial.print(topic);
  Serial.print(". Message: ");
  String messageTemp;
  
  for (int i = 0; i < length; i++) { Serial.print((char)message[i]); messageTemp += (char)message[i]; } Serial.println(); // 隨意添加更多IF語句以控制更多GPIO與MQTT // 當主題room/lamp上收到了一條消息，請檢查消息是on或off。根據消息啟閉燈泡GPIO if(topic=="room/lamp"){ Serial.print("Changing Room lamp to "); if(messageTemp == "true"){ digitalWrite(lamp, HIGH); Serial.print("On"); } else if(messageTemp == "false"){ digitalWrite(lamp, LOW); Serial.print("Off"); } } Serial.println(); } // 此功能將您的ESP8266重新連接到MQTT broker // 如果要與ESP8266訂閱更多主題，請更改下面的功能 void reconnect() { // 循環直到我們重新聯繫 while (!client.connected()) { Serial.print("Attempting MQTT connection..."); String clientId = "ESP8266Client-"; clientId += String(random(0xffff), HEX); if (client.connect(clientId.c_str(),mqtt_user,mqtt_password)) { Serial.println("connected"); // 訂閱或重新訂閱主題 // 您可以訂閱更多主題 (可以控制更多燈泡等等) client.subscribe("room/lamp"); } else { Serial.print("failed, rc="); Serial.print(client.state()); Serial.println(" try again in 5 seconds"); // 重試前等待5秒鐘 delay(5000); } } } // 設置功能將ESP GPIOS設置為輸出，以115200的鮑率啟動序列通信 // 設置MQTT代理並設置callback函數 // 回饋函數是收到消息的原因，實際控制LED void setup() { pinMode(lamp, OUTPUT); dht.begin(); Serial.begin(9600); setup_wifi(); client.setServer(mqtt_server, 1883); client.setCallback(callback); } // 對於此案，您無需在循環函數中更改任何內容。基本上它確保您的ESP已連接到您的broker void loop() { if (!client.connected()) { reconnect(); } now = millis(); // 每30秒發佈的新型溫度和濕度 if (now - lastMeasure > 3000) {
    lastMeasure = now;
    // 感測器的數據可能要每2秒鐘才更新
    float h = dht.readHumidity();
    // 讀取攝氏溫度(預設)
    float t = dht.readTemperature();
    // 讀取華氏溫度 (isFahrenheit = true)
    float f = dht.readTemperature(true);

    // 檢查是否有任何讀取失敗並提早退出（重試）
    if (isnan(h) || isnan(t) || isnan(f)) {
      Serial.println("Failed to read from DHT sensor!");
      return;
    }

    // 計算攝氏度的溫度值
    float hic = dht.computeHeatIndex(t, h, false);
    static char temperatureTemp[7];
    dtostrf(t, 6, 2, temperatureTemp);
    
    // 取消對華氏溫度取值的關注
    // float hif = dht.computeHeatIndex(f, h);
    // static char temperatureTemp[7];
    // dtostrf(hif, 6, 2, temperatureTemp);
    
    static char humidityTemp[7];
    dtostrf(h, 6, 2, humidityTemp);

    // 發布溫度和濕度值
    client.publish("room/temperature", temperatureTemp);
    client.publish("room/humidity", humidityTemp);
    
    Serial.print("Humidity: ");
    Serial.print(h);
    Serial.print(" %\t Temperature: ");
    Serial.print(t);
    Serial.print(" *C ");
    Serial.print(f);
    Serial.print(" *F\t Heat index: ");
    Serial.print(hic);
    Serial.println(" *C ");
    // Serial.print(hif);
    // Serial.println(" *F");
  }
  client.loop();
}

上載程式碼後，在HomeAssistant運行您的Node-RED應用程序和Mosquitto Broker的情況下，您可以以115200的鮑率打開Arduino IDE序列監視器，並即時查看發生了什麼。

這有助於檢查ESP是否已成功建立與路由器和Mosquitto Broker的連接。您還可以查看ESP正在接收和發布的消息。