// Learn about the ESP32 WiFi simulation in
// https://docs.wokwi.com/guides/esp32-wifi
#include <WiFi.h>
#include "PubSubClient.h"
#include <LiquidCrystal_I2C.h>
LiquidCrystal_I2C LCD = LiquidCrystal_I2C(0x27, 16, 2);
#include<DHT.h>
#define DHTPIN 4
#define DHTTYPE DHT22
DHT dht(DHTPIN,DHTTYPE);
const char * MQTTServer = "broker.hivemq.com";
const char * MQTT_Topic = "20004140";
// Tạo ID ngẫu nhiên tại: https://www.guidgen.com/
const char * MQTT_ID = "";
int Port = 1883;
WiFiClient espClient;
PubSubClient client(espClient);
void WIFIConnect() {
Serial.println("Connecting to SSID: Wokwi-GUEST");
WiFi.begin("Wokwi-GUEST", "");
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println("");
Serial.print("WiFi connected");
Serial.print(", IP address: ");
Serial.println(WiFi.localIP());
}
void MQTT_Reconnect() {
while (!client.connected()) {
if (client.connect(MQTT_ID)) {
Serial.print("MQTT Topic: ");
Serial.print(MQTT_Topic);
Serial.print(" connected");
client.subscribe(MQTT_Topic);
Serial.println("");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}
void callback(char* topic, byte* message, unsigned int length) {
Serial.print("Message arrived on topic: ");
Serial.println(topic);
Serial.print("Message: ");
String stMessage;
for (int i = 0; i < length; i++) {
Serial.print((char)message[i]);
stMessage += (char)message[i];
}
// // LCD.clear();
// // LCD.setCursor(0,0);
// LCD.print(stMessage);
}
void setup() {
Serial.begin(115200);
WIFIConnect();
client.setServer(MQTTServer, Port);
client.setCallback(callback);
LCD.init();
LCD.backlight();
dht.begin();
// LCD.setCursor(0, 0);
// LCD.println("20004140");
// LCD.setCursor(0, 1);
// LCD.println("huynh tan phat");
}
void loop() {
delay(10);
npublish();
if (!client.connected()) {
MQTT_Reconnect();
}
client.loop();
}
void npublish(){
float t=dht.readTemperature();
float h = dht.readHumidity();
LCD.setCursor(0,0);
LCD.print("nhiet do:");
LCD.print(t);
LCD.setCursor(0,2);
LCD.print("do am:");
LCD.print(h);
delay(5000);
String send = "{\"NhietDo\":\""+String(t)+"\",\"DoAm\":\""+String(h)+"\"}";
client.publish("20004140",String(send).c_str());
}
///////////////////vs code
// <!DOCTYPE html>
// <html lang="en">
// <head>
// <meta charset="UTF-8">
// <meta http-equiv="X-UA-Compatible" content="IE=edge">
// <meta name="viewport" content="width=device-width, initial-scale=1.0">
// <script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.min.js" type="text/javascript"></script>
// <script src="https://code.jquery.com/jquery-3.6.1.min.js" type="text/javascript"></script>
// </head>
// <body>
// <p id = "nhietdo"></p>
// <p id = "doam"></p>
// </body>
// </html>
// <script>
// client = new Paho.MQTT.Client("broker.hivemq.com", Number(8000), "");
// client.onConnectionLost = onConnectionLost;
// client.onMessageArrived = onMessageArrived;
// client.connect({onSuccess:onConnect});
// function onConnect() {
// console.log("onConnect");
// client.subscribe("20004140");
// }
// function onConnectionLost(responseObject) {
// if (responseObject.errorCode !== 0) {
// console.log("onConnectionLost:"+responseObject.errorMessage);
// }
// }
// function onMessageArrived(message) {
// console.log("onMessageArrived:"+message.payloadString);
// const obj = JSON.parse(message.payloadString);
// console.log(obj.send)
// var t = parseFloat(obj.NhietDo);
// var h = parseFloat(obj.DoAm);
// document.getElementById("nhietdo").innerHTML = "Nhiệt Độ: "+obj.NhietDo+" Độ C";
// document.getElementById("doam").innerHTML = "Độ Ẩm: "+obj.DoAm+" % ";
// }
// </script>