alex9ufo 聰明人求知心切: LDR Sensor With MQTT Broker , Node-Red

LDR Sensor With MQTT Broker , Node-Red

參考來源

http://yhhuang1966.blogspot.com/2015/10/arduino.html

https://youyouyou.pixnet.net/blog/post/120260848-%E7%AC%AC%E5%85%AD%E7%AF%87-esp32%E9%A1%9E%E6%AF%94%E8%AE%80%E5%8F%96%28analogread%29%EF%BC%9A%E5%B0%8F%E5%A4%9C%E7%87%88

http://www.esp32learning.com/code/esp32-and-ldr-example.php

https://iotbyhvm.ooo/interface-ldr-module-with-nodemcu/

Arduino程式

#include <WiFi.h>

#include <PubSubClient.h>

#include <SPI.h>

#include <AutoConnect.h>

#include <WebServer.h>

WebServer server;

AutoConnect Portal(server);

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

#define BUILTIN_LED 2

#define CDS 34

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

/* Photocell simple testing sketch.

Connect one end of the photocell to 5V, the other end to Analog 0.

Then connect one end of a 10K resistor from Analog 0 to ground

Connect LED from pin 11 through a resistor to ground

For more information see http://learn.adafruit.com/photocells */

// Update these with values suitable for your network.

#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

//Variables

long lastMsg = 0;

char jsonChar1[100];

int photocellReading; // the analog reading from the sensor divider

int LEDbrightness; //

int LightValue1;//宣告變數LightValue

float new_value;

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

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/outTopic/ldr/ldr_value", jsonChar1, MQTTpubQos, true); // true means retain

// ... and resubscribe

client.subscribe("alex9ufo/inTopic/led/led_event", MQTTsubQos);

}

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

void mqttDisconnectedCb() {

Serial.println("disconnected");

}

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

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

you can convert payload to a C string appending a null terminator to it;

this is possible when the message (including protocol overhead) doesn't

exceeds the MQTT_MAX_PACKET_SIZE defined in the library header.

you can consider safe to do so when the length of topic plus the length of

message doesn't exceeds 115 characters

char* message = (char *) payload;

message[length] = 0;

Serial.print("Message arrived [");

Serial.print(topic);

Serial.print("] ");

Serial.println(message);

String s = message;

s.trim();

// Switch on the LED if an 1 was received as first character

if (s == "OFF") {

digitalWrite(BUILTIN_LED, LOW); // Turn the LED on (Note that LOW is the voltage level

// but actually the LED is on; this is because

Serial.println("Received OFF , Send LOW TO BuildIn_LED");

} // if (s == "OFF")

if (s == "ON") {

digitalWrite(BUILTIN_LED, HIGH); // Turn the LED off (Note that HIGH is the voltage level

// but actually the LED is on; this is because

Serial.println("Received ON , Send HIGH TO BuildIn_LED");

} //if (s == "ON")

}

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

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(void) {

Serial.begin(115200);

// We'll send debugging information via the Serial monitor

pinMode(CDS, INPUT);//選告GPIO 13作為輸入（光敏電阻）

pinMode(BUILTIN_LED, OUTPUT);

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

}

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

Serial.println(F("Ready!"));

Serial.println(F("Control Build LED ON,OFF"));

//輸出值採前次佔 3 成, 本次佔 7 成方式處理, 這樣數值變化經過積分器濾波後變化就不會那麼劇烈了.

LightValue1=analogRead(CDS);

new_value=0.3*LightValue1 + 0.7*analogRead(CDS);

photocellReading= floor(new_value);

Serial.println(photocellReading);

}

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

void loop(void) {

process_mqtt();

long now = millis();

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

lastMsg = now;

//輸出值採前次佔 3 成, 本次佔 7 成方式處理, 這樣數值變化經過積分器濾波後變化就不會那麼劇烈了.

LightValue1=analogRead(CDS);

new_value=0.3*LightValue1 + 0.7*analogRead(CDS);

photocellReading= floor(new_value);

Serial.print(photocellReading);

/*用光敏電阻感測現場亮度數值，0代表亮度最大，4095代表亮度最小，並依據亮度明暗開啟不同數量的LED作為補光。

環境很亮時（0~500）燈號全關

普通亮時（500~1000）開一顆燈

普通暗時（1000～2000）開兩顆燈

非常暗時（2000以上）燈號全開

這些500、1000、2000的門檻值，請使用者依據現場環境進行調整。 */

//analogWrite(photocellPin, LEDbrightness);

// We'll have a few threshholds, qualitatively determined

if (photocellReading < 500) {

Serial.println(" - ery bright"); //環境很亮時（0~500）燈號全關

} else if (photocellReading>= 500 && photocellReading < 1000) { //普通亮時（500~1000）開一顆燈

Serial.println(" - Bright");

} else if (photocellReading>=1000 && photocellReading < 2000) { //普通暗時（1000～2000）開兩顆燈

Serial.println(" - Light");

} else {

Serial.println(" - Dark"); // 非常暗時（2000以上）燈號全開Dark

}

// Convert data to JSON string

String json1 =

"{\"data\":{"

"\"photocellReading\": \"" + String(photocellReading) + "\"}"

"}";

// Convert JSON string to character array

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

if (client.connected()) {

Serial.print("Publish message: ");

Serial.println(json1);

// Publish JSON character array to MQTT topic

client.publish("alex9ufo/outTopic/ldr/ldr_value",jsonChar1);

} //if (client.connected()

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

Portal.handleClient();

}//loop

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

Node-Red程式

alex9ufo 聰明人求知心切

2020年12月19日星期六

LDR Sensor With MQTT Broker , Node-Red

沒有留言:

張貼留言

Messaging API作為替代方案

2020年12月19日 星期六

LDR Sensor With MQTT Broker , Node-Red

沒有留言:

張貼留言

Messaging API作為替代方案

2020年12月19日星期六