#include <WiFi.h> // Biblioteca para conexão Wi-Fi
#include <PubSubClient.h> // Biblioteca para o protocolo MQTT
#include <Wire.h> // Biblioteca para comunicação I2C
#include <LiquidCrystal_I2C.h> // Biblioteca para controle do LCD via I2C
// Credenciais da rede Wi-Fi
const char* ssid = "Wokwi-GUEST";
const char* password = "";
// Endereço do servidor MQTT
const char* mqtt_server = "test.mosquitto.org";
// Instâncias dos objetos WiFi, MQTT e LCD
WiFiClient espClient;
PubSubClient client(espClient);
LiquidCrystal_I2C lcd(0x27, 16, 2); // Endereço I2C do LCD, dimensões 16x2
void setup() {
// Inicializa a comunicação serial
Serial.begin(115200);
// Inicializa o LCD
lcd.init();
lcd.backlight();
// Conecta ao Wi-Fi
setup_wifi();
// Configura o servidor MQTT e a função de callback
client.setServer(mqtt_server, 1883);
client.setCallback(callback);
}
void setup_wifi() {
delay(10);
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
// Inicia a conexão Wi-Fi
WiFi.begin(ssid, password);
// Aguarda a conexão Wi-Fi
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
// Mostra informações da conexão Wi-Fi
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
// Função chamada quando uma mensagem é recebida
void callback(char* topic, byte* payload, unsigned int length) {
Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
// Converte o payload em uma string
String message = "";
for (unsigned int i = 0; i < length; i++) {
message += (char)payload[i];
}
Serial.println(message);
// Limpa o LCD e exibe a mensagem
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("ADC Value:");
lcd.setCursor(0, 1);
lcd.print(message);
}
void reconnect() {
// Tenta reconectar ao servidor MQTT até conseguir
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
if (client.connect("ESP32Client2")) {
Serial.println("connected");
client.subscribe("esp32/adc"); // Inscreve-se no tópico MQTT
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000); // Aguarda 5 segundos antes de tentar novamente
}
}
}
void loop() {
// Verifica e reconecta ao servidor MQTT se necessário
if (!client.connected()) {
reconnect();
}
client.loop();
}