/*************************************************** Adafruit MQTT Library ESP8266 Example
Must use ESP8266 Arduino from: https://github.com/esp8266/Arduino
Works great with Adafruit's Huzzah ESP board & Feather ----> https://www.adafruit.com/product/2471 ----> https://www.adafruit.com/products/2821
Adafruit invests time and resources providing this open source code, please support Adafruit and open-source hardware by purchasing products from Adafruit!
Written by Tony DiCola for Adafruit Industries. MIT license, all text above must be included in any redistribution ****************************************************/ #include <ESP8266WiFi.h> #include "Adafruit_MQTT.h" #include "Adafruit_MQTT_Client.h"
/************************* WiFi Access Point *********************************/ #define WLAN_SSID "Sher_Locked" // Your SSID #define WLAN_PASS "werewolf" // Your password
/************************* Adafruit.io Setup *********************************/
#define AIO_SERVER "io.adafruit.com" #define AIO_SERVERPORT 1883 // use 8883 for SSL #define IO_USERNAME "jamezmor" #define IO_KEY "aio_pdhn86yu1dfxI2GNX95wfp7iET8t"
/************ Global State (you don't need to change this!) ******************/
// Create an ESP8266 WiFiClient class to connect to the MQTT server. WiFiClient client; // or... use WiFiFlientSecure for SSL //WiFiClientSecure client;
// Setup the MQTT client class by passing in the WiFi client and MQTT server and login details. Adafruit_MQTT_Client mqtt(&client, AIO_SERVER, AIO_SERVERPORT, AIO_USERNAME, AIO_KEY);
/****************************** Feeds ***************************************/
// Setup a feed called 'onoff' for subscribing to changes. Adafruit_MQTT_Subscribe Redbutton = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/Red Light"); Adafruit_MQTT_Subscribe Greenbutton = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/Green Light"); Adafruit_MQTT_Subscribe Bluebutton = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/Blue Light");
/*************************** Sketch Code ************************************/
// Bug workaround for Arduino 1.6.6, it seems to need a function declaration // for some reason (only affects ESP8266, likely an arduino-builder bug). void MQTT_connect();
void setup() { Serial.begin(115200); pinMode(D1, OUTPUT); pinMode(D2, OUTPUT); pinMode(D3, OUTPUT);
delay(10);
Serial.println(F("Adafruit MQTT demo"));
// Connect to WiFi access point. Serial.println(); Serial.println(); Serial.print("Connecting to "); Serial.println(WLAN_SSID);
WiFi.begin(WLAN_SSID, WLAN_PASS); while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.print("."); } Serial.println();
Serial.println("WiFi connected"); Serial.println("IP address: "); Serial.println(WiFi.localIP());
// Setup MQTT subscription for onoff feed. mqtt.subscribe(&Redbutton); mqtt.subscribe(&Greenbutton); mqtt.subscribe(&Bluebutton); }
uint32_t x = 0;
void loop() { // Ensure the connection to the MQTT server is alive (this will make the first // connection and automatically reconnect when disconnected). See the MQTT_connect // function definition further below. MQTT_connect();
// this is our 'wait for incoming subscription packets' busy subloop // try to spend your time here
Adafruit_MQTT_Subscribe *subscription; while ((subscription = mqtt.readSubscription(5000))) { if (subscription == &Redbutton) { Serial.print(F("Got: ")); Serial.println((char *)Redbutton.lastread); String message = (char *)Redbutton.lastread; if (message == "ON") { digitalWrite(D1, HIGH); delay(3000); digitalWrite(D1, HIGH);
}
else
{
digitalWrite(D1, HIGH);
delay(3000);
digitalWrite(D1, HIGH);
}
}
if (subscription == &Greenbutton) {
Serial.print(F("Got: "));
Serial.println((char *)Greenbutton.lastread);
String message = (char *)Greenbutton.lastread;
if (message == "ON")
{
digitalWrite(D1, HIGH);
delay(3000);
digitalWrite(D1, HIGH);
}
else
{
digitalWrite(D1, HIGH);
delay(3000);
digitalWrite(D1, HIGH);
}
}
if (subscription == &Bluebutton) {
Serial.print(F("Got: "));
Serial.println((char *)Bluebutton.lastread);
String message = (char *)Bluebutton.lastread;
if (message == "ON")
{
digitalWrite(D1, HIGH);
delay(3000);
digitalWrite(D1, HIGH);
}
else
{
digitalWrite(D1, HIGH);
delay(3000);
digitalWrite(D1, HIGH);
}
}
}
// ping the server to keep the mqtt connection alive // NOT required if you are publishing once every KEEPALIVE seconds /* if(! mqtt.ping()) { mqtt.disconnect(); } */ }
// Function to connect and reconnect as necessary to the MQTT server. // Should be called in the loop function and it will take care if connecting. void MQTT_connect() {
// // Stop if already connected if (mqtt.connected() && mqtt.ping()) { // mqtt.disconnect(); return; }
int8_t ret;
mqtt.disconnect();
Serial.print("Connecting to MQTT... "); uint8_t retries = 3; while ((ret = mqtt.connect()) != 0) // connect will return 0 for connected { Serial.println(mqtt.connectErrorString(ret)); Serial.println("Retrying MQTT connection in 5 seconds..."); mqtt.disconnect(); delay(5000); // wait 5 seconds retries--; if (retries == 0) { ESP.reset(); } } Serial.println("MQTT Connected!"); }