blob: 46430f00f5015d366619a6e372bfa2576bc7e480 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
//D1 mini / ESP8266 Board: http://arduino.esp8266.com/versions/2.3.0/package_esp8266com_index.json
#include "DHT.h" //https://github.com/adafruit/DHT-sensor-library
#include <ESP8266WiFi.h>
#include <PubSubClient.h> //https://github.com/knolleary/pubsubclient
#define WIFI_SSID "SSID"
#define WIFI_PASS "PASS"
WiFiClient wifiClient;
#define MQTT_ID "ID"
#define MQTT_BROKER "BROKER"
PubSubClient mqttClient(wifiClient);
#define DHTPIN 5 //Pin D1
#define DHTTYPE DHT22 //Temp and Humidity Sensor
#define ANALOG_PIN 17
DHT dht(DHTPIN, DHTTYPE);
void setup() {
Serial.begin(115200);
Serial.println("Initialised...");
connectWifi();
delay(1000);
pinMode(ANALOG_PIN,INPUT);
dht.begin();
}
void connectWifi() {
delay(200);
Serial.print("Connecting to WiFi: ");
Serial.println(WIFI_SSID);
WiFi.mode(WIFI_STA);
WiFi.begin(WIFI_SSID, WIFI_PASS);
while(WiFi.status() != WL_CONNECTED) {
delay(150);
Serial.print(".");
}
Serial.println();
Serial.println("WiFi: Connected");
Serial.print("IP address: ");
Serial.println(WiFi.localIP());
Serial.print("MAC address: ");
Serial.println(WiFi.macAddress());
}
void connectMqtt() {
Serial.print("Connecting to MQTT: ");
Serial.println(MQTT_BROKER);
while (!mqttClient.connected()) {
mqttClient.setServer(MQTT_BROKER, 1883);
if (mqttClient.connect(MQTT_ID)) {
Serial.println("Connected");
} else {
Serial.print(".");
}
delay(150);
}
}
void loop() {
delay(1500);
float h = analogRead(ANALOG_PIN);
float t = dht.readTemperature();
char t_msg[20];
char h_msg[20];
// Check if any reads failed and exit early (to try again).
if (isnan(h) || isnan(t)) {
Serial.println("Failed to read from DHT sensor!");
return;
}
Serial.print("Moisture: ");
Serial.print(h);
Serial.print(" Temperature: ");
Serial.println(t);
if(!mqttClient.connected()) {
connectMqtt();
}
dtostrf(t, 1, 2, t_msg);
mqttClient.publish("temperature", t_msg);
dtostrf(h, 1, 2, h_msg);
mqttClient.publish("moisture", h_msg);
}
|
