#include <WiFi.h>
#include <PubSubClient.h>
// WiFi
const char *ssid = "Wokwi-GUEST";
const char *password = "";
// MQTT Broker
const char *mqtt_host = "broker.emqx.io";
const char *topic_pub = "XIMIPA3";
const int mqtt_port = 1883;
String client_id = "mqttx_b89df0a3";
int waktu_sebelum, waktu_interval = 1*1000;
WiFiClient espClient;
PubSubClient client(espClient);
void setup() {
Serial.begin(115200);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.println("Menghubungkan ke WiFi..");
}
Serial.println("Terhubung ke WiFi");
//Menghubungkan ke mqtt broker
client.setServer(mqtt_host, mqtt_port);
while (!client.connected()) {
if (client.connect(client_id.c_str())) {
Serial.println("Terhubung ke mqtt broker");
} else {
Serial.print("Gagal Terhubung ");
Serial.print(client.state());
delay(2000);
}
}
// publish and subscribe
client.publish(topic_pub, "Hi, adit");
waktu_sebelum = millis();
}
void loop() {
client.loop();
if(millis() - waktu_sebelum >= waktu_interval){
client.publish(topic_pub, "Hi adit");
Serial.println("Hi adit");
waktu_sebelum = millis();
}
}