Node.js物聯網裝置開發

MQTT 協定

|

179

// mqtt_sub_10s.js

//

var mqtt = require('mqtt');

// 建立 MQTT 客戶端

client = mqtt.connect('mqtt://test.mosquitto.org', 1883);

// 指出我們感興趣的主題

client.subscribe('arduino/#');

// 回應訂閱主題的訊息

client.on('message', function (topic, message) {

console.log(topic,": ", message.toString());

});

// 在 10 秒後離開，不論是否收到訊息

setTimeout(function() {

client.end();

}, 10000);

若一切正常，你應可看到：

$ node mqtt_sub_10s.js

arduino/slider : value: 312

arduino/slider : value: 412

arduino/slider : value: 553

MQTT 伺服器 Mosca

除了使用公開的 MQTT 中介器，我們也可以自己捲起袖子，使用 Node.js 來打造 MQTT

伺服器。可行選項之一是 Mosca（

https://www.npmjs.com/package/mosca

）。

若要使用 Mosca，必須安裝一套資料儲存方案，例如 Ascoltatori（

https://www.npmjs.

com/package/ascoltatori ...