[Mosquitto] 3. Subscriber

*본 글은 node.js 언어로 Docker에 올라간 mosquitto (mqtt broker)에 topic을 구독 및 Payloag를 읽는 Subscriber Code 예제입니다.

 

목차

1. subscriber 코드 작성 (mqtt-subscriber -IBU.js)

2. 작성한 코드 실행 후 topic/payload 읽어오는지 확인

 

Subscriber 코드 작성 (파일 명 : mqtt-subscriber-IBU.js)
mqtt-subscriber-IBU.js 파일 생성

$user> code mqtt-subscriber-IBU.js

 

코드 작성

const mqtt = require('mqtt')
const host = 'localhost' //연결한 Broker 주소
const port = '1883' //연결할 Port

const connectUrl = `mqtt://${host}:${port}`
const client = mqtt.connect(connectUrl) 
const topic = 'GV60/IBU/' //Broker에 있는 topic 중 'GV60/IBU/'를 구독

client.on('connect', () => {
    console.log('Connected')
    client.subscribe([topic], () => {
      console.log(`Subscribe to topic '${topic}'`)
    })
  })

client.on('message', function(topic, payload){
    console.log('[TOPIC] VEHICLE/ECU :',topic,' | [PAYLOAD] CAN MESSAGE : ',payload.toString());
});

 

파일 실행 후 Broker 확인 및 Subscriber 실행 시 Topic에 맞게 Payload를 읽어오는지 확인

파일 실행

$user> node mqtt-subscriber-IBU.js

Broker (received PUBLISH / sending PUBLISH 에 성공함)

 

Subscriber - Topic/Payload