#include "PubSubClient.h"
#include<DHT.h>
#include<WiFi.h>
#include <LiquidCrystal_I2C.h>
#define DHTPIN 15
#define DHTTYPE DHT22
DHT dht(DHTPIN,DHTTYPE);
LiquidCrystal_I2C lcd(0x27,16,2);
const char * MQTTServer = "broker.emqx.io";
const char * MQTT_Topic = "VLUTE";
// 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 setup() {
Serial.begin(115200);
dht.begin();
WIFIConnect();
client.setServer(MQTTServer, Port);
lcd.init();
lcd.backlight();
}
void loop() {
float hum=dht.readHumidity();
float temp=dht.readTemperature();
lcd.setCursor(0,0);
lcd.print("Do am : ");
lcd.print(hum);
lcd.print(" %");
lcd.setCursor(0,1);
lcd.print("Nhiet do : ");
lcd.print(temp);
// lcd.println(" ℃");
delay(2000);
// lcd.clear();
// float tongg = 0;
// for(int i = 0;i<3;i++){
// tongg = tongg+temp;
// }
// float trb = tongg/3;
// lcd.setCursor(0,0);
// lcd.print("ND TB 3 lan : ");
// lcd.setCursor(0,1);
// lcd.print(trb);
// delay(2000);
delay(10);
npublish();
if (!client.connected()) {
MQTT_Reconnect();
}
client.loop();
}
void npublish(){
float t = dht.readTemperature();
float h = dht.readHumidity();
float tong = 0;
for(int i = 0;i<3;i++){
tong = tong+t;
}
float tb = tong/3;
String send = "{\"Nhietdo\":\""+String(t)+"\",\"DoAm\":\""+String(h)+"\",\"TB\":\""+String(tb)+"\"}";
client.publish("VLUTE",String(send).c_str());
}
// <!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>
// <p id = "tb"></p>
// </body>
// </html>
// <script>
// client = new Paho.MQTT.Client("broker.emqx.io", Number(8083), "");
// client.onConnectionLost = onConnectionLost;
// client.onMessageArrived = onMessageArrived;
// client.connect({onSuccess:onConnect});
// function onConnect() {
// console.log("onConnect");
// client.subscribe("VLUTE");
// }
// 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)
// document.getElementById("nhietdo").innerHTML = "Nhiet Do: "+obj.Nhietdo+" Do C";
// document.getElementById("tb").innerHTML = "Nhiet Do trung binh: "+obj.TB+" Do C";
// document.getElementById("doam").innerHTML = "Do Am: "+obj.DoAm+" %";
// var doAm = parseFloat(obj.DoAm);
// if(doAm > 85){
// document.getElementById("doam").innerHTML = "Do Am : "+obj.DoAm+" % độ ẩm cao";
// }else
// document.getElementById("doam").innerHTML = "Do Am : "+obj.DoAm+" % độ ẩm thấp";
// }
// </script>