alex9ufo 聰明人求知心切: ESP32 MQTT – Publish BME280 Sensor Readings (Arduino IDE)

ESP32 MQTT – Publish BME280 Sensor Readings (Arduino IDE)

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

Arduino程式

#include <Wire.h> // include Wire library, required for I2C devices

#include <Adafruit_Sensor.h> // include Adafruit sensor library

#include <Adafruit_BMP280.h> // include adafruit library for BMP280 sensor

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

#include <WiFi.h>

#include <PubSubClient.h>

#include <AutoConnect.h>

#include <WebServer.h>

WebServer server;

AutoConnect Portal(server);

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

// define device I2C address: 0x76 or 0x77 (0x77 is library default address)

#define BMP280_I2C_ADDRESS 0x76

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

#define MQTTid "" //id of this mqtt client

#define MQTTip "broker.mqtt-dashboard.com" //ip address or hostname of the mqtt broker

#define MQTTport 1883 //port of the mqtt broker

#define MQTTuser "alex9ufo" //username of this mqtt client

#define MQTTpsw "alex1234" //password of this mqtt client

//#define MQTTuser "your_username" //username of this mqtt client

//#define MQTTpsw "your_password" //password of this mqtt client

#define MQTTpubQos 2 //qos of publish (see README)

#define MQTTsubQos 1 //qos of subscribe

Adafruit_BMP280 bmp280;

//Variables

long lastMsg = 0;

String json = "";

char jsonChar1[50];

char jsonChar2[50];

char jsonChar3[50];

char jsonChar4[50];

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

boolean pendingDisconnect = false;

void mqttConnectedCb(); // on connect callback

void mqttDisconnectedCb(); // on disconnect callback

void mqttDataCb(char* topic, byte* payload, unsigned int length); // on new message callback

WiFiClient wclient;

PubSubClient client(MQTTip, MQTTport, mqttDataCb, wclient);

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

void rootPage() {

char content[] = "Hello, world";

server.send(200, "text/plain", content);

}

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

void mqttConnectedCb() {

Serial.println("connected");

// Once connected, publish an announcement...

client.publish("alex9ufo/BMP280/TempC", jsonChar1, MQTTpubQos, true); // true means retain

// Once connected, publish an announcement...

client.publish("alex9ufo/BMP280/TempF", jsonChar2, MQTTpubQos, true); // true means retain

// Once connected, publish an announcement...

client.publish("alex9ufo/BMP280/Pressure", jsonChar3, MQTTpubQos, true); // true means retain

// Once connected, publish an announcement...

client.publish("alex9ufo/BMP280/FAltitude", jsonChar4, MQTTpubQos, true); // true means retain

// ... and resubscribe

}

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

void mqttDisconnectedCb() {

Serial.println("disconnected");

}

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

void mqttDataCb(char* topic, byte* payload, unsigned int length) {

Serial.println("mqttDataCb --> subscribe 無訂閱");

}

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

void process_mqtt() {

if (WiFi.status() == WL_CONNECTED) {

if (client.connected()) {

client.loop();

} else {

// client id, client username, client password, last will topic, last will qos, last will retain, last will message

if (client.connect(MQTTid, MQTTuser, MQTTpsw, MQTTid "/status", 2, true, "0")) {

pendingDisconnect = false;

mqttConnectedCb();

}

} else {

if (client.connected())

client.disconnect();

}

if (!client.connected() && !pendingDisconnect) {

pendingDisconnect = true;

mqttDisconnectedCb();

}

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

void setup() {

Serial.begin(115200);

Serial.println("Configuring ESP32...");

Serial.println(F("Arduino + BMP280"));

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

Serial.println("Configuring your Mobile WiFi to esp32ap...");

Serial.println("Configuring another WiFi SSID,PWD...");

server.on("/", rootPage);

if (Portal.begin()) {

Serial.println("HTTP server:" + WiFi.localIP().toString());

}

else {

Serial.println("Connection failed");

while(true) {yield();}

}

if (!bmp280.begin(BMP280_I2C_ADDRESS))

{

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

while (1);

}

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

// main loop

void loop()

{

process_mqtt();

long now = millis();

if (now - lastMsg > 3000) { //等3秒

lastMsg = now;

// get temperature, pressure and altitude from library

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

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

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

//1013.15需修正

//該1013.25值應為數百Pa處的海平面局部壓力。

//如果要顯示高於地面的高度，則需要知道該位置，並編寫代碼以計算高度偏移。

//海平面：泛指我們所處的高度，即1大氣壓(1atm或1013.25hPa 或 1013.25mb)

//That 1013.25 value should be the local pressure at sea level in hundreds of Pa.

//If want to show altitude above ground level, you will need to know that for your location and write your code to calculate the altitude offset.

// print data on the serial monitor software

// 1: print temperature

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

Serial.print(temperature);

Serial.println(" °C");

float TempF = (temperature*1.8)+32;

Serial.print("Temperature FAHRENHEIT 華氏溫度= ");

Serial.print(TempF);

Serial.println(" °F");

// 2: print pressure

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

Serial.print(pressure/100);

Serial.println(" hPa");

// 3: print altitude

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

Serial.print(altitude_);

Serial.println(" m");

Serial.println(); // start a new line

String json1 = String(temperature);

String json2 = String(TempF);

String json3 = String(pressure/100);

String json4 = String(altitude_);

json1.toCharArray(jsonChar1, json1.length()+1);

json2.toCharArray(jsonChar2, json2.length()+1);

json3.toCharArray(jsonChar3, json3.length()+1);

json4.toCharArray(jsonChar4, json4.length()+1);

if (client.connected()) {

Serial.println("Publish message:攝氏溫度華氏溫度大氣壓力百帕海拔高度 ");

Serial.println(json1+','+json2+','+json3+','+json4);

// Publish JSON character array to MQTT topic

client.publish("alex9ufo/BMP280/TempC",jsonChar1);

client.publish("alex9ufo/BMP280/TempF",jsonChar2);

client.publish("alex9ufo/BMP280/Pressure",jsonChar3);

client.publish("alex9ufo/BMP280/FAltitude",jsonChar4);

}

}// if (now - lastMsg > 3000) 等3秒

}

// end of code.

Node-Red程式

alex9ufo 聰明人求知心切

2020年12月25日星期五

ESP32 MQTT – Publish BME280 Sensor Readings (Arduino IDE)

沒有留言:

張貼留言

Messaging API作為替代方案

2020年12月25日 星期五

ESP32 MQTT – Publish BME280 Sensor Readings (Arduino IDE)

沒有留言:

張貼留言

Messaging API作為替代方案

2020年12月25日星期五