[Node.js] mqtt 다루기

MQTT는 Message Queue Telemetry Transport의 축약으로, IoT나 메시지 전송 서버 등에 사용하기 적합한 통신 프로토콜 중 하나다.

클라이언트<->서버의 2자만이 존재하는 HTTP와 다르게, 총 3개의 요소로 구성된다.
중심 서버의 역할을 하는 **중개자(broker)**가 있고,
토픽을 발행하는 **발행인(publisher)**이 있다.
그리고 **구독자(subscriber)**는 발행된 토픽을 통해 메세지를 받아온다.
그리고 이러한 발행과 구독은 브로커가 관리하게 된다.

https://wnsgml972.github.io/mqtt/2018/03/05/mqtt/ 펌

백문이 불여일견이라, 일단 써보면서 익혀보자.

브로커

일단 중심이 될 브로커부터 선택하자.
브로커 서버는 우리가 직접 구현하긴 힘들 수 있고, 제공되는 친구들을 쓰는 게 편리하다.
mosquitto, HiveMQ, Rabbit MQ, IBM MQ, Vertx 등이 있는데, 이 중에서도 모스키토가 인기가 많은 것 같다.

모스키토를 쓴다면 'mqtt://test.mosquitto.org'를 통해 브로커에 접속할 수 있다.

발행과 구독

그럼 이제 브로커를 통해 구독과 발행을 하기 위한 클라이언트 모듈을 설치하자. 이름은 mqtt다.

일단 퍼블리셔부터 따로 만들었다.
간단하게 모스키토 브로커에게 연결한 후에, 2초마다 test 토픽으로 메세지를 계속 전송한다.

그리고 구독자다. test 토픽을 구독한 후에, message 이벤트 핸들링으로 받아온 데이터를 출력한다.

저 2개의 프로그램을 각각 돌리면, 구독자에게는 아래와 같이 계속 메세지가 들어오고 로깅될 것이다.

QoS 수준

mqtt는 3가지의 QoS 수준을 제공한다.
뭐 그렇게 거창한 것은 아니고, 전송에 실패했을 때 어떻게 처리를 할 것인지를 수준에 따라 나누는 것이다.

0레벨은 그냥 무식하게 한번 쏘고 만다. 송수신에 실패해도 그냥 무시된다. UDP처럼...
1레벨은 적어도 한번 수신된다. 수신에 성공할때까지 보내는 것이다.
2레벨은 거기에 더해서 중복 처리도 해준다. 무조건 정확히 한번만 수신되도록 하는 것이다.

보통은 따로 설정하지 않는다면 0레벨로 동작한다.
직접 설정하고 싶다면 추가 옵션을 주면 된다.

참조
https://yonghyunlee.gitlab.io/node/node-mqtt/
https://wnsgml972.github.io/mqtt/2018/03/05/mqtt/
https://medium.com/@alifabdullah/setting-up-private-mqtt-broker-using-mosca-in-node-js-c61a3c74f952
https://www.npmjs.com/package/mqtt#install