온도 센서값을 읽어서 MQTT 를 이용해 Broker 에 보내는 firmware 예제 프로그램

[예제 소스]

#include <ESP8266WiFi.h> #include <PubSubClient.h> #include <DHT.h> // WiFi 설정 const char* ssid = "YOUR_WIFI_SSID"; const char* password = "YOUR_WIFI_PASSWORD"; // MQTT Broker 설정 const char* mqtt_server = "YOUR_MQTT_BROKER_IP"; const int mqtt_port = 1883; const char* mqtt_user = "YOUR_MQTT_USERNAME"; const char* mqtt_password = "YOUR_MQTT_PASSWORD"; const char* mqtt_topic = "sensors/temperature"; // DHT11 센서 설정 #define DHTPIN 2      // DHT11 데이터 핀 #define DHTTYPE DHT11 DHT dht(DHTPIN, DHTTYPE); WiFiClient espClient; PubSubClient client(espClient); long lastMsg = 0; char msg[50]; void setup_wifi() {   delay(10);   Serial.println();   Serial.print("Connecting to ");   Serial.println(ssid);   WiFi.begin(ssid, password);   while (WiFi.status() != WL_CONNECTED) {     delay(500);     Serial.print(".");   }   Serial.println("");   Serial.println("WiFi connected");   Serial.println("IP address: ");   Serial.println(WiFi.localIP()); } void reconnect() {   while (!client.connected()) {     Serial.print("Attempting MQTT connection...");     String clientId = "ESP8266Client-";     clientId += String(random(0xffff), HEX);          if (client.connect(clientId.c_str(), mqtt_user, mqtt_password)) {       Serial.println("connected");     } else {       Serial.print("failed, rc=");       Serial.print(client.state());       Serial.println(" try again in 5 seconds");       delay(5000);     }   } } void setup() {   Serial.begin(115200);   setup_wifi();   client.setServer(mqtt_server, mqtt_port);   dht.begin(); } void loop() {   if (!client.connected()) {     reconnect();   }   client.loop();   long now = millis();   if (now - lastMsg > 2000) {  // 2초마다 센서 읽기     lastMsg = now;          float temperature = dht.readTemperature();     float humidity = dht.readHumidity();          if (isnan(temperature) || isnan(humidity)) {       Serial.println("Failed to read from DHT sensor!");       return;     }     // JSON 형식으로 데이터 포맷팅     snprintf(msg, 50, "{\"temp\":%.1f,\"humid\":%.1f}", temperature, humidity);     Serial.print("Publishing message: ");     Serial.println(msg);          client.publish(mqtt_topic, msg);   } }

이 예제는:

WiFi 연결
MQTT 브로커 연결
DHT11 센서에서 온도/습도 읽기
JSON 형식으로 데이터 포맷팅
MQTT 토픽으로 발행

을 수행합니다.
사용하기 전에 다음 라이브러리 설치가 필요합니다:

PubSubClient
DHT sensor library
ArduinoJson (옵션)

또한 다음 정보를 수정해야 합니다:

WiFi SSID와 비밀번호
MQTT 브로커 정보
핀 번호 (필요시)

2초마다 데이터를 전송하도록 설정되어 있으며, 필요에 따라 주기를 조정할 수 있습니다.