Как я могу использовать TLS с Paho MQTT поверх Javascript? - PullRequest
0 голосов
/ 29 октября 2018

код, который я использую в настоящее время на моем сайте

var client       = null;
var device_is_on    = null;
var hostname       = "********";
var port           = "8003";
var clientId       = "mqtt_js_" + parseInt(Math.random() * 100000, 10);
var device_topic     = "stat/Device_001/POWER";
var status_topic   = "cmnd/Device_001/power";


function connect(){
    client = new Paho.MQTT.Client(hostname, Number(port), clientId);

    client.onConnectionLost = onConnectionLost;
    client.onMessageArrived = onMessageArrived;

    var options = {
        useSSL: true,
        userName : "***",
        password : "********",
        onSuccess: onConnect,
        onFailure: onFail
    };
    client.connect(options);
}


function onConnect(context) {
    options = {qos:0}
    client.subscribe(device_topic, options);
    client.subscribe(status_topic, options);

    var payloadd = "6";

    message = new Paho.MQTT.Message(payloadd);
    message.destinationName = status_topic;
    message.retained = true;
    client.send(message);
}

function onFail(context) {
}

function onConnectionLost(responseObject) {
    if (responseObject.errorCode !== 0) {
        window.alert("Connection Lost!\nPlease Refresh.");
    }
}

function onMessageArrived(message) {

    if (message.destinationName == device_topic){ 
        var temperature_heading = document.getElementById("device_display");
        temperature_heading.innerHTML = "Air Conditioner: " + message.payloadString;
        if (message.payloadString == "ON" || message.payloadString == "o"){
            device_is_on = true;
        } else {
            device_is_on = false;
        }
    }
}

function device_toggle(){
    if (device_is_on){
        var payload = "off";
        device_is_on = false;
    } else {
        var payload = "on";
        device_is_on = true;
    }

    message = new Paho.MQTT.Message(payload);
    message.destinationName = status_topic;
    message.retained = true;
    client.send(message);
}

Что я должен поместить в раздел "var options"? в настоящее время я получаю сообщение об ошибке ERR_CERT_AUTHORITY_INVALID в консоли Google Chrome.

Примечание 1. Этот код прекрасно работает по протоколу http, но я конвертирую в https.

Примечание 2: я использую Mosquitto в качестве моего брокера MQTT.

Помощь очень ценится.

Ответы [ 2 ]

0 голосов
/ 29 октября 2018

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

У вас есть 2 варианта:

  1. Импортируйте сертификат в ваш браузер и пометьте его как доверенный (как вы это сделаете, зависит от того, какой браузер вы используете). Это действительно полезно только для тестирования / разработки, поскольку обычные пользователи не должны импортировать случайные сертификаты, поскольку это открывает их для всех видов проблем безопасности.

  2. Получите настоящий доверенный сертификат для вашего сайта и брокера. Самый простой / дешевый способ сделать это - использовать letsencrypt . Затем вы можете настроить mosquitto для использования этого сертификата.

0 голосов
/ 29 октября 2018

Клиент TLS javascript Paho доступен: Github paho.mqtt.javascript / Issues / 88

...