Блог

Я пытаюсь реализовать node.js клиент mqtt с TLS, использующий приведенный ниже пакет;

https://www.npmjs.com/package/mqtt#client

Код для запуска клиента mqtt без TLS выглядит следующим образом;

 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()
})
  

Как следует изменить приведенный выше код, чтобы использовать TLS на клиенте mqtt?

Брокер mosca MQTT был запущен как автономный с помощью приведенной ниже команды;

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

Должно быть достаточно, чтобы изменить protocol часть URL на mqtts://

mqtts://test.mosquitto.org .

Самозаверяющие сертификаты

connect При использовании самозаверяющих сертификатов (только для целей тестирования) вы можете передать функции следующую опцию:

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

Вам необходимо предоставить mqtt.connect() функции объект options, который включает сертификат CA, используемый для проверки соединения.

Объект options должен включать ca ключ, который указывает на сертификат, используемый для подписи сертификата брокеров. Поскольку похоже, что вы используете самозаверяющий сертификат, это будет тот же сертификат, который используется брокером.

ca Ключ описан здесь

Или вы можете разрешить любой сертификат с rejectUnauthorized ключом, как указано в ответе @notion. Но это делает невозможным определить, выдает ли кто-то себя за вашего брокера