Node.js
mqtt
IoT

Node.js の mqtt クライアント

More than 1 year has passed since last update.

Node.js の mqtt クライアントの例です。
Arch Linux で動作の確認をしました。
Node.js のバージョンは、v9.2.0 です。

publish.js
#! /usr/bin/node
// ---------------------------------------------------------------
//  publish.js
//
//                  Dec/04/2017
//
// ---------------------------------------------------------------
console.error ("*** 開始 ***")
var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://192.168.8.101')
const topic = 'topic_1'

client.on('connect', function () {
    const today = new Date ()
    var ddx = (1900 + today.getYear ()) + "-" + (today.getMonth () +1)
    ddx += "-" + today.getDate () + " " + today.getHours()
    ddx += ":" + today.getMinutes () + ":" + today.getSeconds()
    client.publish(topic, ddx)
    console.log(ddx)
    client.publish(topic, 'Good Afternoon mqtt')
    client.publish(topic, 'こんにちは')
    client.end()
    console.error ("*** 終了 ***")
})

// ---------------------------------------------------------------
subscribe.js
#! /usr/bin/node
// ---------------------------------------------------------------
//  subscribe.js
//
//                  Dec/04/2017
//
// ---------------------------------------------------------------
console.error ("*** 開始 ***")
var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://localhost')

client.on('connect', function () {
    client.subscribe('topic_1')
})

client.on('message', function (topic, message) {
  // message is Buffer
    console.log(message.toString())
})
// ---------------------------------------------------------------