5.3 AI MQTT CiRA

#include <Arduino.h>  

#include<ArduinoJson.h>

#include <WiFi.h>

#include <ESP32Servo.h>

#include <PubSubClient.h>

// Update these with values suitable for your network.

const char* ssid = "BJHome2G";

const char* password = "123456789";

// Config MQTT Server

#define mqtt_server "192.168.1.11"

#define mqtt_port 1883

#define mqtt_user ""

#define mqtt_password ""

#define LED_PIN 26

WiFiClient espClient;

PubSubClient client(espClient);

void setup() {

  pinMode(LED_PIN, OUTPUT);

  Serial.begin(115200);

  delay(10);

  Serial.println();

  Serial.print("Connecting to ");

  Serial.println(ssid);

  WiFi.begin(ssid, password);

  digitalWrite(LED_PIN, HIGH);

  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }

  Serial.println("");

  Serial.println("WiFi connected");

  Serial.println("IP address: ");

  Serial.println(WiFi.localIP());

  client.setServer(mqtt_server, mqtt_port);

  client.setCallback(callback);

}

void loop() {

  if (!client.connected()) {

    Serial.print("Attempting MQTT connection...");

    if (client.connect("ESP32Client", mqtt_user, mqtt_password)) {

      Serial.println("connected");

      client.subscribe("/ESP/LED");  // ESP Topic

    } else {

      Serial.print("failed, rc=");

      Serial.print(client.state());

      Serial.println(" try again in 5 seconds");

      delay(5000);

      return;

    }

  }

  client.loop();

}

void callback(char* topic, byte* payload, unsigned int length) {

  Serial.print("Message arrived [");

  Serial.print(topic);

  Serial.print("] ");

  String msg = "";

  int i = 0;

  while (i < length) msg += (char)payload[i++];

  if (msg == "GET") {

    client.publish("/ESP/LED", (digitalRead(LED_PIN) ? "LEDON" : "LEDOFF"));

    Serial.println("Send !");

    return;

  }

// Cira

const size_t capacity = JSON_OBJECT_SIZE(1); //? Object Size

DynamicJsonDocument doc(capacity);           //? Declare variable for store json

deserializeJson(doc, payload, length); //? deserialize JSON

String msg_cira = doc["a"];       //? Store key title to tittle 

Serial.println( msg_cira);

digitalWrite(LED_PIN, (msg_cira == "LEDON" ? HIGH : LOW));

//

//digitalWrite(LED_PIN, (msg == "LEDON" ? HIGH : LOW));

/*

/////////////////////////////

//if (topic == "/ESP/LED")

//  {

    Serial.println("---  JSON Process ---");

const size_t capacity = JSON_OBJECT_SIZE(1);

   DynamicJsonDocument doc(capacity);           //? Declare variable for store json

    deserializeJson(doc, payload, length); //? deserialize JSON

  String check = doc["a"];       //? Store key title to tittle 

    Serial.println("cira = " + check);

    Serial.println("--- END JSON Process ---");

  }*/

Serial.println(msg);

 // Serial.println(topic);

 /////////////////////////////////////////////////

}