Created
August 11, 2016 17:57
-
-
Save shawngrimes/2b7c8cb30ee05f0dace9f194d0cc5543 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#include <ESP8266WiFi.h> | |
#include <Adafruit_MQTT.h> | |
#include <Adafruit_MQTT_Client.h> | |
#include "DHT.h" | |
#define DHTPIN 14 // what digital pin we're connected to | |
#define DHTTYPE DHT22 // DHT 22 (AM2302), AM2321 | |
DHT dht(DHTPIN, DHTTYPE); | |
/************************* WiFi Access Point *********************************/ | |
#define WLAN_SSID "[Wifi Network Name]" | |
#define WLAN_PASS "[Wifi Network Password]" | |
/************************* Adafruit.io Setup *********************************/ | |
#define AIO_SERVER "io.adafruit.com" | |
#define AIO_SERVERPORT 1883 | |
#define AIO_USERNAME "username" | |
#define AIO_KEY "key" | |
/************ Global State (you don't need to change this!) ******************/ | |
// Create an ESP8266 WiFiClient class to connect to the MQTT server. | |
WiFiClient client; | |
// Store the MQTT server, username, and password in flash memory. | |
// This is required for using the Adafruit MQTT library. | |
const char MQTT_SERVER[] PROGMEM = AIO_SERVER; | |
const char MQTT_USERNAME[] PROGMEM = AIO_USERNAME; | |
const char MQTT_PASSWORD[] PROGMEM = AIO_KEY; | |
// Setup the MQTT client class by passing in the WiFi client and MQTT server and login details. | |
Adafruit_MQTT_Client mqtt(&client, MQTT_SERVER, AIO_SERVERPORT, MQTT_USERNAME, MQTT_PASSWORD); | |
/****************************** Feeds ***************************************/ | |
// Setup a feed called 'photocell' for publishing. | |
// Notice MQTT paths for AIO follow the form: <username>/feeds/<feedname> | |
const char dhftemp_feed[] PROGMEM = AIO_USERNAME "/feeds/dhftemp"; | |
Adafruit_MQTT_Publish dhftemp = Adafruit_MQTT_Publish(&mqtt, dhftemp_feed); | |
const char dhfhumid_feed[] PROGMEM = AIO_USERNAME "/feeds/dhfhumid"; | |
Adafruit_MQTT_Publish dhfhumid = Adafruit_MQTT_Publish(&mqtt, dhfhumid_feed); | |
// 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() { | |
// put your setup code here, to run once: | |
Serial.begin(9600); | |
// 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()); | |
dht.begin(); | |
} | |
uint32_t x=0; | |
void loop() { | |
// put your main code here, to run repeatedly: | |
// 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(); | |
float h = dht.readHumidity(); | |
// Read temperature as Fahrenheit (isFahrenheit = true) | |
float f = dht.readTemperature(true); | |
Serial.print("Humidity: "); | |
Serial.print(h); | |
Serial.print(" %\t"); | |
Serial.print("Temperature: "); | |
Serial.print(f); | |
Serial.print(" *F\t"); | |
dhftemp.publish(f); | |
dhfhumid.publish(h); | |
// ping the server to keep the mqtt connection alive | |
if(! mqtt.ping()) { | |
mqtt.disconnect(); | |
} | |
// Wait a few seconds between measurements. | |
delay(600000); | |
} | |
// 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() { | |
int8_t ret; | |
// Stop if already connected. | |
if (mqtt.connected()) { | |
return; | |
} | |
Serial.print("Connecting to MQTT... "); | |
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 | |
} | |
Serial.println("MQTT Connected!"); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment