<div id="readability-page-1" class="page"><div>
 <div id="SE-8a73e10a-6ab6-4d9d-825e-ca4a7d40ca7e">
 ​ESP32 아두이노 기반에서 MQTT를 사용하는 방법을 다뤄볼것이다.여기서는 AWS 서버가 아닌 별도의 MQTT 브로커와 아주 간단한 인증절차(ID/PASSWORD)만으로 연결하는 구조를 설명할 것이다.참고로 아래의 글은 우분투 서버에 MQTT 브로커를 설치하는 내용이다.<a href="https://blog.naver.com/chandong83/224225398438" data-linktype="text" data-linkdata="{&quot;id&quot;: &quot;SE-4761a8ef-f0af-4340-ab17-572eb754fe3c&quot;, &quot;link&quot;: &quot;https://blog.naver.com/chandong83/224225398438&quot;}" target="_blank">https://blog.naver.com/chandong83/224225398438</a>
 </div> 
 <div id="SE-bf575598-1480-4335-b8b5-692ef1e6280c">
 ​1. PubSubClient 라이브러리 설치아두이노에서 왼쪽 메뉴중 라이브러리 탭을 클릭 후 검색창에 pubsubclient라고 입력한다.그다음 by Nick O'Leary가 관리하는 라이브러리를 설치하자.
 </div> <div id="SE-45dadad2-35ff-4bb4-8042-b3002b1033b9">
 <a href="#" onclick="return false;" data-linktype="img" data-linkdata="{&quot;id&quot; : &quot;SE-45dadad2-35ff-4bb4-8042-b3002b1033b9&quot;, &quot;src&quot; : &quot;https://mblogthumb-phinf.pstatic.net/MjAyNjAzMjJfMTAg/MDAxNzc0MTYzNjczNjcy.ar6v_go9JxdHMf_szxexWIszuuZ-hkwgBpiKfYJKIZ8g.Yd5Ctc3sFqqyUnRmNbVsE3zBoODciN9nfRTIZDjGLtgg.PNG/SE-45dadad2-35ff-4bb4-8042-b3002b1033b9.png&quot;, &quot;originalWidth&quot; : &quot;641&quot;, &quot;originalHeight&quot; : &quot;393&quot;, &quot;linkUse&quot; : &quot;false&quot;, &quot;link&quot; : &quot;&quot;, &quot;fileSize&quot;: &quot;58245&quot; }">
 <img src="https://mblogthumb-phinf.pstatic.net/MjAyNjAzMjJfMTAg/MDAxNzc0MTYzNjczNjcy.ar6v_go9JxdHMf_szxexWIszuuZ-hkwgBpiKfYJKIZ8g.Yd5Ctc3sFqqyUnRmNbVsE3zBoODciN9nfRTIZDjGLtgg.PNG/SE-45dadad2-35ff-4bb4-8042-b3002b1033b9.png?type=w800" data-width="641" data-height="393" alt="">
 </a>
 
 </div>
 <div id="SE-7035204e-a97f-4026-878c-02134d82ac8f">
 ​2. 예제 코드아래의 예제코드는 하나의 토픽(test/topic)을 구독과 발행하는 코드이다.5초에 한번식 해당 토픽으로 발행(전송)하고 해당 토픽으로 발행된 메시지를 출력하는 간단한 코드이다.
 </div> <div id="SE-6744146a-dee6-4967-92a4-f585b06383eb">
 #include &lt;WiFi.h&gt;
#include &lt;PubSubClient.h&gt;

// wifi 정보
const char* WIFI_SSID = "..."; // 공유기 ssid
const char* WIFI_PASSWORD = "..."; // 공유기 패스워드

const char* MQTT_BROKER = "192.168.1.2"; // Ubuntu MQTT 서버 IP
const int MQTT_PORT = 1883;
const char* MQTT_USER = "user1"; // 사용자 정보, 사용 안하는 경우 ""
const char* MQTT_PASSWORD = "user1"; // 사용자 비번, 사용 안하는 경우 ""

const char* TOPIC_PUB = "test/topic"; // 발행 토픽
const char* TOPIC_SUB = "test/topic"; // 구독 토픽

WiFiClient espClient; // WiFi 선언
PubSubClient client(espClient); // MQTT 클라이언트 선언

unsigned long lastPublishMs = 0; // 발행 주기를 위한 변수

/*
 와이파이 연결 함수
*/
void connectWiFi() {
 Serial.print("WiFi connecting");

 WiFi.mode(WIFI_STA);
 WiFi.begin(WIFI_SSID, WIFI_PASSWORD);

 while (WiFi.status() != WL_CONNECTED) {
 delay(500);
 Serial.print(".");
 }

 Serial.println();
 Serial.println("WiFi connected");
 Serial.print("IP: ");
 Serial.println(WiFi.localIP()); //연결시 IP 주소 출력
}

/*
 MQTT 콜백 함수, 구독한 토픽이 발행되면 호출되는 함수
*/
void mqttCallback(char* topic, byte* payload, unsigned int length) {
 Serial.print("Message arrived [");
 Serial.print(topic);
 Serial.print("] ");

 String msg;
 for (unsigned int i = 0; i &lt; length; i++) {
 msg += (char)payload[i];
 }
 Serial.println(msg); 
}

// MQTT 연결 함수
void reconnectMQTT() {
 while (!client.connected()) {
 Serial.print("MQTT connecting...");

 String clientId = "1"; // 클라이언트 ID

 client.setBufferSize(512); // 버퍼 크기 설정

 // 연결
 bool connected = client.connect(
 clientId.c_str(),
 MQTT_USER,
 MQTT_PASSWORD);

 if (connected) {
 Serial.println("connected");
 
 // 명령 토픽 구독
 client.subscribe(TOPIC_SUB, 1);
 } else {
 Serial.print("failed, rc=");
 Serial.print(client.state());
 Serial.println(" retry in 2 sec");
 delay(2000);
 }
 }
}

// 초기 실행되는 아두이노 초기화 함수
void setup() {
 Serial.begin(115200);
 delay(1000);

 // wifi 연결
 connectWiFi();

 // mqtt 연결
 client.setServer(MQTT_BROKER, MQTT_PORT);
 // 콜백함수 등록
 client.setCallback(mqttCallback);
 // 주기적으로 연결 유지를 위한 체크 시간
 client.setKeepAlive(60); // 60초
}

// 주기적으로 호출되는 아두이노 loop 함수
void loop() {
 // 연결이 끊어지면 연결 시도
 if (WiFi.status() != WL_CONNECTED) {
 connectWiFi();
 }

 // MQTT 연결이 끊어졌다면 재 연결 시도
 if (!client.connected()) {
 reconnectMQTT();
 }

 // MQTT 동작 
 client.loop();

 unsigned long now = millis();
 if (now - lastPublishMs &gt;= 5000) {
 lastPublishMs = now;
 //5초에 한번씩 전송(발행)
 String payload = "{\"device_id\":\"esp32_001\",\"temp\":25.3,\"status\":\"ok\"}";
 // 마지막 파라메터는 retain으로 true를 주면 브로커가 저장하고 있다가 해당 토픽 구독을 하는 장치가 연결되면 즉각 마지막 상태를 전송한다.
 client.publish(TOPIC_PUB, payload.c_str(), true); 
 Serial.println("Published: " + payload);
 }
}
 </div> <div id="SE-499b1df4-cc9f-4e17-85ee-034145b11ea1">
 MQTTX에서 전송한 메시지가 아두이노 IDE 모니터링 화면에 표시되고ESP32에서 전송하는 메시지가 MQTTX에 출력되는 것을 볼 수 있다.
 </div> <div id="SE-11dfba5f-a7e0-4347-8c3f-90efae532493">
 <a href="#" onclick="return false;" data-linktype="img" data-linkdata="{&quot;id&quot; : &quot;SE-11dfba5f-a7e0-4347-8c3f-90efae532493&quot;, &quot;src&quot; : &quot;https://mblogthumb-phinf.pstatic.net/MjAyNjAzMjJfMjU4/MDAxNzc0MTY0OTM2OTQ3.9Z21sQgUiVoNrzIVf-lxfdognhcSIhcf47ilOMSD1VMg.Sc7s8G2B4J5tM-KWzzakkHEHIcyVD_Xxchc3o9Afvgwg.PNG/image.png&quot;, &quot;originalWidth&quot; : &quot;1381&quot;, &quot;originalHeight&quot; : &quot;594&quot;, &quot;linkUse&quot; : &quot;false&quot;, &quot;link&quot; : &quot;&quot;, &quot;fileSize&quot;: &quot;117057&quot; }">
 <img src="https://mblogthumb-phinf.pstatic.net/MjAyNjAzMjJfMjU4/MDAxNzc0MTY0OTM2OTQ3.9Z21sQgUiVoNrzIVf-lxfdognhcSIhcf47ilOMSD1VMg.Sc7s8G2B4J5tM-KWzzakkHEHIcyVD_Xxchc3o9Afvgwg.PNG/image.png?type=w800" data-width="693" data-height="298" alt="">
 </a>
 
 </div>
 <div id="SE-c1c5a403-9341-408b-a7b0-249b533893c3">
 ​옵션 설명마지막으로 두 가지 옵션에 대해서 알아보자.해당 옵션들은 MQTT에서 사용하는 핵심 기능으로, 대부분의 프레임워크에서 지원하기 때문에 이해하고 있으면 매우 유용할 것이다.​KeepAlive 
 </div> <div id="SE-e6479c2d-f6c4-4dd9-a656-7060470a007f">
 client.setKeepAlive(60); // 60초간 송수신이 없으면 ping으로 연결 확인 요청
 </div> <div id="SE-68fc8b22-a745-4b01-9ca1-dd97deb89a5d">
 keepalive는 지정된 시간 동안 데이터 송수신이 없을 경우, 클라이언트가 브로커에 ping(PINGREQ)을 보내고 브로커는 응답(PINGRESP)을 통해 연결 상태를 확인하는 일종의 Heartbeat 라고 보면 된다.만약 응답이 없을 경우 연결이 끊어진 것으로 판단하고 재연결을 시도하게 된다.​​retain
 </div> <div id="SE-45513e8b-5cd5-4a25-8a7d-5b3198121919">
 client.publish(TOPIC_PUB, payload.c_str(), true); // 마지막 파라메터값은 retain
 </div> <div id="SE-356f9528-3148-4820-95fd-0769a362cbd9">
 retain=true 설정 시 브로커는 해당 토픽의 마지막 메시지를 저장한다.이후 이 토픽을 구독하는 클라이언트가 새로 구독할 경우, 저장된 마지막 메시지(최종 상태)를 즉시 전달받는다.따라서 장치의 ON/OFF 상태나 센서의 마지막 값처럼 최종 상태를 유지해야 하는 데이터에 유용하게 사용할 수 있다.​​
 </div> </div></div>

하이! 제니스

ESP32 아두이노 기반에서 MQTT를 사용하는 방법을 다뤄볼것이다. 여기서는 AWS 서버가 아닌 별도의 MQTT 브로커와 아주 간단한 인증절차(ID/PASSWORD)만으로 연결하는 구조를 설명할 것이다. 참고로 아래의 글은 우분투 서버에 MQTT 브로커를 설치하는 내용이다. https://blog.naver.com/chandong83/224225398438 1. PubSubClient 라이브러리 설치 아두이노에서 왼쪽 메뉴중 라이브러리 탭을 클릭 후 검색창에 pubsubclient라고 입력한다. 그다음 by Nick O'Leary가 관리하는 라이브러리를 설치하자. 2. 예제 코드 아래의 예제코드는 하나의 토픽(test/topic)을 구독과 발행하는 코드이다. 5초에 한번식 해당 토픽으로 발행(전송)하고 해당.......

ESP32 아두이노에서 MQTT 사용하기(AWS 아닌 일반 브로커)

댓글