- Selamat Datang di Website resmi SMKS Sanjaya Bajawa, berlokasi di Jalan Let.Jend. Soeprapto, Kec. Bajawa-Kabupaten Ngada-Flores, Nusa Tenggara Timur-Kontak Admin 082236008339
- Selamat Datang di Website resmi SMKS Sanjaya Bajawa, berlokasi di Jalan Let.Jend. Soeprapto, Kec. Bajawa-Kabupaten Ngada-Flores, Nusa Tenggara Timur-Kontak Admin 082236008339
NodeMCU ESP8266 Dengan Protokol MQTT
Selamat pagi anak-anak, kali ini kita akan belajar cara menggunakan NodeMCU ESP8266 untuk keperluan project internet of things dengan protokol komunikasi MQTT – Message Queuing Telemetry Transport.
MQTT diciptakan pada tahun 1999 oleh Dr. Andy Stanford-Clark dari IBM dan Arlen Nipper dari Arcom. MQTT adalah salah satu protokol yang sering digunakan untuk keperluan Internet of Things yang berjalan di atas TCP/IP dan bersifat Open Source. MQTT mendukung pengiriman pesan antara perangkat ke cloud dan cloud ke perangkat.Kebutuhan bahan untuk praktek :
- Modul Relay
- Node MCU ESP8266
- Kabel Jumper
- BreadBoard
- Kabel Micro USB
- Aplikasi MQTT didownload bebas di Android atau Apps
Hubungkan :
- GND Relay => GND Node MCU
- VCC Relay => Vin Node MCU
- In1 Relay=>D3
- In2 Relay=>D4
- D6
- D7
- Selanjutnya utk Beban perangkat Elektronik misalnya Lampu =>Pin COm dan NO dari masing2 Relay nya; misalnya dibawah ini Relay 4 Channel dibawah ini.
KODING NODE MCU
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#define relay1 D3
#define relay2 D4
#define relay3 D6
#define relay4 D7
const char* ssid = “NAMA WIFI”;
const char* password = “PASSWORD WIFI”;
const char* mqtt_server = “broker.mqtt-dashboard.com”;
WiFiClient espClient;
PubSubClient client(espClient);
unsigned long lastMsg = 0;
#define MSG_BUFFER_SIZE (50)
char msg[MSG_BUFFER_SIZE];
int value = 0;
String publish = “idrusproject/msg”;
String subscribe = “idrusproject/relays”;
void setup() {
Serial.begin(115200);
pinMode(relay1, OUTPUT);
pinMode(relay2, OUTPUT);
pinMode(relay3, OUTPUT);
pinMode(relay4, OUTPUT);
digitalWrite(relay1, 1);
digitalWrite(relay2, 1);
digitalWrite(relay3, 1);
digitalWrite(relay4, 1);
setup_wifi();
client.setServer(mqtt_server, 1883);
client.setCallback(callback);
}
void loop() {
if (!client.connected()) {
reconnect();
}
client.loop();
delay(100);
}
KODING FUNCTION
void setup_wifi() {
delay(10);
Serial.println();
Serial.print(“Connecting to “);
Serial.println(ssid);
WiFi.mode(WIFI_STA);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(“.”);
}
randomSeed(micros());
Serial.println(“”);
Serial.println(“WiFi connected”);
Serial.println(“IP address: “);
Serial.println(WiFi.localIP());
}
void callback(char* topic, byte* payload, unsigned int length) {
Serial.print(“Message arrived [“);
Serial.print(topic);
Serial.print(“] “);
// Create a String to hold the payload
String payloadString = “”;
for (int i = 0; i < length; i++) {
payloadString += (char)payload[i];
}
Serial.println(payloadString);
if (payloadString == “relay1_on”) {
digitalWrite(relay1, LOW);
Serial.println(“Relay 1 ON”);
} else if (payloadString == “relay1_off”) {
digitalWrite(relay1, HIGH);
Serial.println(“Relay 1 OFF”);
} else if (payloadString == “relay2_on”) {
digitalWrite(relay2, LOW);
Serial.println(“Relay 2 ON”);
} else if (payloadString == “relay2_off”) {
digitalWrite(relay2, HIGH);
Serial.println(“Relay 2 OFF”);
} else if (payloadString == “relay3_on”) {
digitalWrite(relay3, LOW);
Serial.println(“Relay 3 ON”);
} else if (payloadString == “relay3_off”) {
digitalWrite(relay3, HIGH);
Serial.println(“Relay 3 OFF”);
} else if (payloadString == “relay4_on”) {
digitalWrite(relay4, LOW);
Serial.println(“Relay 4 ON”);
} else if (payloadString == “relay4_off”) {
digitalWrite(relay4, HIGH);
Serial.println(“Relay 4 OFF”);
}
}
void pubMessage() {
lastMsg = millis();
++value;
snprintf (msg, MSG_BUFFER_SIZE, “hello world #%ld”, value);
Serial.print(“Publish message: “);
Serial.println(msg);
client.publish(“outTopic”, msg);
}
void reconnect() {
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.publish(publish.c_str(), “ONLINE !”);
client.subscribe(subscribe.c_str());
} else {
Serial.print(“failed, rc=”);
Serial.print(client.state());
Serial.println(” try again in 5 seconds”);
// Wait 5 seconds before retrying
delay(5000);
}
}
}
Artikel Lainnya
Tinggalkan Komentar