[아두이노] MQTT 연동하기

<본 블로그는 엘리스 IoT 1를 참고해서 공부하며 작성하였습니다 :-)>

(코드는 저작권상 공유 안됩니당!!)

 

🥑 MQTT 프로토콜 연결 시퀀스

         클라이언트 ---- CONNCET ----> MQTT 브로커
(구독/발행자) <---- CANNCAK ---- (Mosquitto)

- 연결 설정 및 확인

: MQTT 클라이언트와 브로커는 TCP 연결

: 클라이언트는 CONNECT 메시지 보내고, 이를 수신한 브로커는 CONNACK 보냄

: CONNCET 메시지에는 클라이언트 정보 포함

 

🥑 MQTT 프로토콜 구독 시퀀스

   클라이언트 ----  SUBSCRIBE ----> MQTT 브로커
  (구독자) <------ SUBACK ------ (Mosquitto)

- 구독 설정 및 확인

: 클라이언트는 토픽명과 QoS 수준을 포함한 SUBSCRIBE 메시지를 브로커에 보냄

: 브로커는 SUBACK를 클라이언트에게 보내 구독 확인, SUBACK 에도 QoS 수준 포함됨

 

🥑 MQTT 프로토콜 발행 시퀀스

   클라이언트 ----  PUBLISH  ----> MQTT 브로커
  (구독자) <------ PUBACK  ------ (Mosquitto)

- 발행 및 확인

: 클라이언트는 토픽명과 페이로드(메시지)를 포함한 PUBLISH 메시지 보냄

: 클라이언트의 메시지 전달을 보장해야 하는 경우 브로커가 PUBACK 혹은 PUBREC 메시지 보내도록 QoS 설정 가능

 

🥑 MQTT.js

: javascript 로 작성된 Node.js 및 브라우저 MQTT 프로토콜 클라이언트 라이브러리

: MQTT 브로커와 통신하기 위한 API 제공

// 주어진 ULR 과 옵션에 따라 브로커에 연결 하고 Client 객체 리턴 
mqtt.connect([url], options)

// 주기적인 서버 핑, QoS 동작, 재연결, 연결 전 메시지 발행 등 자동 수행
mqtt.Client(streamBuilder, options)

// 해당 토픽에 메시지 발행
mqtt.publish(topic, message, [options], [callback])

// 토픽 구독
mqtt.subscribe(topic/topic array/topic object, [options], [callback])

 

🍔 MQTT json 메시지 발행 및 구독하기

: MQTT 브로커에 연결 및 메시지 발행 목표

: 디바이스 대신 테스트 할 코드 작성