Node.js: MQTT クライアントのサンプル

こちらで定めた仕様を満たすクライアントです。
IOT: MQTT クライアントのサンプル

Raspberry Pi で確認しました。

GPIO16 に接続した LED を ON/OFF します。

プログラム

subscribe.js

# ! /usr/local/bin/node
// ---------------------------------------------------------------
//	subscribe.js
//
//					Oct/05/2021
//
// ---------------------------------------------------------------
'use strict'

console.error ("*** 開始 ***")
var mqtt = require('mqtt')
const client  = mqtt.connect('mqtt://example.com')
const topic = 'example/test01'

var Gpio = require('onoff').Gpio
var led = new Gpio(16, 'out')

// ---------------------------------------------------------------
client.on('connect', function () {
	client.subscribe(topic)
})

// ---------------------------------------------------------------
client.on('message', function (topic, message) {
	const json_str = message.toString()
	const dict_aa = JSON.parse (json_str)

	if ('desired' in dict_aa['state'])
		{
		const desired = dict_aa['state']['desired']
		led_proc(desired)
		}
})

// ---------------------------------------------------------------
function led_proc(desired)
{
	console.log(desired)
	console.log(desired['led'])
	const on_off = desired['led']

	if (on_off == "on")
		{
		led.writeSync(1)
		}
	else if (on_off == "off")
		{
		led.writeSync(0)
		}

	report_proc(on_off)
}

// ---------------------------------------------------------------
function report_proc(on_off)
{
	var dict_aa = new Object ()
	dict_aa["state"] = new Object ()
	dict_aa["state"]["reported"] = new Object()
	dict_aa["state"]["reported"]["led"] = on_off
	const json_str = JSON.stringify(dict_aa) 
	console.log(json_str)
	console.log()
	client.publish(topic, json_str)
}

// ---------------------------------------------------------------

実行スクリプト

export NODE_PATH=/usr/local/lib/node_modules
./subscribe.js

次のパージョンで確認しました。

$ node -v
v14.17.6