alex9ufo 聰明人求知心切: ESP32 — MQTT 基本範例 (Node-Red , MQTT, SQLite)---2

ESP32 — MQTT 基本範例 (Node-Red , MQTT, SQLite)---2

ESP32 arduino程式 (WOKWI)

// Wifi 與 MQttClient 程式庫

#include <ArduinoMqttClient.h>

#include <WiFi.h>

int LED = 2;  //定義LED接腳

char ssid[]="Wokwi-GUEST";

char pass[]="";

WiFiClient wifiClient;

MqttClient mqttClient(wifiClient);

//const char broker[] = "test.mosquitto.org";

const char broker[] = "broker.mqtt-dashboard.com";

int        port     = 1883;

String json = "";

const char *SubTopic1 = "alex9ufo/led/led_event";

const char *PubTopic2 = "alex9ufo/led/led_status";

const char willTopic[] = "alex9ufo/led/Starting";

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

//布林代數 LED狀態 是否連上網路ESP32 ready ?

bool ledState = false;

bool atwork = false;

bool Send = false;  //true

String LEDjson = "";

int Count= 0;

bool Flash = false;  //true

bool Timer = false;  //true

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

void onMqttMessage(int messageSize) {

  // we received a message, print out the topic and contents

  Serial.print("Received a message with topic '");

  Serial.print(mqttClient.messageTopic());

  String Topic= mqttClient.messageTopic();

  Serial.print("', duplicate = ");

  Serial.print(mqttClient.messageDup() ? "true" : "false");

  Serial.print(", QoS = ");

  Serial.print(mqttClient.messageQoS());

  Serial.print(", retained = ");

  Serial.print(mqttClient.messageRetain() ? "true" : "false");

  Serial.print("', length ");

  Serial.print(messageSize);

  Serial.println(" bytes:");

  String message="";

  // use the Stream interface to print the contents

  while (mqttClient.available()) {

    //Serial.print((char)mqttClient.read());

    message += (char)mqttClient.read();

}

  Serial.println(message);

  message.trim();

  Topic.trim();

  if (Topic=="alex9ufo/led/led_event") {

  if (message == "on") {

    digitalWrite(LED, LOW);  // Turn on the LED

    //ledState = true;  //ledState = ture HIGH

    //設定 各個 旗號

    LEDjson ="ON";

    Send = true ;

    Serial.print("LED =");

    Serial.println(LEDjson);

}

  if (message == "off" ) {

    digitalWrite(LED, HIGH); // Turn off the LED

    //ledState = false; //ledState = false LOW

    LEDjson ="OFF";

    Send = true ;

    Serial.print("LED =");

    Serial.println(LEDjson);

}

  if (message == "flash" ) {

    digitalWrite(LED, HIGH); // Turn off the LED

    Flash = true;

    Timer = false;

    LEDjson ="FLASH";

    Send = true ;  

    Serial.print("LED =");

    Serial.println(LEDjson);      

}

  if (message == "timer" ) {

    digitalWrite(LED, LOW); // Turn off the LED

    Flash = false;

    Timer = true;

    LEDjson ="TIMER";

    Send = true ;

    Count= 11;

    Serial.print("LED =");

    Serial.println(LEDjson);   

}

    Serial.println();

    Serial.println("-----------------------");

}

}

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

//副程式  setup wifi

void setup_wifi() {

  delay(10);

  // We start by connecting to a WiFi network

  Serial.println();

  Serial.print("Connecting to ");

  Serial.println(ssid);     //print ssid

  WiFi.begin(ssid, pass);  //初始化WiFi 函式庫並回傳目前的網路狀態

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

    delay(500);

    Serial.print(".");

  }   //假設 wifi 未連接 show ………

  Serial.println("");

  Serial.println("WiFi connected");

  Serial.println("IP address: ");

  Serial.println(WiFi.localIP());

}

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

//判斷 旗號Flash , Timer 是否為真

void LED_Message() {

  //判斷 旗號 Flash / timer  是否為真 ? 閃爍 定時

  if (Flash){

    digitalWrite(LED, !digitalRead(LED));

    delay(500);

    if (digitalRead(LED))

      ledState = true;

    else

      ledState = false;

  } //(Flash)

  if (Timer) {

    digitalWrite(LED, LOW);

    delay(500);

    if (digitalRead(LED))

      ledState = true;

    else

      ledState = false;

  Count=Count-1;

  if (Count == 0 ){

    Timer=false;

    digitalWrite(LED, HIGH);

    ledState = false;

}

  } //(Timer)

  ////判斷 旗號 Send 是否為真 回傳MQTT訊息到MQTT Broker　

  if (Send) {

    // Convert JSON string to character array

    Serial.print("Publish message: ");

    Serial.println(LEDjson);

    LEDjson.trim();

    bool retained = false;

    int qos = 1;

    bool dup = false;

    // Publish JSON character array to MQTT topic

    mqttClient.beginMessage(PubTopic2,  LEDjson.length(), retained, qos, dup);  //LED Status

    mqttClient.print(LEDjson);

    mqttClient.endMessage();

    Send = false;    //處理過後 旗號 Send為假

}

}

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

void setup() {

  pinMode(LED, OUTPUT);

  digitalWrite(LED, HIGH);  // Turn off the LED initially

  //Initialize serial and wait for port to open: 

  Serial.begin(115200);   // Initialize serial communications with the PC

  while (!Serial);    // Do nothing if no serial port is opened (added for Arduinos based on ATMEGA32U4)

  setup_wifi();

  Serial.println("You're connected to the network");

  Serial.println();

  String willPayload = "ESP32 Start working....!";

  bool willRetain = true;

  int willQos = 1;

  mqttClient.beginWill(willTopic, willPayload.length(), willRetain, willQos);

  mqttClient.print(willPayload);

  mqttClient.endWill();

  Serial.print("Attempting to connect to the MQTT broker: ");

  Serial.println(broker);

  if (!mqttClient.connect(broker, port)) {

    Serial.print("MQTT connection failed! Error code = ");

    Serial.println(mqttClient.connectError());

    while (1);

}

  Serial.println("You're connected to the MQTT broker!");

  Serial.println();

  // set the message receive callback

  mqttClient.onMessage(onMqttMessage);

  Serial.print("Subscribing to topic: ");

  Serial.println(SubTopic1);

  // subscribe to a topic

  // the second parameter sets the QoS of the subscription,

  // the the library supports subscribing at QoS 0, 1, or 2

  int subscribeQos = 1;

  mqttClient.subscribe(SubTopic1, subscribeQos);

}

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

void loop() {

  // call poll() regularly to allow the library to receive MQTT messages and

  // send MQTT keep alives which avoids being disconnected by the broker

  mqttClient.poll();

  LED_Message();

}

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

Node-Red程式

2024-05-27 更新 Node-Red 含 Line Notify

設定 LINE Notify https://md.webduino.io/s/LCGRt1Jve

「LINE Notify」的服務，透過開通權杖 ( Token )，讓 Node-Red(LED) 主動傳訊息至 LINE 帳號中，可用來結合通知、警告等應用。

準備好自己的 LINE 帳號密碼。
前往 LINE Notify 官方網站。( 請使用電腦開啟！)
登入帳號。
點擊右上角帳號，選擇選單中的「個人頁面」。
點擊「發行權杖」。
設定權杖，填寫權杖名稱、接收通知的聊天室。這裡以「透過1對1聊天接收LINE Notify的通知」為例。
- 權杖名稱：發送訊息時，會顯示的名稱。
- 接收通知的聊天室：要使用 Notify 的聊天室，或是個人訊息。
按下「發行」後，會出現發行的權杖如下圖，並將權杖複製。
權杖只會顯示 1 次，每次使用程式積木都需要輸入，為避免忘記，建議先將權杖記錄下來。
設定完成後，就可以在「已連動的服務」中看到剛剛設定的權杖了。
打開 LINE 應用程式，可以看到名稱為「LINE Notify」的帳號發送訊息「已發行個人存取權杖。」。