ESP32 DHT22&MQTT (AsyncMQTT_ESP32)
MQTT_HOST "broker.mqtt-dashboard.com"
Topic : alex9ufo/esp32/command1
Message: 0: 回傳溫度 1:回傳濕度 2:回傳溫度與濕度
Wokwi程式
#include <Adafruit_Sensor.h>
#include <DHT_U.h>
#include <WiFi.h>
extern "C" {
#include "freertos/FreeRTOS.h"
#include "freertos/timers.h"
}
#include <AsyncMQTT_ESP32.h>
#define MQTT_HOST "broker.mqtt-dashboard.com"
//#define MQTT_HOST "broker.hivemq.com"
//#define MQTT_HOST "test.mosquitto.org" // Broker address
//#define MQTT_HOST "broker.mqttgo.io"
#define MQTT_PORT 1883
#define WIFI_SSID "Wokwi-GUEST"
#define WIFI_PASSWORD ""
AsyncMqttClient mqttClient;
TimerHandle_t mqttReconnectTimer;
TimerHandle_t wifiReconnectTimer;
#define DHT22PIN 13
#define DHTTYPE DHT22 // DHT 11
DHT_Unified dht(DHT22PIN, DHTTYPE);
float temp, hum;
String json="";
bool Temp=false,Humi=false,Send=false;
const char *SubTopic1 = "alex9ufo/esp32/command1";
const char *PubTopic2 = "alex9ufo/esp32/temperature";
const char *PubTopic3 = "alex9ufo/esp32/humidity";
//================================================================
void connectToWifi() {
Serial.println("Connecting to Wi-Fi...");
WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
}
//================================================================
void connectToMqtt() {
Serial.println("Connecting to MQTT...");
mqttClient.connect();
}
//================================================================
void WiFiEvent(WiFiEvent_t event)
{
switch (event)
{
#if USING_CORE_ESP32_CORE_V200_PLUS
case ARDUINO_EVENT_WIFI_READY:
Serial.println("WiFi ready");
break;
case ARDUINO_EVENT_WIFI_STA_START:
Serial.println("WiFi STA starting");
break;
case ARDUINO_EVENT_WIFI_STA_CONNECTED:
Serial.println("WiFi STA connected");
break;
case ARDUINO_EVENT_WIFI_STA_GOT_IP6:
case ARDUINO_EVENT_WIFI_STA_GOT_IP:
Serial.println("WiFi connected");
Serial.print("IP address: ");
Serial.println(WiFi.localIP());
connectToMqtt();
break;
case ARDUINO_EVENT_WIFI_STA_LOST_IP:
Serial.println("WiFi lost IP");
break;
case ARDUINO_EVENT_WIFI_STA_DISCONNECTED:
Serial.println("WiFi lost connection");
xTimerStop(mqttReconnectTimer, 0); // ensure we don't reconnect to MQTT while reconnecting to Wi-Fi
xTimerStart(wifiReconnectTimer, 0);
break;
#else
case SYSTEM_EVENT_STA_GOT_IP:
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
connectToMqtt();
break;
case SYSTEM_EVENT_STA_DISCONNECTED:
Serial.println("WiFi lost connection");
xTimerStop(mqttReconnectTimer, 0); // ensure we don't reconnect to MQTT while reconnecting to Wi-Fi
xTimerStart(wifiReconnectTimer, 0);
break;
#endif
default:
break;
}
}
//================================================================
void onMqttConnect(bool sessionPresent) {
Serial.println("Connected to MQTT.");
Serial.print("Session present: ");
Serial.println(sessionPresent);
Serial.println("Connected to MQTT.");
Serial.print("Session present: ");
Serial.println(sessionPresent);
uint16_t packetIdSub1 = mqttClient.subscribe(SubTopic1 , 2);
Serial.print("Subscribing at QoS 2, packetId: ");
Serial.println(packetIdSub1);
//uint16_t packetIdSub2 = mqttClient.subscribe(SubTopic2, 2);
//Serial.print("Subscribing at QoS 2, packetId: ");
//Serial.println(packetIdSub2);
}
//================================================================
void onMqttDisconnect(AsyncMqttClientDisconnectReason reason) {
Serial.println("Disconnected from MQTT.");
if (WiFi.isConnected()) {
xTimerStart(mqttReconnectTimer, 0);
}
}
//================================================================
void onMqttSubscribe(uint16_t packetId, uint8_t qos) {
Serial.println("Subscribe acknowledged.");
Serial.print(" packetId: ");
Serial.println(packetId);
Serial.print(" qos: ");
Serial.println(qos);
}
//================================================================
void onMqttUnsubscribe(uint16_t packetId) {
Serial.println("Unsubscribe acknowledged.");
Serial.print(" packetId: ");
Serial.println(packetId);
}
//================================================================
void onMqttPublish(uint16_t packetId) {
Serial.print("Publish acknowledged.");
Serial.print(" packetId: ");
Serial.println(packetId);
}
//================================================================
void onMqttMessage(char* topic, char* payload, AsyncMqttClientMessageProperties properties, size_t len, size_t index, size_t total) {
String messageTemp;
for (int i = 0; i < len; i++) {
Serial.print((char)payload[i]);
messageTemp += (char)payload[i];
}
if (strcmp(topic, SubTopic1) == 0) {
// If the relay is on turn it off (and vice-versa)
Serial.println();
Serial.println(messageTemp);
if (messageTemp == "0") {
Temp=true;
Humi=false;
Send=true;
Serial.print("temperature");
}
if (messageTemp == "1") {
Humi=true;
Temp=false;
Send=true;
Serial.print("humidity");
}
if (messageTemp == "2") {
Humi=true;
Temp=true;
Send=true;
Serial.print("temperature&humidity");
}
}
}
//================================================================
void setup() {
Serial.begin(115200);
Serial.println();
pinMode(15, OUTPUT);
Serial.println("Hello, ESP32!");
dht.begin();
// Get temperature sensor details.
sensor_t sensor;
dht.temperature().getSensor(&sensor);
dht.humidity().getSensor(&sensor);
mqttReconnectTimer = xTimerCreate("mqttTimer", pdMS_TO_TICKS(2000), pdFALSE, (void*)0, reinterpret_cast<TimerCallbackFunction_t>(connectToMqtt));
wifiReconnectTimer = xTimerCreate("wifiTimer", pdMS_TO_TICKS(2000), pdFALSE, (void*)0, reinterpret_cast<TimerCallbackFunction_t>(connectToWifi));
WiFi.onEvent(WiFiEvent);
mqttClient.onConnect(onMqttConnect);
mqttClient.onDisconnect(onMqttDisconnect);
mqttClient.onSubscribe(onMqttSubscribe);
mqttClient.onUnsubscribe(onMqttUnsubscribe);
mqttClient.onMessage(onMqttMessage); //callback
mqttClient.setServer(MQTT_HOST, MQTT_PORT);
// If your broker requires authentication (username and password), set them below
//mqttClient.setCredentials("REPlACE_WITH_YOUR_USER", "REPLACE_WITH_YOUR_PASSWORD");
connectToWifi();
}
//================================================================
void loop()
{
// publish message
static uint32_t prev_ms = millis();
if (millis() > prev_ms + 2500) {
prev_ms = millis();
sensors_event_t event;
dht.temperature().getEvent(&event);
if (isnan(event.temperature)) {
Serial.println(F("Error reading temperature!"));
}
else {
Serial.print(F("Temperature: "));
temp = event.temperature;
Serial.print(temp);
Serial.println(F("°C"));
}
// Get humidity event and print its value
dht.humidity().getEvent(&event);
if (isnan(event.relative_humidity)) {
Serial.println(F("Error reading humidity!"));
}
else {
Serial.print(F("Humidity: "));
hum = event.relative_humidity;
Serial.print(hum);
Serial.println(F("%"));
}
String temp1 = String(temp,1); // 2nd param is decimal digits
String hum1 = String(hum,1); // 2nd param is decimal digits
if (Send) {
if (Temp&&Humi)
{
uint16_t packetIdPub1 = mqttClient.publish(PubTopic2, 1, true, temp1.c_str());
Serial.printf("Temperature Published", PubTopic2, packetIdPub1);
delay(500);
uint16_t packetIdPub2 = mqttClient.publish(PubTopic3, 1, true, hum1.c_str());
Serial.printf("Temperature Published", PubTopic3, packetIdPub2);
}
if (Temp&&!Humi)
{
uint16_t packetIdPub1 = mqttClient.publish(PubTopic2, 1, true, temp1.c_str());
Serial.printf("Temperature Published", PubTopic2, packetIdPub1);
}
if (!Temp&&Humi)
{
uint16_t packetIdPub2 = mqttClient.publish(PubTopic3, 1, true, hum1.c_str());
Serial.printf("Temperature Published", PubTopic3, packetIdPub2);
}
Send=false;
}
}
}
沒有留言:
張貼留言