Я пытаюсь подписаться на брокер mqtt, но ничего не происходит, когда я запускаю код на node.js
var mqtt = require('mqtt')
const address = "mqtt://myaddress"
const port = 1883
const user = 'iot'
const pass = 'iot2017'
var options = {port: port, user: user, password: pass, debug: true,
onSuccess: function () {
console.log("Connected");
},
//Gets Called if the connection could not be established
onFailure: function (message) {
console.log("Connection failed: " + message.errorMessage);
}}
var client = mqtt.connect(address, options)
client.on('connect', function () {
console.log('connected')
client.subscribe('iotmehow/temp', function (err) {
console.log('subscribe temp')
if (!err) {
client.publish('presence', 'Hello mqtt')
}
else{
console.log('subscribe error')
console.log(err)
}
})
})
client.on('message', function (topic, message) {
console.log('message')
console.log(message)
client.end()
})
client.on('error', function (topic, message) {
// message is Buffer
console.log('error')
console.log(message)
//client.end()
})
Это работает, когда я использую этот код из github:
var mqtt = require('mqtt')
var client = mqtt.connect('mqtt://test.mosquitto.org')
client.on('connect', function () {
client.subscribe('presence', function (err) {
if (!err) {
client.publish('presence', 'Hello mqtt')
}
})
})
client.on('message', function (topic, message) {
// message is Buffer
console.log(message.toString())
client.end()
})
У меня нет ответа от моего кода, ни onSuccess, ни onFailure ничего не показывает.Я использую узел v6.10.2 и Windows 10