#include <WiFi.h>
#include <WiFiClient.h>
#include <PubSubClient.h>
#include <LiquidCrystal_I2C.h>
LiquidCrystal_I2C lcd(0x27,16,2);
int ledPin = 27;
long previousMillis = 0; // will store last time LED
int interval = 1000; //Intervalo para o Blink
const char* ssid = "SENAI_ACADEMICO";
const char* password = "Senai*Academico";
const char* hostname = "test.mosquitto.org";
WiFiClient espClient;
PubSubClient client(espClient);
const char* espClientName = "454545eeeeee"; //Esse ID deverá ser unico
int PORTNUM = 1883;
void setup_wifi()
{
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED )
{
delay(1000);
Serial.print(".");
}
Serial.println();
Serial.print("Conectado a rede SSID: ");
Serial.println(ssid);
Serial.print("IP: ");
Serial.println(WiFi.localIP());
}
void connectMQTT()
{
while (!client.connected() )
{
Serial.println("Conectando ao MQTT ...");
if (client.connect(espClientName) ) //, mqttUser, mqttPassword) )
{
Serial.println("Conectado");
MQTTSubscribe();
}
else
{
Serial.print("Falha com Estado: ");
Serial.print(client.state() );
delay(2000);
}
}
}
void callback(String topic, byte* payload, unsigned int length)
{
String messageTemp;
Serial.print("Mensagem recebida no TOPICO:");
Serial.print(topic);
Serial.print("O Tamanho da Mensagem: ");
Serial.println(length);
Serial.print("Dados Recebidos no Broker: ");
for (int i = 0; i < length; i++)
{
messageTemp += (char)payload[i];
}
if (topic == "antonio/IOT")
{
if(messageTemp.toInt() > 2000){
digitalWrite(ledPin,LOW);
}else if(messageTemp.toInt() <2000){
digitalWrite(ledPin,HIGH);
}
lcd.clear();
lcd.setCursor(0,0);
lcd.print(messageTemp);
}
}
void MQTTSubscribe()
{
client.subscribe("antonio/IOT");
}
void setup_MQTT()
{
client.setServer(hostname, PORTNUM);
client.setCallback(callback);
}
void setup()
{
pinMode(ledPin,OUTPUT);
Serial.begin(115200);
lcd.init();
lcd.backlight();
lcd.setCursor(1,0);
lcd.print("BOM DIA");
setup_wifi();
setup_MQTT();
}
void loop()
{
if ( !client.connected() )
{
connectMQTT();
}
client.loop();
long currentMillis = millis();
if ( currentMillis - previousMillis >= interval)
{
previousMillis = currentMillis; // save the last time you blinked the LED
int pot = analogRead(A0);
String potString = String(pot);
client.publish("antonio/IOT", potString.c_str());
}
}