Я не получаю никакого ответа в моем приложении mqtt, работающем на node.js - PullRequest
0 голосов
/ 19 сентября 2018

Я пытаюсь подписаться на брокер 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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...