alex9ufo 聰明人求知心切: 2023

2023年12月31日星期日

Node-Red MQTT基本實驗

ON Bouuton 節點	Payload :　on
OFF Bouuton 節點	Payload :　off
MQTT out節點	Server :broker.hivemq.com :　1883 Qos=1 保留: 是發行主題 : alex9ufo/node-red/out
MQTT in節點	Server :broker.hivemq.com :　1883 Qos=1 保留: 是發行主題 : alex9ufo/node-red/out
Audio Out 節點	1. Microsoft Yatinf—Chinese
Function 節點	var onoff=msg.payload; if (onoff=="on") { msg.payload=true; } if (onoff=="off") { msg.payload=false; } return msg;
勤益科大 Bouuton 節點	Payload :　勤益科大
Hello Bouuton 節點	Payload :　 hello
MQTT out節點	Server :broker.hivemq.com :　1883 Qos=1 保留: 是發行主題 : alex9ufo/esp32/hello
MQTT in節點	Server :broker.hivemq.com :　1883 Qos=1 保留: 是發行主題 : alex9ufo/esp32/hello
Text 節點	Label :　訂閱主題 : Value format{{msg.payload}} Layout:　上中

Node-Red程式

2023年12月29日星期五

實驗1-2 2023-08 ESP32 + RFID + MQTT Explorer + Google App MyMQTT + Node-Red

準備工作

1) Arduino 實習1-1 程式測試MFRC522 正常工作 (硬體正常)

2) Arduino 實習1-2 程式測試MFRC522 正常工作 (硬體正常)

3) Node-Red 安裝節點 dashboard UI 的安裝

4) MQTT Client 軟體 MQTT Explorer 下載安裝 https://mqtt-explorer.com/

5) Andriod APP MyMQTT 下載安裝 https://play.google.com/store/apps/details?id=at.tripwire.mqtt.client&hl=zh_TW&gl=US

或 Snopper MQTT APP

6) MQTT相關概念

7) broker.mqtt-dashboard.com = broker.hivemq.com MQTT Server (Broker)

8) 每一個 node-red MQTT in 及 MQTT out 的節點中 alex9ufo/esp32/RFID alex9ufo/esp32/led 需修改成自己的

例如 john9012/esp32/RFID , john9012/esp32/led

包含MQTT Explorer / MyMQTT / Snooper MQTT 中的訂閱發行主題都需要隨之更改 john9012/esp32/RFID , john9012/esp32/led

9) 需修改wifi 密碼 MQTT Broker topic Mqtt username , password

// WiFi

const char *ssid = "alex9ufo"; // Enter your Wi-Fi name

const char *password = "alex9981";  // Enter Wi-Fi password

// MQTT Broker

const char *mqtt_broker = "broker.mqtt-dashboard.com";

const char *topic1 = "alex9ufo/esp32/led";

const char *topic2 = "alex9ufo/esp32/RFID";

const char *mqtt_username = "alex9ufo";

const char *mqtt_password = "public";

const int mqtt_port = 1883;

實驗1-2 2023-08 ESP32 + RFID + MQTT Explorer + Google App MyMQTT + Node-Red

// MQTT Broker

const char *mqtt_broker = "broker.mqtt-dashboard.com";

const char *topic1 = "alex9ufo/esp32/led";

const char *topic2 = "alex9ufo/esp32/RFID";

或

Node-Red 程式

Node-RED基礎教學

今日講解Node-RED分成兩部分

一、安裝/刪除節點

二、匯入/匯出流程

一、安裝/刪除節點

1.點選右上角的三條橫線下拉選單→「節點管理」(圖1)

2.進入後可以看到已安裝的節點，在此可以禁用或刪除

3.被刪除的節點可以再次重新安裝

4.切換至安裝頁面，上方可輸入關鍵字搜尋

(安裝sqlite)

5.選取要得節點後按下右下角安裝即會進入安裝狀態

特別提醒：安裝和刪除時請確保Node-RED正確運作，切勿關閉或斷線，會造成系統異常而無法開啟和編輯

6.新增的節點將會出現於主畫面左側的節點區

二、匯入/匯出流程

1.點選右上角的三條橫線下拉選單→「匯入、匯出」

(1)匯入：將外部檔案放入自己的Node-RED中編輯使用

(2)匯出：將自己的專案轉成jason或文字碼供他人使用

2.點選「匯入」→「匯入所選檔案」→「匯入」

特別提醒：若匯入他人資料時本身沒有資料中的結點，Node-RED會無法辨識而跳出警示，需要針對該節點去新增安裝後重新匯入一次，始得正常使用

3.點選「匯出」→「現在的節點」→「下載」

(1)按下下載後會匯出jason檔案，需要時再使用匯入功能即可取回資料至Node-RED中

(2)下載旁的「匯出到剪貼簿」會生成文字碼(記事本可開啟)，兩種都可以作為匯出的方式

(3)建議當專案完成後即可匯出檔案作為備份以免遺失

Node-Red 操作結果

1)　先觀察 Arduino 是否連上Wifi

2) 輸入 127.0.0.1:1880/ui 進入 Node-Red UI人機介面

3) LED ON

4) LED OFF

5) RFID 感應顯示 UID

Arduino ESP32 程式

//Wifi  + MQTT 
#include <WiFi.h>
#include <PubSubClient.h>

//RFID　SPI + RC522
#include <SPI.h>
#include <MFRC522.h>

// GPIO 2 D1
#define LED 2

/* Wiring RFID RC522 module
=============================================================================
GND     = GND   3.3V    = 3.3V
The following table shows the typical pin layout used:
 *             MFRC522      ESP32     Arduino       Arduino   Arduino    Arduino          Arduino
 *             Reader/PCD             Uno/101       Mega      Nano v3    Leonardo/Micro   Pro Micro
 * Signal      Pin          Pin       Pin           Pin       Pin        Pin              Pin
 * -----------------------------------------------------------------------------------------
 * RST/Reset   RST          GPIO27    9             5         D9         RESET/ICSP-5     RST
 * SPI SS      SDA(SS)      GPIO5     10            53        D10        10               10
 * SPI MOSI    MOSI         GPIO23    11 / ICSP-4   51        D11        ICSP-4           16
 * SPI MISO    MISO         GPIO19    12 / ICSP-1   50        D12        ICSP-1           14
 * SPI SCK     SCK          GPIO18    13 / ICSP-3   52        D13        ICSP-3           15
 *
[1] (1, 2) Configurable, typically defined as RST_PIN in sketch/program.
[2] (1, 2) Configurable, typically defined as SS_PIN in sketch/program.
[3] The SDA pin might be labeled SS on some/older MFRC522 boards
=============================================================================
*/
// SPI　
#define SS_PIN  5  // ESP32 pin GIOP5 
#define RST_PIN 27 // ESP32 pin GIOP27 


// WiFi
const char *ssid = "alex9ufo"; // Enter your Wi-Fi name
const char *password = "alex9981";  // Enter Wi-Fi password

// MQTT Broker
const char *mqtt_broker = "broker.mqtt-dashboard.com";
const char *topic1 = "alex9ufo/esp32/led";
const char *topic2 = "alex9ufo/esp32/RFID";

const char *mqtt_username = "alex9ufo";
const char *mqtt_password = "public";
const int mqtt_port = 1883;

bool ledState = false;

WiFiClient espClient;
PubSubClient client(espClient);
MFRC522 rfid(SS_PIN, RST_PIN); // Create MFRC522 instance

long lastMsg = 0;
char msg[50];
String json = "";    
char jsonChar1[50];  //client.publish("alex9ufo/Esp32/RFID"

//宣告任務Task1
TaskHandle_t Task1;

// Wifi reconnect
unsigned long previousMillis = 0;
unsigned long interval = 30000;
//===========================================================
//任務1副程式Task1_senddata
void Task1_senddata(void * pvParameters ) {
  //無窮迴圈
  for (;;) {
    //偵測上傳旗標是否為true
    Serial.println("Reading RFID tag");
    if (rfid.PICC_IsNewCardPresent()) { // new tag is available
      if (rfid.PICC_ReadCardSerial()) { // NUID has been readed
        MFRC522::PICC_Type piccType = rfid.PICC_GetType(rfid.uid.sak);
        Serial.print("RFID/NFC Tag Type: ");
        Serial.println(rfid.PICC_GetTypeName(piccType));
        String rfidno="";
        // print UID in Serial Monitor in the hex format
        Serial.print("UID:");
        for (int i = 0; i < rfid.uid.size; i++) {
          Serial.print(rfid.uid.uidByte[i] < 0x10 ? " 0" : " ");
          Serial.print(rfid.uid.uidByte[i], HEX);
        }
        Serial.println();

        String json = printHex(rfid.uid.uidByte, rfid.uid.size);
        json.trim();
        json.toUpperCase();
        // Convert JSON string to character array
        json.toCharArray(jsonChar1, json.length()+1);
    
        if  (client.connected()) {
            Serial.print("Publish message: ");
            Serial.println(json);
            // Publish JSON character array to MQTT topic
            client.publish(topic2,jsonChar1);
             
          rfid.PICC_HaltA(); // halt PICC
          rfid.PCD_StopCrypto1(); // stop encryption on PCD
        }  
        else 
        {
          Serial.print("MQTT not connected ");
        }
      
      }
    } 


    else   
    {
      // PN532 probably timed out waiting for a card
      Serial.println("Timed out waiting for a card");
    }      
    //Task1休息，delay(X)不可省略
    delay(1000);
  }
}

//===========================================================
String printHex(byte *buffer, byte bufferSize) {
      String id = "";
      for (byte i = 0; i < bufferSize; i++) {
        id += buffer[i] < 0x10 ? "0" : "";
        id += String(buffer[i], HEX);
        id +=" ";
      }
      return id;
    }

//===========================================================
void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // Attempt to connect

    if (client.connect("esp32-client-")) {
      Serial.println("connected");
      // Subscribe
      client.subscribe("alex9ufo/esp32/led");
      client.subscribe("alex9ufo/esp32/RFID");      
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
      if (WiFi.status() != WL_CONNECTED)  {
        Serial.println("Reconnecting to WiFi...");
        WiFi.disconnect();
        WiFi.reconnect();
      }
    }
  }
}
//===========================================================
void callback(char *topic, byte *payload, unsigned int length) {
    Serial.print("Message arrived in topic: ");
    Serial.println(topic);
    Serial.print("Message: ");
    String message;
    for (int i = 0; i < length; i++) {
        message += (char) payload[i];  // Convert *byte to string
    }
    Serial.print(message);
    if (message == "on" && !ledState) {
        digitalWrite(LED, HIGH);  // Turn on the LED
        ledState = true;
    }
    if (message == "off" && ledState) {
        digitalWrite(LED, LOW); // Turn off the LED
        ledState = false;
    }
    Serial.println();
    Serial.println("-----------------------");
}
//===========================================================

void setup() {
    // Set software serial baud to 115200;
    Serial.begin(115200);
    delay(1000); // Delay for stability
    //======================================================
    // Connecting to a WiFi network
    WiFi.begin(ssid, password);
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.println("Connecting to WiFi...");
    }
    Serial.println("Connected to the WiFi network");

    // Setting LED pin as output
    pinMode(LED, OUTPUT);
    digitalWrite(LED, LOW);  // Turn off the LED initially
    //======================================================
    SPI.begin();           // Init SPI bus
    rfid.PCD_Init();    // Init MFRC522

    Serial.println(F("Ready!"));
    Serial.println(F("======================================================")); 
    Serial.println("Tap an RFID/NFC tag on the RFID-RC522 reader");


    // Connecting to an MQTT broker
    client.setServer(mqtt_broker, mqtt_port);
    client.setCallback(callback);
    while (!client.connected()) {
        String client_id = "esp32-client-";
        client_id += String(WiFi.macAddress());
        Serial.printf("The client %s connects to the public MQTT broker\n", client_id.c_str());
        if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {
            Serial.println("Public HiveMQ MQTT broker (broker.mqtt-dashboard.com) connected");
        } else {
            Serial.print("Failed with state ");
            Serial.print(client.state());
            delay(2000);
        }
    }

    // Publish and subscribe
    client.subscribe(topic1);
    //在核心0啟動任務1
    xTaskCreatePinnedToCore(
    Task1_senddata, /*任務實際對應的Function*/
      "Task1",        /*任務名稱*/
      10000,          /*堆疊空間*/
      NULL,           /*無輸入值*/
      0,              /*優先序0*/
      &Task1,         /*對應的任務變數位址*/
      0);             /*指定在核心0執行 */

}
//===========================================================
void loop() {
  if (!client.connected()) {
      reconnect();
      Serial.print(" client not connected  reconnect ");
      delay(200);
  }
  client.loop();
  // Process LED message

  unsigned long currentMillis = millis();
  // if WiFi is down, try reconnecting
  if ((WiFi.status() != WL_CONNECTED) && (currentMillis - previousMillis >=interval)) {
    Serial.print(millis());
    Serial.println("Reconnecting to WiFi...");
    WiFi.disconnect();
    WiFi.reconnect();
    previousMillis = currentMillis;
    client.setCallback(callback);
  }

}
//===========================================================

訂閱：文章 (Atom)

2023年12月31日 星期日

Node-Red MQTT基本實驗

2023年12月29日 星期五

實驗1-2 2023-08 ESP32 + RFID + MQTT Explorer + Google App MyMQTT + Node-Red

Messaging API作為替代方案

2023年12月31日星期日

2023年12月29日星期五