alex9ufo 聰明人求知心切: ESP32 Relay Module & MQTT

ESP32 Relay Module & MQTT

源自於https://randomnerdtutorials.com/esp32-relay-module-ac-web-server/

// Import required libraries

#include "WiFi.h"

#include "ESPAsyncWebServer.h"

//================MQTT=====================

#include <PubSubClient.h> //MQTT

// Set to true to define Relay as Normally Open (NO)

#define RELAY_NO true

// Set number of relays

#define NUM_RELAYS 5

// Assign each GPIO to a relay

int relayGPIOs[NUM_RELAYS] = {2, 26, 27, 25, 33};

// Replace with your network credentials

//const char* ssid = "REPLACE_WITH_YOUR_SSID";

//const char* password = "REPLACE_WITH_YOUR_PASSWORD";

const char* ssid = "TOTOLINK_A3002MU";

const char* password = "24063173";

const char* PARAM_INPUT_1 = "relay";

const char* PARAM_INPUT_2 = "state";

//================MQTT=====================

String inputMessage;

String inputMessage2;

String output2State;

String output26State;

String output27State;

String output25State;

String output33State;

// Create AsyncWebServer object on port 80

AsyncWebServer server(80);

//================MQTT=====================

const char* mqtt_server = "broker.mqtt-dashboard.com" ; //MQTT

//================MQTT=====================

WiFiClient espClient;

PubSubClient client(espClient);

long lastMsg = 0;

char msg[50];

// relayGPIOs[NUM_RELAYS] = {2, 26, 27, 25, 33};

const int output2 = 2;

const int output26 = 26;

const int output27 = 27;

const int output25 = 25;

const int output33 = 33;

//=========================================

const char index_html[] PROGMEM = R"rawliteral(

<!DOCTYPE HTML><html>

<head>

<style>

html {font-family: Arial; display: inline-block; text-align: center;}

h2 {font-size: 3.0rem;}

p {font-size: 3.0rem;}

body {max-width: 600px; margin:0px auto; padding-bottom: 25px;}

.switch {position: relative; display: inline-block; width: 120px; height: 68px}

.switch input {display: none}

.slider {position: absolute; top: 0; left: 0; right: 0; bottom: 0; background-color: #ccc; border-radius: 34px}

.slider:before {position: absolute; content: ""; height: 52px; width: 52px; left: 8px; bottom: 8px; background-color: #fff; -webkit-transition: .4s; transition: .4s; border-radius: 68px}

input:checked+.slider {background-color: #2196F3}

input:checked+.slider:before {-webkit-transform: translateX(52px); -ms-transform: translateX(52px); transform: translateX(52px)}

</style>

</head>

<body>

<h2>ESP Web Server</h2>

%BUTTONPLACEHOLDER%

var xhr = new XMLHttpRequest();

if(element.checked){ xhr.open("GET", "/update?relay="+element.id+"&state=1", true); }

else { xhr.open("GET", "/update?relay="+element.id+"&state=0", true); }

xhr.send();

}</script>

</body>

</html>

)rawliteral";

//=========================================

// Replaces placeholder with button section in your web page

String processor(const String& var){

//Serial.println(var);

if(var == "BUTTONPLACEHOLDER"){

String buttons ="";

for(int i=1; i<=NUM_RELAYS; i++){

String relayStateValue = relayState(i);

buttons+= "<h4>Relay #" + String(i) + " - GPIO " + relayGPIOs[i-1] + "</h4><label class=\"switch\"><input type=\"checkbox\" onchange=\"toggleCheckbox(this)\" id=\"" + String(i) + "\" "+ relayStateValue +"><span class=\"slider\"></span></label>";

}

return buttons;

}

return String();

}

//=========================================

String relayState(int numRelay){

if(RELAY_NO){

if(digitalRead(relayGPIOs[numRelay-1])){

return "";

}

else {

return "checked";

}

else {

if(digitalRead(relayGPIOs[numRelay-1])){

return "checked";

}

else {

return "";

}

return "";

}

//================MQTT=====================

void callback(char* topic, byte* message, unsigned int length) {

Serial.print("Message arrived on topic: ");

Serial.print(topic);

Serial.print(". Message: ");

String messageTemp;

for (int i = 0; i < length; i++) {

Serial.print((char)message[i]);

messageTemp += (char)message[i];

}

Serial.println();

// Feel free to add more if statements to control more GPIOs with MQTT

// If a message is received on the topic esp32/output, you check if the message is either "on" or "off".

// Changes the output state according to the message

//******* relayGPIOs[NUM_RELAYS] = {2, 26, 27, 25, 33};

if (String(topic)=="alex9ufo/esp32/input/LED2") {

if(messageTemp == "on"){

Serial.println("on");

output2State = "on";

digitalWrite(output2, HIGH);

}

else if(messageTemp == "off"){

Serial.println("off");

output2State = "off";

digitalWrite(output2, LOW);

}

if (String(topic)=="alex9ufo/esp32/input/LED26") {

if(messageTemp == "on"){

Serial.println("on");

output26State = "on";

digitalWrite(output26, HIGH);

}

else if(messageTemp == "off"){

Serial.println("off");

output26State = "off";

digitalWrite(output26, LOW);

}

if (String(topic)=="alex9ufo/esp32/input/LED27") {

if(messageTemp == "on"){

Serial.println("on");

output27State = "on";

digitalWrite(output27, HIGH);

}

else if(messageTemp == "off"){

Serial.println("off");

output27State = "off";

digitalWrite(output27, LOW);

}

if (String(topic)=="alex9ufo/esp32/input/LED25") {

if(messageTemp == "on"){

Serial.println("on");

output25State = "on";

digitalWrite(output25, HIGH);

}

else if(messageTemp == "off"){

Serial.println("off");

output25State = "off";

digitalWrite(output25, LOW);

}

if (String(topic)=="alex9ufo/esp32/input/LED33") {

if(messageTemp == "on"){

Serial.println("on");

output33State = "on";

digitalWrite(output33, HIGH);

}

else if(messageTemp == "off"){

Serial.println("off");

output33State = "off";

digitalWrite(output33, LOW);

}

loop_mqtt();

}

//================MQTT=====================

void reconnect() {

// Loop until we're reconnected

while (!client.connected()) {

Serial.print("Attempting MQTT connection...");

// Attempt to connect

if (client.connect("ESP32Client")) {

Serial.println("connected");

// Subscribe

//******* relayGPIOs[NUM_RELAYS] = {2, 26, 27, 25, 33};

client.subscribe("alex9ufo/esp32/input/LED2");

client.subscribe("alex9ufo/esp32/input/LED26");

client.subscribe("alex9ufo/esp32/input/LED27");

client.subscribe("alex9ufo/esp32/input/LED25");

client.subscribe("alex9ufo/esp32/input/LED33");

} else {

Serial.print("failed, rc=");

Serial.print(client.state());

Serial.println(" try again in 5 seconds");

// Wait 5 seconds before retrying

delay(5000);

}

//================MQTT=====================

void loop_mqtt(){

if (!client.connected()) {

reconnect();

}

client.loop();

long now = millis();

if (now - lastMsg > 5000) {

lastMsg = now;

//******* relayGPIOs[NUM_RELAYS] = {2, 26, 27, 25, 33};

client.publish("alex9ufo/esp32/output/LED2", String(output2State).c_str());

client.publish("alex9ufo/esp32/output/LED26", String(output26State).c_str());

client.publish("alex9ufo/esp32/output/LED27", String(output27State).c_str());

client.publish("alex9ufo/esp32/output/LED25", String(output25State).c_str());

client.publish("alex9ufo/esp32/output/LED33", String(output33State).c_str());

}

//=========================================

void setup(){

// Serial port for debugging purposes

Serial.begin(115200);

// Set all relays to off when the program starts - if set to Normally Open (NO), the relay is off when you set the relay to HIGH

for(int i=1; i<=NUM_RELAYS; i++){

pinMode(relayGPIOs[i-1], OUTPUT);

if(RELAY_NO){

digitalWrite(relayGPIOs[i-1], HIGH);

}

else{

digitalWrite(relayGPIOs[i-1], LOW);

}

// Connect to Wi-Fi

WiFi.begin(ssid, password);

while (WiFi.status() != WL_CONNECTED) {

delay(1000);

Serial.println("Connecting to WiFi..");

}

// Print ESP32 Local IP Address

Serial.println(WiFi.localIP());

// Route for root / web page

server.on("/", HTTP_GET, [](AsyncWebServerRequest *request){

request->send_P(200, "text/html", index_html, processor);

});

// Send a GET request to <ESP_IP>/update?relay=<inputMessage>&state=<inputMessage2>

server.on("/update", HTTP_GET, [] (AsyncWebServerRequest *request) {

//String inputMessage;

String inputParam;

//String inputMessage2;

String inputParam2;

// GET input1 value on <ESP_IP>/update?relay=<inputMessage>

if (request->hasParam(PARAM_INPUT_1) & request->hasParam(PARAM_INPUT_2)) {

inputMessage = request->getParam(PARAM_INPUT_1)->value();

inputParam = PARAM_INPUT_1;

inputMessage2 = request->getParam(PARAM_INPUT_2)->value();

inputParam2 = PARAM_INPUT_2;

if(RELAY_NO){

Serial.print("NO ");

digitalWrite(relayGPIOs[inputMessage.toInt()-1], !inputMessage2.toInt());

}

else{

Serial.print("NC ");

digitalWrite(relayGPIOs[inputMessage.toInt()-1], inputMessage2.toInt());

}

else {

inputMessage = "No message sent";

inputParam = "none";

}

Serial.println(inputMessage + inputMessage2);

//******* relayGPIOs[NUM_RELAYS] = {2, 26, 27, 25, 33};

//==================MQTT=======================

int in=inputMessage.toInt();

Serial.println(in);

switch (in) {

case 1 :

if (inputMessage2.substring(0,1)=="1") {

output2State="on";

} else {

output2State="off";

}

break;

case 2 :

if (inputMessage2.substring(0,1)=="1") {

output26State="on";

} else {

output26State="off";

}

break;

case 3 :

if (inputMessage2.substring(0,1)=="1") {

output27State="on";

} else {

output27State="off";

}

break;

case 4 :

if (inputMessage2.substring(0,1)=="1") {

output25State="on";

} else {

output25State="off";

}

break;

case 5 :

if (inputMessage2.substring(0,1)=="1") {

output33State="on";

} else {

output33State="off";

}

break;

default:

break;

}

//=============================================

request->send(200, "text/plain", "OK");

});

// Start server

server.begin();

//================MQTT=====================

client.setServer(mqtt_server, 1883);

client.setCallback(callback);

}

//=========================================

void loop() {

loop_mqtt();

}

alex9ufo 聰明人求知心切

2022年1月3日星期一

ESP32 Relay Module & MQTT

沒有留言:

張貼留言

WOKWI LED + MQTT Node-Red SQLite

2022年1月3日 星期一

ESP32 Relay Module & MQTT

沒有留言:

張貼留言

WOKWI LED + MQTT Node-Red SQLite

2022年1月3日星期一