Wokwi - Online ESP32, STM32, Arduino Simulator

#include <LiquidCrystal_I2C.h>
#include <DHT.h>
#include "PubSubClient.h"
#include <WiFi.h> 

LiquidCrystal_I2C lcd (0x27,16,2);
DHT dht(4,DHT22);
const char * MQTTServer = "broker.hivemq.com";
const char * MQTT_Topic = "pt/nhietdo";
const char * MQTT_Topic1 = "pt/doam";
const char * MQTT_Topic2 = "pt/trungbinh";

const char * MQTT_ID = "mqttx_7e7c4ab4";
int Port = 1883;


// trungbinh
float temperatures[3]; // Mảng để lưu trữ 3 lần đo nhiệt độ
int currentIndex = 0;  //Chỉ số hiện tại trong mảng

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.println(" connected");
      //để nhận dữ liệu từ web
      // client.subscribe(LED_Control_Topic); // Đăng ký chủ đề nhận dữ liệu từ web
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}
void setup() {
  dht.begin();
  lcd.init();
  lcd.backlight();
  Serial.begin(115200);
  Serial.println("Hello, ESP32!");
  WIFIConnect();
  client.setServer(MQTTServer, Port);
}

void loop() {
  if (!client.connected()) {
    MQTT_Reconnect();
  }
  client.loop();
  delay(10); 
  float t = dht.readTemperature();
  float h = dht.readHumidity();
  // Lưu giá trị vào mảng
  temperatures[currentIndex] = t;
   // Tăng chỉ số
  currentIndex = (currentIndex + 1) % 3;

 float avg_temp = 0;
  for (int i = 0; i < 3; i++) {
    avg_temp += temperatures[i];
  }
  avg_temp /= 3;


  lcd.setCursor(0,0);
  lcd.print(t);
  lcd.setCursor(0,1);
  lcd.print(h);
  String nd = String(t);
  String da = String(h);
  String tb = String(avg_temp);
  client.publish(MQTT_Topic, nd.c_str());
  client.publish(MQTT_Topic1, da.c_str());
  client.publish(MQTT_Topic2, tb.c_str());


}




// <!DOCTYPE html>
// <html lang="en">
// <head>
//     <meta charset="UTF-8">
//     <meta name="viewport" content="width=device-width, initial-scale=1.0">
//     <title>Document</title>
//     <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>
//     <h1>DHT22 Sensor Data</h1>
//     <div id="data">
//         <p class="row">Temperature: <span id="temperature" class="value">Loading...</span> °C</p>
//         <p class="row">Humidity: <span id="humidity" class="value">Loading...</span> % <span id="humidityAlert" class="alert"></span></p>
//         <p class="row">Avg: <span id="trungbinh" class="value">Loading...</span> % <span id="avgAlert" class="alert"></span></p>
//         <!--<p class="row">Max: <span id="max" class="value">Loading...</span> % <span id="MAX" class="alert"></span></p>
//         <p class="row">Min: <span id="min" class="value">Loading...</span> % <span id="MIN" class="alert"></span></p> -->
//     </div>
//     <script>
//          var client = new Paho.MQTT.Client("broker.hivemq.com", 8000, "clientId-" + Math.random().toString(36).substring(2, 15));

//         client.onConnectionLost = function (responseObject) {
//             if (responseObject.errorCode !== 0) {
//                 console.log("onConnectionLost:" + responseObject.errorMessage);
//             }
//         };  

//         client.onMessageArrived = function (message) {
//             console.log("onMessageArrived:" + message.destinationName + " - " + message.payloadString);
//             if (message.destinationName === "pt/nhietdo")
//              {
//                 $('#temperature').text(message.payloadString);
//             } else if (message.destinationName === "pt/doam")
//             {
//                 $('#humidity').text(message.payloadString);
//             }
//             else if (message.destinationName==="pt/trungbinh")
//             {
//                 $('#trungbinh').text(message.payloadString);

//             }
//         }

//         client.connect({
//             onSuccess: function () {
//                 console.log("Connected to MQTT broker");
//                 client.subscribe("pt/nhietdo");
//                 client.subscribe("pt/doam");
//                 client.subscribe("pt/trungbinh");
//                 // client.subscribe("max");
//                 // client.subscribe("min");

//             },
//             useSSL: false,
//             timeout: 3,
//             onFailure: function (message) {
//                 console.error("Connection failed: " + message.errorMessage);
//             }
//         });

//     </script>
// </body>
// </html>