#include <WiFi.h>
#include <MQTT.h>
WiFiClient net;
MQTTClient client;
const char ssid[] = "Wokwi-GUEST";
const char pass[] = "";
const int pinLED = 4;
void setup() {
Serial.begin(9600);
pinMode(pinLED, OUTPUT);
WiFi.begin(ssid, pass);
client.begin("broker.hivemq.com", net);
client.onMessage(subscribe);
connect();
}
void loop() {
client.loop();
if(!client.connected()){
connect();
}
delay(10);
}
void subscribe(String &topic, String &data){
Serial.print("Topic: ");
Serial.println(topic);
Serial.print("Data: ");
Serial.println(data);
if(topic == "PraktikumIoT/p9"){
if(data == "NYALA"){
digitalWrite(pinLED, HIGH);
}else if(data == "MATI"){
digitalWrite(pinLED, LOW);
}
}
}
void connect(){
Serial.print("\nMenghubungkan ke WiFi");
while (WiFi.status() != WL_CONNECTED) {
Serial.print(".");
delay(500);
}
Serial.println("\nBerhasil terhubung ke WiFi");
while(!client.connect("clientId-2nIzQA1Gox")
){
delay(50000);
}
Serial.print("MQTT Connect");
//Memanggil Variabel + melakukan Fungsi Subscribe + argumen (Topik, QoS) setelah terhubung ke broker
client.subscribe("PraktikumIoT/p9", 0);
}