/*
Example MQTT-switch-relay-node with 4 buttons and 4 relays
- connects to an MQTT server
- subscribes to the topic "relay"
- controls 4 relays
- reads 4 button
- turns on/off a specific relay when it receives a specific "on"/"off" from the "relay" topic
- sends a specific "on"/"off" to the "relay" topic a specific button is pressed
- multiple arduino's with same generic sketch can run parallel to each other
- multiple arduino's need each to have a unique ip-addres, unique mac address and unique MQTT client-ID
- control DHT11 sensor temperature and humidity sensor
- control PIR sensor HC-SR501HC - NEED TO CHECK!
- led for PIR sensor (showing activity)
- tested on arduino-mega with W5100 ethernet shield - NEED more testing!
- Ethernet Shield W5100
*/
//------------------------------------------------------------------------------
#include <SPI.h>
#include <Ethernet.h>
#include <PubSubClient.h>
#include <Bounce2.h>
#include "DHT.h"
// --- temp/hum sensor --//
#define DHTPIN 11 // what pin we're connected to
#define humidity_topic "home/humidity1"
#define temperature_topic "home/temperature1"
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);
// --- temp/hum sensor --//
// --- PIR sensor --//
int pirPin = 12; //the digital pin connected to the PIR sensor's output
int ledpirPin = 13;
int lastPirValue = LOW;
// --- PIR sensor --//
// Set relay variables to Arduino digital pins
int relay1 = 2;
int relay2 = 3;
int relay3 = 5; // pin 4 used by ethernet shield
int relay4 = 6;
// Set button variables to Arduino digital pins
int button1 = 7;
int button2 = 8;
int button3 = 9;
int button4 = 31; // pins 10,51,52 used by ethernetshield
// Set variables to act as virtual switches
// Set variable values initially to LOW (and not HIGH)
int relay1Value = LOW;
int relay2Value = LOW;
int relay3Value = LOW;
int relay4Value = LOW;
//---------------------------------------------------------------------------
// Arduino MAC address is on a sticker on your Ethernet shield
// must be unique for every node in same network
// To make a new unique address change last letter
byte mac[] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xEE };
// Unique static IP address of this Arduino - change to adapt to your network
IPAddress ip(192,168,0,201);
// IP Address of your MQTT broker - change to adapt to your network
IPAddress server(192, 168, 1, 140);
char message_buff[100]; // this buffers our incoming messages so we can do something on certain commands
EthernetClient ethClient;
PubSubClient client(ethClient);
long lastReconnectAttempt = 0;
boolean reconnect() {
//Serial.print("Attempting MQTT connection...");
if (client.connect("ethClient", "mqtt", "xxx")) {
// Once connected, publish an announcement...
client.publish("home","connected");
Serial.println("connected");
// ... and resubscribe
client.subscribe("home/#");
}
else {
Serial.print("fairelay, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
return client.connected();
}
// Handle and convert incoming MQTT messages ----------------------------------------
void callback(char* topic, byte* payload, unsigned int length) {
// handle message arrived
String content="";
char character;
for (int num=0;num<length;num++) {
character = payload[num];
content.concat(character);
}
Serial.println(topic);
Serial.println(content); // message sent out by button actions is returned from broker and serial printed
// Set specific virtual switches on basis of specific incoming messages ----------------------------
if (content == "1on") {
relay1Value = HIGH;
}
if (content == "1off") {
relay1Value = LOW;
}
if (content == "2on") {
relay2Value = HIGH;
}
if (content == "2off") {
relay2Value = LOW;
}
if (content == "3on") {
relay3Value = HIGH;
}
if (content == "3off") {
relay3Value = LOW;
}
if (content == "4on") {
relay4Value = HIGH;
}
if (content == "4off") {
relay4Value = LOW;
}
// Set digital pin states according to virtual switch settings
digitalWrite(relay1,relay1Value);
digitalWrite(relay2,relay2Value);
digitalWrite(relay3,relay3Value);
digitalWrite(relay4,relay4Value);
}
// Initiate instances -----------------------------------
// Initiate a bouncer instance for each button
Bounce bouncer1 = Bounce();
Bounce bouncer2 = Bounce();
Bounce bouncer3 = Bounce();
Bounce bouncer4 = Bounce();
//-------------------------------------------------------
void setup()
{
// setup relay, button, bouncer 1 -----------------------
pinMode(relay1, OUTPUT);
pinMode(button1,INPUT);
digitalWrite(button1,HIGH);
bouncer1 .attach(button1);
bouncer1 .interval(5);
// setup relay, button, bouncer 2 -----------------------
pinMode(relay2, OUTPUT);
pinMode(button2,INPUT);
digitalWrite(button2,HIGH);
bouncer2 .attach(button2);
bouncer2 .interval(5);
// setup relay, button, bouncer 3 -----------------------
pinMode(relay3, OUTPUT);
pinMode(button3,INPUT);
digitalWrite(button3,HIGH);
bouncer3 .attach(button3);
bouncer3 .interval(5);
// setup relay, button, bouncer 4 -----------------------
pinMode(relay4, OUTPUT);
pinMode(button4,INPUT);
digitalWrite(button4,HIGH);
bouncer4 .attach(button4);
bouncer4 .interval(5);
// setup serial and ethernet communications -------------------------------
// Setup serial connection
Serial.begin(9600);
// Setup ethernet connection to MQTT broker
client.setServer("192.168.0.140", 8123);
client.setCallback(callback);
Ethernet.begin(mac, ip);
delay(1500);
lastReconnectAttempt = 0;
Serial.println(Ethernet.localIP());
// --- temp/hum sensor --//
dht.begin();
// --- temp/hum sensor --//
// --- PIR sensor --//
pinMode(pirPin, INPUT);
pinMode(ledpirPin, OUTPUT);
// --- PIR sensor --//
}
// --- temp/hum sensor --//
bool checkBound(float newValue, float prevValue, float maxDiff) {
return newValue < prevValue - maxDiff || newValue > prevValue + maxDiff;
}
long lastMsg = 0;
float temp = 0.0;
float hum = 0.0;
float diff = 1.0;
// --- temp/hum sensor --//
void loop()
{
if (!client.connected()) {
long now = millis();
if (now - lastReconnectAttempt > 5000) {
lastReconnectAttempt = now;
// Attempt to reconnect
if (reconnect()) {
lastReconnectAttempt = 0;
}
}
}
else {
client.loop(); }
// Listen for button interactions and take actions ----------------------------------------
// Note: Button actions do send MQTT message AND do set relay(x)Value to HIGH or LOW
if (bouncer1.update()) {
if (bouncer1.read() == HIGH) {
if (relay1Value == LOW) {
relay1Value = HIGH;
client.publish("home/relay","1on");
} else {
relay1Value = LOW;
client.publish("home/relay","1off");
}
}
}
//-----------------------------------------------
if (bouncer2.update()) {
if (bouncer2.read() == HIGH) {
if (relay2Value == LOW) {
relay2Value = HIGH;
client.publish("home/relay","2on");
} else {
relay2Value = LOW;
client.publish("home/relay","2off");
}
}
}
//------------------------------------------------
if (bouncer3.update()) {
if (bouncer3.read() == HIGH) {
if (relay3Value == LOW) {
relay3Value = HIGH;
client.publish("home/relay","3on");
} else {
relay3Value = LOW;
client.publish("home/relay","3off");
}
}
}
//-----------------------------------------------
if (bouncer4.update()) {
if (bouncer4.read() == HIGH) {
if (relay4Value == LOW) {
relay4Value = HIGH;
client.publish("home/relay","4on");
} else {
relay4Value = LOW;
client.publish("home/relay","4off");
}
}
}
// --- temp/hum sensor --//
long now = millis();
if (now - lastMsg > 60000) {
lastMsg = now;
// Reading temperature or humidity takes about 250 milliseconds!
// Sensor readings may also be up to 2 seconds 'old' (its a very slow sensor)
float newHum = dht.readHumidity();
// Read temperature as Fahrenheit (isFahrenheit = true)
float newTemp = dht.readTemperature();
if (checkBound(newTemp, temp, diff)) {
temp = newTemp;
Serial.print("New temperature:");
Serial.println(String(temp).c_str());
client.publish(temperature_topic, String(temp).c_str());
}
if (checkBound(newHum, hum, diff)) {
hum = newHum;
Serial.print("New humidity:");
Serial.println(String(hum).c_str());
client.publish(humidity_topic, String(hum).c_str());
}
}
// --- temp/hum sensor --//
// --- PIR sensor --//
int pirValue = digitalRead(pirPin);
if (pirValue != lastPirValue) {
if (pirValue == HIGH) {
digitalWrite(ledpirPin, HIGH);
String message = String(pirValue);
client.publish("home/ruch1", message.c_str());
Serial.println(message.c_str());
}
if (pirValue == LOW) {
digitalWrite(ledpirPin, LOW);
String message = String(pirValue);
client.publish("home/ruch1", message.c_str());
Serial.println(message.c_str());
}
Serial.println(pirValue);
lastPirValue = pirValue;
// delay(30 * 1000);
}
// --- PIR sensor --//
}
// End of sketch ---------------------------------
