#include <WiFi.h>
#include <PubSubClient.h>
#include <DHT.h>
#define DHTPIN 2 // Digital pin connected to the DHT sensor
#define DHTTYPE DHT11 // DHT 11
const char* ssid = "aNlas6ao4GVzhJwSDZDn";
const char* password = "YOUR_WIFI_PASSWORD";
const char* mqttServer = "YOUR_THINGSBOARD_HOST"; // Example: "demo.thingsboard.io"
const int mqttPort = 1883;
const char* mqttUsername = "YOUR_MQTT_USERNAME"; // Or an empty string if not required
const char* mqttPassword = "YOUR_MQTT_PASSWORD"; // Or an empty string if not required
WiFiClient espClient;
PubSubClient client(espClient);
DHT dht(DHTPIN, DHTTYPE);
void setup() {
Serial.begin(115200);
delay(10);
dht.begin();
setup_wifi();
client.setServer(mqttServer, mqttPort);
}
void setup_wifi() {
delay(10);
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.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
void reconnect() {
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
if (client.connect("ArduinoClient", mqttUsername, mqttPassword)) {
Serial.println("connected");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}
void loop() {
if (!client.connected()) {
reconnect();
}
client.loop();
float temperature = dht.readTemperature();
float humidity = dht.readHumidity();
if (isnan(temperature) || isnan(humidity)) {
Serial.println("Failed to read from DHT sensor!");
return;
}
Serial.print("Temperature: ");
Serial.print(temperature);
Serial.print(" °C\t");
Serial.print("Humidity: ");
Serial.print(humidity);
Serial.println(" %");
String temperatureString = String(temperature);
String humidityString = String(humidity);
// Publish data to ThingsBoard
String data = "{\"temperature\":" + temperatureString + ",\"humidity\":" + humidityString + "}";
char attributes[100];
data.toCharArray(attributes, 100);
client.publish("v1/devices/me/telemetry", attributes);
delay(2000); // Adjust delay time according to your needs
}