alex9ufo 聰明人求知心切: ESP32 MQTT – Publish BMP280 Sensor Readings & send message to Line Bot

ESP32 MQTT – Publish BMP280 Sensor Readings & send message to Line Bot

源自於https://randomnerdtutorials.com/esp32-mqtt-publish-bme280-arduino/

安裝PubSubClient Library

Installing the PubSubClient Library

The PubSubClient library provides a client for doing simple publish/subscribe messaging with a server that supports MQTT (basically allows your ESP32 to talk with Node-RED).

Click here to download the PubSubClient library. You should have a .zip folder in your Downloads folder
Unzip the .zip folder and you should get pubsubclient-master folder
Rename your folder from ~~pubsubclient-master~~ to pubsubclient
Move the pubsubclient folder to your Arduino IDE installation libraries folder
Then, re-open your Arduino IDE

The library comes with a number of example sketches. See File >Examples > PubSubClient within the Arduino IDE software.

Important: PubSubClient is not fully compatible with the ESP32, but the example provided in this tutorial is working very reliably during our tests.

Arduino程式

#include <WiFi.h>

extern "C" {

#include "freertos/FreeRTOS.h"

#include "freertos/timers.h"

}

#include <AsyncMqttClient.h>

#include <Wire.h>

#include <SPI.h>

#include <Adafruit_Sensor.h>

#include "Adafruit_BMP280.h"

//#define WIFI_SSID "REPLACE_WITH_YOUR_SSID"

//#define WIFI_PASSWORD "REPLACE_WITH_YOUR_PASSWORD"

//#define WIFI_SSID "PTS-2F"

//#define WIFI_PASSWORD "PTS6662594"

#define WIFI_SSID "TOTOLINK_A3002MU"

#define WIFI_PASSWORD "24063173"

// Raspberry Pi Mosquitto MQTT Broker

#define MQTT_HOST "broker.mqtt-dashboard.com"

// For a cloud MQTT broker, type the domain name

//#define MQTT_HOST "example.com"

#define MQTT_PORT 1883

// Temperature MQTT Topics

#define MQTT_PUB_TEMP "alex9ufo/esp32/bmp280/temperature"

#define MQTT_PUB_ALTI "alex9ufo/esp32/bmp280/altitude"

#define MQTT_PUB_PRES "alex9ufo/esp32/bmp280/pressure"

#define BMP280_I2C_ADDRESS 0x76

Adafruit_BMP280 bmp280; // I2C

// Variables to hold sensor readings

float temperature;

float altitude;

float pressure;

AsyncMqttClient mqttClient;

TimerHandle_t mqttReconnectTimer;

TimerHandle_t wifiReconnectTimer;

unsigned long previousMillis = 0; // Stores last time temperature was published

const long interval = 10000; // Interval at which to publish sensor readings

void getBMP280Readings(){

temperature = bmp280.readTemperature(); // get temperature

pressure = bmp280.readPressure()/100.0; // get pressure

altitude = bmp280.readAltitude(1013.25); // get altitude (this should be adjusted to your local forecast)

}

void connectToWifi() {

Serial.println("Connecting to Wi-Fi...");

WiFi.begin(WIFI_SSID, WIFI_PASSWORD);

}

void connectToMqtt() {

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

mqttClient.connect();

}

void WiFiEvent(WiFiEvent_t event) {

Serial.printf("[WiFi-event] event: %d\n", event);

switch(event) {

case SYSTEM_EVENT_STA_GOT_IP:

Serial.println("WiFi connected");

Serial.println("IP address: ");

Serial.println(WiFi.localIP());

connectToMqtt();

break;

case SYSTEM_EVENT_STA_DISCONNECTED:

Serial.println("WiFi lost connection");

xTimerStop(mqttReconnectTimer, 0); // ensure we don't reconnect to MQTT while reconnecting to Wi-Fi

xTimerStart(wifiReconnectTimer, 0);

break;

}

void onMqttConnect(bool sessionPresent) {

Serial.println("Connected to MQTT.");

Serial.print("Session present: ");

Serial.println(sessionPresent);

}

void onMqttDisconnect(AsyncMqttClientDisconnectReason reason) {

Serial.println("Disconnected from MQTT.");

if (WiFi.isConnected()) {

xTimerStart(mqttReconnectTimer, 0);

}

/*void onMqttSubscribe(uint16_t packetId, uint8_t qos) {

Serial.println("Subscribe acknowledged.");

Serial.print(" packetId: ");

Serial.println(packetId);

Serial.print(" qos: ");

Serial.println(qos);

}

void onMqttUnsubscribe(uint16_t packetId) {

Serial.println("Unsubscribe acknowledged.");

Serial.print(" packetId: ");

Serial.println(packetId);

}*/

void onMqttPublish(uint16_t packetId) {

Serial.print("Publish acknowledged.");

Serial.print(" packetId: ");

Serial.println(packetId);

}

void setup() {

Serial.begin(115200);

Serial.println();

delay(3000);

if (!bmp280.begin(BMP280_I2C_ADDRESS))

{

Serial.println(F("Could not find a valid BMP280 sensor, check wiring!"));

while (1);

}

mqttReconnectTimer = xTimerCreate("mqttTimer", pdMS_TO_TICKS(2000), pdFALSE, (void*)0, reinterpret_cast<TimerCallbackFunction_t>(connectToMqtt));

wifiReconnectTimer = xTimerCreate("wifiTimer", pdMS_TO_TICKS(2000), pdFALSE, (void*)0, reinterpret_cast<TimerCallbackFunction_t>(connectToWifi));

WiFi.onEvent(WiFiEvent);

mqttClient.onConnect(onMqttConnect);

mqttClient.onDisconnect(onMqttDisconnect);

//mqttClient.onSubscribe(onMqttSubscribe);

//mqttClient.onUnsubscribe(onMqttUnsubscribe);

mqttClient.onPublish(onMqttPublish);

mqttClient.setServer(MQTT_HOST, MQTT_PORT);

// If your broker requires authentication (username and password), set them below

//mqttClient.setCredentials("REPlACE_WITH_YOUR_USER", "REPLACE_WITH_YOUR_PASSWORD");

connectToWifi();

}

void loop() {

unsigned long currentMillis = millis();

// Every X number of seconds (interval = 10 seconds)

// it publishes a new MQTT message

if (currentMillis - previousMillis >= interval) {

// Save the last time a new reading was published

previousMillis = currentMillis;

getBMP280Readings();

Serial.println();

Serial.print("Temperature CELSIUS 攝氏溫度= ");

Serial.printf("Temperature = %.2f ºC \n", temperature);

Serial.print("Approx Altitude 大概海拔高度= ");

Serial.printf("Altitude = %.2f % \n", altitude);

Serial.print("Pressure 大氣壓力百帕(hPa)= ");

Serial.printf("Pressure = %.2f hPa \n", pressure);

// Publish an MQTT message on topic esp/bme680/temperature

uint16_t packetIdPub1 = mqttClient.publish(MQTT_PUB_TEMP, 1, true, String(temperature).c_str());

Serial.printf("Publishing on topic %s at QoS 1, packetId: %i", MQTT_PUB_TEMP, packetIdPub1);

Serial.printf("Message: %.2f \n", temperature);

// Publish an MQTT message on topic esp/bmp280/altitude

uint16_t packetIdPub2 = mqttClient.publish(MQTT_PUB_ALTI, 1, true, String(altitude).c_str());

Serial.printf("Publishing on topic %s at QoS 1, packetId %i: ", MQTT_PUB_ALTI, packetIdPub2);

Serial.printf("Message: %.2f \n", altitude);

// Publish an MQTT message on topic esp/bmp280/pressure

uint16_t packetIdPub3 = mqttClient.publish(MQTT_PUB_PRES, 1, true, String(pressure).c_str());

Serial.printf("Publishing on topic %s at QoS 1, packetId %i: ", MQTT_PUB_PRES, packetIdPub3);

Serial.printf("Message: %.2f \n", pressure);

}

Node-Red程式

alex9ufo 聰明人求知心切

2021年12月8日星期三

ESP32 MQTT – Publish BMP280 Sensor Readings & send message to Line Bot

安裝PubSubClient Library

Installing the PubSubClient Library

沒有留言:

張貼留言

WOKWI LED + MQTT Node-Red SQLite

2021年12月8日 星期三

ESP32 MQTT – Publish BMP280 Sensor Readings & send message to Line Bot

安裝PubSubClient Library

Installing the PubSubClient Library

沒有留言:

張貼留言

WOKWI LED + MQTT Node-Red SQLite

2021年12月8日星期三