alex9ufo 聰明人求知心切: ESP32 BME680 MQTT LINE Webserver Node-Red

ESP32 BME680 MQTT LINE Webserver Node-Red

BME680 多功能環境感測器博世 Bosch Sensortec MEMS 多功能 VOC（揮發性有機物）、溫度、濕度、氣壓

BME680 多功能環境感測器是一款四合一 MEMS 環境感測器，可測量VOC（揮發性有機物）、溫度、濕度、氣壓這四個參數，非常適用於監測空氣品質。由於採用了 MEMS 技術，該感測器體積小、功耗低，因此也適用於低功耗場合，如可穿戴等。

#include <Wire.h>

extern "C" {

#include "freertos/FreeRTOS.h"

#include "freertos/timers.h"

}

#include <AsyncMqttClient.h>

#include <SPI.h>

#include <Adafruit_Sensor.h>

#include "Adafruit_BME680.h"

#include "ESPAsyncWebServer.h"

// 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";

//Uncomment if using SPI

/*#define BME_SCK 18

#define BME_MISO 19

#define BME_MOSI 23

#define BME_CS 5*/

// 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/bme680/temperature"

#define MQTT_PUB_HUMI "alex9ufo/esp32/bme680/humidity"

#define MQTT_PUB_GASR "alex9ufo/esp32/bme680/gasResistance"

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

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

AsyncMqttClient mqttClient;

TimerHandle_t mqttReconnectTimer;

TimerHandle_t wifiReconnectTimer;

Adafruit_BME680 bme; // I2C

//Adafruit_BME680 bme(BME_CS); // hardware SPI

//Adafruit_BME680 bme(BME_CS, BME_MOSI, BME_MISO, BME_SCK);

#define SEALEVELPRESSURE_HPA (1013.25)

float temperature;

float humidity;

float pressure;

float gasResistance;

float altitude;

AsyncWebServer server(80);

AsyncEventSource events("/events");

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

unsigned long lastTime = 0;

unsigned long timerDelay = 10*60000; // send readings timer

void connectToWifi() {

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

WiFi.begin(ssid,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 onMqttPublish(uint16_t packetId) {

Serial.print("Publish acknowledged.");

Serial.print(" packetId: ");

Serial.println(packetId);

}

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

void getBME680Readings(){

// Tell BME680 to begin measurement.

unsigned long endTime = bme.beginReading();

if (endTime == 0) {

Serial.println(F("Failed to begin reading :("));

return;

}

if (!bme.endReading()) {

Serial.println(F("Failed to complete reading :("));

return;

}

temperature = bme.temperature;

pressure = bme.pressure / 100.0;

humidity = bme.humidity;

gasResistance = bme.gas_resistance / 1000.0;

altitude = bme.readAltitude(SEALEVELPRESSURE_HPA);

}

String processor(const String& var){

getBME680Readings();

//Serial.println(var);

if(var == "TEMPERATURE"){

return String(temperature);

}

else if(var == "HUMIDITY"){

return String(humidity);

}

else if(var == "PRESSURE"){

return String(pressure);

}

else if(var == "GAS"){

return String(gasResistance);

}

else if(var == "ALT"){

return String(altitude);

}

const char index_html[] PROGMEM = R"rawliteral(

<!DOCTYPE HTML><html>

<head>

<title>BME680 Web Server</title>

<style>

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

p { font-size: 1.2rem;}

body { margin: 0;}

.topnav { overflow: hidden; background-color: #4B1D3F; color: white; font-size: 1.7rem; }

.content { padding: 20px; }

.card { background-color: white; box-shadow: 2px 2px 12px 1px rgba(140,140,140,.5); }

.cards { max-width: 700px; margin: 0 auto; display: grid; grid-gap: 2rem; grid-template-columns: repeat(auto-fit, minmax(300px, 1fr)); }

.reading { font-size: 2.8rem; }

.card.temperature { color: #0e7c7b; }

.card.humidity { color: #17bebb; }

.card.pressure { color: #3fca6b; }

.card.gas { color: #d62246; }

</style>

</head>

<body>

<h3>BME680 WEB SERVER</h3>

</div>

<h4><i class="fas fa-thermometer-half"></i> TEMPERATURE</h4><p><span class="reading"><span id="temp">%TEMPERATURE%</span> °C</span></p>

</div>

<h4><i class="fas fa-tint"></i> HUMIDITY</h4><p><span class="reading"><span id="hum">%HUMIDITY%</span> &percnt;</span></p>

</div>

<h4><i class="fas fa-angle-double-down"></i> PRESSURE</h4><p><span class="reading"><span id="pres">%PRESSURE%</span> hPa</span></p>

</div>

</div>

<h4><i class="fas fa-map-marker-alt"></i> ALTITUDE</h4><p><span class="reading"><span id="alt">%ALT%</span> Meter </span></p>

</div>

if (!!window.EventSource) {

var source = new EventSource('/events');

source.addEventListener('open', function(e) {

console.log("Events Connected");

}, false);

source.addEventListener('error', function(e) {

if (e.target.readyState != EventSource.OPEN) {

console.log("Events Disconnected");

}

}, false);

source.addEventListener('message', function(e) {

console.log("message", e.data);

}, false);

source.addEventListener('temperature', function(e) {

console.log("temperature", e.data);

document.getElementById("temp").innerHTML = e.data;

}, false);

source.addEventListener('humidity', function(e) {

console.log("humidity", e.data);

document.getElementById("hum").innerHTML = e.data;

}, false);

source.addEventListener('pressure', function(e) {

console.log("pressure", e.data);

document.getElementById("pres").innerHTML = e.data;

}, false);

source.addEventListener('gas', function(e) {

console.log("gas", e.data);

document.getElementById("gas").innerHTML = e.data;

}, false);

}

</script>

</body>

</html>)rawliteral";

void setup() {

Serial.begin(115200);

// Set the device as a Station and Soft Access Point simultaneously

WiFi.mode(WIFI_AP_STA);

// Set device as a Wi-Fi Station

WiFi.begin(ssid, password);

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

delay(1000);

Serial.println("Setting as a Wi-Fi Station..");

}

Serial.print("Station IP Address: ");

Serial.println(WiFi.localIP());

Serial.println();

// Init BME680 sensor

if (!bme.begin(0x76)) {

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

while (1);

}

Serial.println(F("BME680 sensor is working!"));

// Set up oversampling and filter initialization

bme.setTemperatureOversampling(BME680_OS_8X);

bme.setHumidityOversampling(BME680_OS_2X);

bme.setPressureOversampling(BME680_OS_4X);

bme.setIIRFilterSize(BME680_FILTER_SIZE_3);

bme.setGasHeater(320, 150); // 320*C for 150 ms

// Handle Web Server

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

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

});

// Handle Web Server Events

events.onConnect([](AsyncEventSourceClient *client){

if(client->lastId()){

Serial.printf("Client reconnected! Last message ID that it got is: %u\n", client->lastId());

}

// send event with message "hello!", id current millis

// and set reconnect delay to 1 second

client->send("hello!", NULL, millis(), 10000);

});

server.addHandler(&events);

server.begin();

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

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();

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

}

void loop() {

if ((millis() - lastTime) > timerDelay) {

getBME680Readings();

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

//Serial.printf("Humidity = %.2f % \n", humidity);

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

//Serial.printf("Gas Resistance = %.2f KOhm \n", gasResistance);

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

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

Serial.print("Humidity 濕度= ");

Serial.printf("Humidity = %.2f % \n", humidity);

Serial.print("Gas Resistance 氣壓阻值= ");

Serial.printf("Gas Resistance = %.2f KOhm \n", gasResistance);

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

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

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

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

Serial.println();

// Send Events to the Web Server with the Sensor Readings

events.send("ping",NULL,millis());

events.send(String(temperature).c_str(),"temperature",millis());

events.send(String(humidity).c_str(),"humidity",millis());

events.send(String(pressure).c_str(),"pressure",millis());

events.send(String(gasResistance).c_str(),"gas",millis());

//mqtt process

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

// Temperature MQTT Topics

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

//#define MQTT_PUB_HUMI "alex9ufo/esp32/bme680/humidity"

//#define MQTT_PUB_GASR "alex9ufo/esp32/bme680/gasResistance"

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

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

// Publish an MQTT message on topic alex9ufo/esp32/bmp680/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 alex9ufo/esp32/bmp680/humidity

uint16_t packetIdPub2 = mqttClient.publish(MQTT_PUB_HUMI, 1, true, String(humidity).c_str());

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

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

// Publish an MQTT message on topic alex9ufo/esp32/bmp680/gasResistance

uint16_t packetIdPub3 = mqttClient.publish(MQTT_PUB_GASR, 1, true, String(gasResistance).c_str());

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

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

// Publish an MQTT message on topic alex9ufo/esp32/bmp680/pressure

uint16_t packetIdPub4 = 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, packetIdPub4);

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

// Publish an MQTT message on topic alex9ufo/esp32/bmp680/pressure

uint16_t packetIdPub5 = 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, packetIdPub5);

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

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

lastTime = millis();

}

#include <Wire.h>

#include <SPI.h>

#include <Adafruit_Sensor.h>

#include "Adafruit_BME680.h"

#define SEALEVELPRESSURE_HPA (1013.25)

Adafruit_BME680 bme; // I2C

void setup() {

Serial.begin(115200);

while (!Serial);

Serial.println(F("BME680 test"));

if (!bme.begin(0x76))

{

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

while (1);

}

// Set up oversampling and filter initialization

bme.setTemperatureOversampling(BME680_OS_8X);

bme.setHumidityOversampling(BME680_OS_2X);

bme.setPressureOversampling(BME680_OS_4X);

bme.setIIRFilterSize(BME680_FILTER_SIZE_3);

bme.setGasHeater(320, 150); // 320*C for 150 ms

}

void loop()

{

if (! bme.performReading())

{

Serial.println("Failed to perform reading :(");

return;

}

Serial.print("Temperature = ");

Serial.print(bme.temperature);

Serial.println(" *C");

Serial.print("Pressure = ");

Serial.print(bme.pressure / 100.0);

Serial.println(" hPa");

Serial.print("Humidity = ");

Serial.print(bme.humidity);

Serial.println(" %");

Serial.print("Gas = ");

Serial.print(bme.gas_resistance / 1000.0);

Serial.println(" KOhms");

Serial.print("Approx. Altitude = ");

Serial.print(bme.readAltitude(SEALEVELPRESSURE_HPA));

Serial.println(" m");

Serial.println();

delay(3000);

}

alex9ufo 聰明人求知心切

2021年12月9日星期四

ESP32 BME680 MQTT LINE Webserver Node-Red

BME680 多功能環境感測器博世 Bosch Sensortec MEMS 多功能 VOC（揮發性有機物）、溫度、濕度、氣壓

沒有留言:

張貼留言

Messaging API作為替代方案

2021年12月9日 星期四

ESP32 BME680 MQTT LINE Webserver Node-Red

BME680 多功能環境感測器 博世 Bosch Sensortec MEMS 多功能 VOC（揮發性有機物）、溫度、濕度、氣壓

沒有留言:

張貼留言

Messaging API作為替代方案

2021年12月9日星期四

BME680 多功能環境感測器博世 Bosch Sensortec MEMS 多功能 VOC（揮發性有機物）、溫度、濕度、氣壓