گلدان هوشمند با MQTT و Node_RED

سلام در این جلسه قصد داریم با استفاده از سنسور رطوبت خاک و سنسور دما و رطوبت و برد Node_MCU و از طریق نرم افزار Node_RED و پروتکل MQTT و پلتفرم ۴ADAIOT یک گلدان هوشمند بسازیم.

شماتیک و اتصالات:

نحوه قرار دادن بلوک ها در پلتفرم برنامه نویسی بلوکی ۴ADAIOT:

کد ساخته شده توسط پلتفرم برنامه نویسی بلوکی ۴ADAIOT:

/////////////////////////////////
// Generated with a lot of love//
// with 4ADAIOT FOR ESP8266     //
// Website: https://4adateam.com    //
/////////////////////////////////
#include <ESP8266WiFi.h>

#include <PubSubClient.h>
#include "DHT.h"

WiFiClient espClient;
PubSubClient client(espClient);

void reconnectmqttserver() {
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
String clientId = "ESP8266Client-";
 clientId += String(random(0xffff), HEX);
if (client.connect(clientId.c_str())) {
Serial.println("connected");
  client.subscribe("relay");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}

DHT dht5(5,DHT11);

char msgmqtt[50];
void callback(char* topic, byte* payload, unsigned int length) {
  String MQTT_DATA = "";
  for (int i=0;i<length;i++) {
   MQTT_DATA += (char)payload[i];}
  if (MQTT_DATA == "on") {
    digitalWrite(16,HIGH);

  }
  if (MQTT_DATA == "off") {
    digitalWrite(16,LOW);

  }
  if (MQTT_DATA == "oton") {
    if (analogRead(A0) > 450) {
      digitalWrite(16,HIGH);

    }
    if (analogRead(A0) < 450) {
      digitalWrite(16,LOW);

    }

  }

}

void setup()
{
  pinMode(16, OUTPUT);
Serial.begin(9600);
  digitalWrite(16,LOW);
  WiFi.disconnect();
  delay(3000);
  Serial.println("START");
   WiFi.begin("نام وایفای","رمز عبور");
  while ((!(WiFi.status() == WL_CONNECTED))){
    delay(300);
    Serial.print("..");

  }
  Serial.println("Connected");
  Serial.println("Your IP is");
  Serial.println((WiFi.localIP().toString()));
  client.setServer("آدرس سرور", ۱۸۸۳);
  client.setCallback(callback);

}


void loop()
{

    if (!client.connected()) {
    reconnectmqttserver();
    }
    client.loop();
    snprintf (msgmqtt, 50, "%f",(dht5.readTemperature( )));
    client.publish("temp", msgmqtt);
    snprintf (msgmqtt, 50, "%f",(dht5.readHumidity()));
    client.publish("hum", msgmqtt);
    snprintf (msgmqtt, 50, "%ld ",analogRead(A0));
    client.publish("ylsens", msgmqtt);
    delay(1300);

}