[node.js 응용] NodeJS 에서 mqtt 사용하기

mqtt 공식 홈페이지

1. MQTT란 무엇인가?

Mqtt는 경량 메시지 프로토콜입니다. 상대적으로 가볍습니다. 그래서 주로 IoT 장치와 클라우드 애플리케이션 간의 효율적인 데이터 교환을 위해서 사용합니다.

2. MQTT 기본 용어

broker(브로커) - mqtt서버 ,장치와 장치를 연결해줍니다.
publish(발행) - client가 서버에 메시지를 보냅니다.
subscribe(구독) - client가 서버로부터 메시지를 받습니다. 받는 client는 subscriber(구독자)라고 합니다.
topic - 메시지를 보낼때 topic으로 구분해서 보냅니다.
qos - Quaility of Service 의 약자로서, 메시지의 품질을 나타냅니다. 0,1,2로 구분되며, 레벨이 높을수록 서버에서 처리할 내용이 많아집니다.

2. MQTT 브로커 설치

  1. 맥에서 mqtt브로커를 설치하기 위해서는 홈브루를 설치해야 합니다.
    홈브루 공식 홈페이지

맥 터미널에서 복사 붙여넣기 해주세요

/bin/bash -c "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/HEAD/install.sh)"
  1. 홈브루가 설치되었으면 mqtt 브로커를 설치해줍니다. mqtt브로커로는 여러가지가 있지만 가장 유명한 mosquitto를 사용하였습니다.
brew install mosquitto

/usr/local/sbin/mosquitto -c /usr/local/etc/mosquitto/mosquitto.conf

위와같이 터미널에서 순차적으로 실행시킨다면, mqtt 브로커가 잘 실행되는것을 잘 확인할 수 있습니다.

3.MQTT 익스프로러 설치

mqtt 익스플로러는 mqtt 브로커와 연결하여 mqtt메시지를 잘 볼수 있도록 하는 프로그램입니다.

mqtt 익스플로러 홈페이지

이곳에서 new connection을 눌러서 Host에 localhost를 작성하면 구독해서 확인할 수 있습니다.

4.Node.JS에서 확인하기

mqtt 소스코드 예제

경축! 아무것도 안하여 에스천사게임즈가 새로운 모습으로 재오픈 하였습니다.
어린이용이며, 설치가 필요없는 브라우저 게임입니다.
https://s1004games.com

npm init -y
npm install mqtt --save

publisher.js

const mqtt = require("mqtt")
const client = mqtt.connect('mqtt://localhost:1883')

const message={
    a:1,
    b:2
}
setInterval(
    () => client.publish('topic', JSON.stringify(message)
    ), 10000)

10초 한번씩 간단한 JSON을 발행하는 소스코드이다.

subscriber.js

const mqtt = require("mqtt")
const client = mqtt.connect('mqtt://localhost:1883')
//mqtt가 연결되면 실행
client.on('connect', () => {
    //mqtt가 연결되어있는지 확인
    console.log(client.connected);
    //topic 구독
    client.subscribe('topic'); //topic 구독
    //구독해놓은 메시지가 들어오면 실행
    client.on("message", (topic, message) => {
        console.log(topic, JSON.parse(message));
    })
})

해당 사진과 같이 mqtt explorer 에서 토픽과 메시지 history와 함께 확인이 쉽게 되는 것을 볼 수 있습니다.

 

[출처] https://velog.io/@hurjun/NodeJS-%EC%97%90%EC%84%9C-mqtt-%EC%82%AC%EC%9A%A9%ED%95%98%EA%B8%B0

 

 

본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
번호 제목 글쓴이 날짜 조회 수
505 [JavaScript] lastIndexOf() : String에서 원하는 값의 마지막 위치(index) 찾기 졸리운_곰 2024.02.28 3
504 [node.js 응용] Node.js에서 다른 파일의 함수를 "include" 하는 방법 졸리운_곰 2024.02.28 1
» [node.js 응용] NodeJS 에서 mqtt 사용하기 file 졸리운_곰 2024.02.23 1
502 [Javascript] Toggle Between Grid and List View in React file 졸리운_곰 2024.02.23 1
501 [node.js 응용] Next.js 기본 개념정리 file 졸리운_곰 2024.02.23 1
500 [HTML/JavaScript] Merge neighbouring HTML table cells with same value using JS : html 테이블 셀 자동적으로 가로/세로 합치기 졸리운_곰 2024.02.18 3
499 [웹 어셈블리, WSAM] An example of emscripten with WebSocket. file 졸리운_곰 2023.12.12 2
498 [HTML] DNS 유지한 채 도메인 포워딩 : How to set up URL frame forwarding 졸리운_곰 2023.12.04 3
497 [Javascript] [Javascript] 자바스크립트에서 Class 사용하기-constructor, extends, file 졸리운_곰 2023.11.29 16
496 [Javascript] undefined와 null의 차이점이란 ? 졸리운_곰 2023.11.29 13
495 [node.js 응용] ejs 사용설명서 file 졸리운_곰 2023.11.25 7
494 [웹 어셈블리, WSAM] サーバサイドはWebAssemblyの夢を見るか? – Node.jsでwasmってみた : 서버 측은 WebAssembly의 꿈을 꾸는가? – Node.js에서 wasm 해 보았습니다. file 졸리운_곰 2023.08.27 6
493 [웹 어셈블리 WSAM, webassembly] WebAssembly on the server-side : 서버측 웹어셈블리 file 졸리운_곰 2023.08.27 7
492 [HTML} Vercel을 이용하여 정적사이트를 무료로 운영하기 file 졸리운_곰 2023.07.09 3
491 [HTML] GitHub와 Netlify를 이용한 쉽고 빠른 HTTPS 무료 호스팅 졸리운_곰 2023.07.09 8
490 [HTML] netlify로 정적 사이트 배포하기 졸리운_곰 2023.07.09 9
489 [Javascript/Typescript] TypeScript 간단 정리 졸리운_곰 2023.05.21 12
488 [JavaScript] CORS란? CORS를 해결해보자 졸리운_곰 2023.05.09 24
487 [JavaScript] [JS] CORS 정리 및 오류 해결 졸리운_곰 2023.05.09 22
486 [node.js 응용] Build a Node.js Proxy Server in Under 10 minutes! file 졸리운_곰 2023.05.07 18
대표 김성준 주소 : 경기 용인 분당수지 U타워 등록번호 : 142-07-27414
통신판매업 신고 : 제2012-용인수지-0185호 출판업 신고 : 수지구청 제 123호 개인정보보호최고책임자 : 김성준 sjkim70@stechstar.com
대표전화 : 010-4589-2193 [fax] 02-6280-1294 COPYRIGHT(C) stechstar.com ALL RIGHTS RESERVED