Nano Hash - криптовалюты, майнинг, программирование

Не получать полезную нагрузку от mosquitto через веб-сокеты

Я использую VPS и отправляю данные с Arduino на сервер через MQTT.

Mosquitto успешно печатает полезные данные через терминал, но когда я пытаюсь распечатать их в режиме реального времени через веб-страницу, ничего не происходит.

Зная, что я уже разрешил веб-сокеты в конфигурации Mosquitto, если я запускаю:

sudo netstat -plnt

Я получил :

tcp        0      0 0.0.0.0:1883            0.0.0.0:*               LISTEN      
13248/mosquitto
tcp        0      0 0.0.0.0:1884            0.0.0.0:*               LISTEN      
20169/mosquitto
tcp6       0      0 :::1883                 :::*                    LISTEN      13248/mosquitto

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

  <script>

    var websocket="myserver.ovh.net";
    var port= 1884;
    var user="username";
    var pass="password";


    client = new Paho.MQTT.Client(websocket, port, "innovation");


     // set callback handlers
     client.onConnectionLost = onConnectionLost;
     client.onMessageArrived = onMessageArrived;

  var options = {
   useSSL: false,
   userName: user,
   password: pass,
   onSuccess:onConnect,
   onFailure:doFail
}

// connect the client

client.connect(options);


// called when the client connects

 function onConnect() {
// Once a connection has been made, make a subscription and send a 
message.


 document.getElementById("connstatus").innerHTML = "Mqtt Connected";

 console.log("Mqtt Connected");

  client.subscribe("/pression");

    }

    function doFail(e){
    console.log(e);
   }

   // called when the client loses its connection
    function onConnectionLost(responseObject) {

  document.getElementById("connstatus").innerHTML = "Mqtt Not Connected";

     if (responseObject.errorCode !== 0) {
         console.log("onConnectionLost:"+responseObject.errorMessage);
    }
   }

   function onMessageArrived(message) {
   console.log("Pression is :");
   document.getElementById("connstatus").innerHTML = message.payloadString;
   console.log(message.payloadString);

   }


  </script>

когда я запускаю скрипт, он говорит «Mqtt Connected», но ничего не происходит.

Однако, если я запускаю в терминале:

         mosquitto_sub -t '/pression'

Я получаю значения давления.

если я держу веб-страницу в течение нескольких минут, я получаю это сообщение:

       Mqtt Connected
       test.html:76 onConnectionLost:AMQJS0008I Socket closed.

файл конфигурации:

   # Place your local configuration in /etc/mosquitto/conf.d/
   #
   # A full description of the configuration file is at
   # /usr/share/doc/mosquitto/examples/mosquitto.conf.example

   pid_file /var/run/mosquitto.pid

   persistence true
   persistence_location /var/lib/mosquitto/

   log_dest file /var/log/mosquitto/mosquitto.log

   include_dir /etc/mosquitto/conf.d

   #password_file /etc/mosquitto/passwd
   #allow_anonymous false



   listener 1884
   protocol websockets

журнал комаров:

       1557922249: Config loaded from /etc/mosquitto/mosquitto.conf.
       1557922249: Opening websockets listen socket on port 1884.
       1557922254: New client connected from xx.xx.11.163 as innovation (c1, k60, u'innovation').
       1557922279: Socket error on client innovation, disconnecting.
       1557922279: New client connected from xx.xx.11.163 as innovation (c1, k60, u'innovation').
       1557922318: Socket error on client innovation, disconnecting.
       1557922318: New client connected from xx.xx.11.163 as innovation (c1, k60, u'innovation').
       1557922346: Socket error on client innovation, disconnecting.
       1557922346: New client connected from xx.xx.11.163 as innovation (c1, k60, u'innovation').
       1557922363: Socket error on client innovation, disconnecting.
       1557922364: New client connected from xx.xx.11.163 as innovation (c1, k60, u'innovation').
       1557922463: Socket error on client innovation, disconnecting.
15.05.2019

Ответы:


1

Хорошо, проблема здесь, скорее всего, в том, что вы используете фиксированный идентификатор клиента (innovation) в HTML.

У вас может быть только 1 клиент, подключенный с данным идентификатором клиента, поэтому брокер отключит самый старый клиент, когда подключается новый клиент с тем же идентификатором (например, когда вы перезагружаете страницу).

Попробуйте изменить строку подключения на что-то вроде этого:

var clientID = "innovation_" + new Date().getTime();
client = new Paho.MQTT.Client(websocket, port, clientID);
15.05.2019
  • Я только что сделал это, и я все еще получаю ту же ошибку. 1557924290: конфигурация загружена из /etc/mosquitto/mosquitto.conf. 1557924290: Открытие сокета для прослушивания веб-сокетов на порту 1884. 1557924296: Новый клиент подключен с xx.xx.11.163 как Innovation_1557924296241 (c1, k60, u'innovation'). 1557924315: Ошибка сокета на клиенте Innovation_1557924296241, отключение. 15.05.2019
  • Есть ли брандмауэр между браузером и брокером? 15.05.2019
  • Как я могу проверить, пожалуйста? 15.05.2019
  • Прочтите документы и попробуйте установить для KeepAlive примерно 10 секунд, а не 60 секунд по умолчанию. 15.05.2019
  • Спасибо, hardillb, я все перепробовал, но ничего не работает, может проблема в SSL? потому что я пробовал свой js-код с cloudMQTT, и он работал отлично, но когда я использую свой собственный VPS, у меня возникает эта проблема, единственная разница в том, что в cloudMQTT я использую безопасный веб-сокет. 15.05.2019
  • Я думаю, что это, вероятно, брандмауэр / маршрутизатор для вашего VPS, но, не имея доступа к нему, я не могу придумать простых способов а) проверить / доказать это и б) как предложить это исправить. Более частый пинг keepAlive должен был помочь. 15.05.2019
  • Новые материалы

    Кластеризация: более глубокий взгляд
    Кластеризация — это метод обучения без учителя, в котором мы пытаемся найти группы в наборе данных на основе некоторых известных или неизвестных свойств, которые могут существовать. Независимо от..

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

    Частный метод Python: улучшение инкапсуляции и безопасности
    Введение Python — универсальный и мощный язык программирования, известный своей простотой и удобством использования. Одной из ключевых особенностей, отличающих Python от других языков, является..

    Как я автоматизирую тестирование с помощью Jest
    Шутка для победы, когда дело касается автоматизации тестирования Одной очень важной частью разработки программного обеспечения является автоматизация тестирования, поскольку она создает..

    Работа с векторными символическими архитектурами, часть 4 (искусственный интеллект)
    Hyperseed: неконтролируемое обучение с векторными символическими архитектурами (arXiv) Автор: Евгений Осипов , Сачин Кахавала , Диланта Хапутантри , Тимал Кемпития , Дасвин Де Сильва ,..

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

    Обеспечение масштабируемости LLM: облачный анализ с помощью AWS Fargate и Copilot
    В динамичной области искусственного интеллекта все большее распространение получают модели больших языков (LLM). Они жизненно важны для различных приложений, таких как интеллектуальные..