转载请注明出处:https://leytton.blog.csdn.net/article/details/100705766
NodeJS和npm安装就不说了,直接进入正题。
(1)创建项目目录,例如MqttClient
,在该目录下执行命令npm init
,
这时就会在目录下产生package.json
配置文件,包括依赖库管理。
(2)参考MQTT
库官方文档 https://www.npmjs.com/package/mqtt
(3)添加MQTT
库,执行命令npm install mqtt --save
,就会在项目目录下生成node_modules
目录,里面是依赖库文件。
(4)创建index.js
入口文件
(5)添加以下内容:
var mqtt = require('mqtt')
var client = mqtt.connect('mqtt://test.mosquitto.org')
client.on('connect', function () {
console.log("connected!");
client.subscribe('topic_0001', function (err) {
if (!err) {
client.publish('topic_0001', 'Hello mqtt');
console.log("published message~");
}
})
})
client.on('message', function (topic, message) {
// message is Buffer
console.log("received data:"+message.toString())
//client.end()// close clint
})
console.log("continue code");
代码执行结果如下:
E:\Dev\NodeJS\MqttClient>node index.js
continue code
connected!
published message~
received data:Hello mqtt