使用TLS的Node.js mqtt客户端

Question

var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://test.mosquitto.org')

client.on('connect', function () {
  client.subscribe('presence')
  client.publish('presence', 'Hello mqtt')
})

client.on('message', function (topic, message) {
  // message is Buffer 
  console.log(message.toString())
  client.end()
})

mosca MQTT代理作为独立运行，使用下面的命令；

mosca --key ./tls-key.pem --cert ./tls-cert.pem --http-port 3000 --http-bundle --http-static ./ | pino

Answer 1

应该足以将URL的协议部分更改为mqtts://

mqtts://test.mosquitto.org。

自签名证书

mqtt.connect('mqtts://test.mosquitto.org', {
    rejectUnauthorized: false
});