Ir para conteúdo
Fórum CódigoFonte.net
  • Anúncios

    • codigofonte

      Novo Fórum

      Pessoal, Atualizamos nossa versão do fórum para a mais recente da Invision Power. Como tínhamos uma versão muito antiga, talvez algumas áreas possam funcionar de forma errada ou com problemas, gostaria de pedir-lhes a compreensão, pois iremos resolvendo aos poucos. Até mais!
Entre para seguir isso  
cardealt

Javascript MQTT Web Application

Recommended Posts

Olá pessoal, eu espero que estejam bem! 

Primeiramente eu gostaria de me desculpar pela minha "noobice". Eu não venho da área de web, por isso a minha falta de conhecimento e a minha necessidade urgente de obter ajuda :/

Como não conheço muito a linguagem, vou tentar detalhar bem meu problema colocando várias imagens em anexo, perdoem-me se eu estiver sendo exagerada rsrs

Vamos lá:

Eu criei uma aplicação bem simples (imagem APP - 1. Tela.png). Essa aplicação tem 4 campos em tela que quando publicados, salva a mensagem (payload) em tempo real em uma tabela (imagem SAP HANA database - Tabela para salvar dados.png) no SAP HANA database (banco de dados do SAP HANA Trial (imagem SAP HANA database.png)). 

Para isso, usarei o protocolo MQTT. Sendo assim, criei uma conta no Cloud MQTT (imagem Cloud MQTT criado.png). 

Obs: Ou seja, a grosso modo, a minha app vai mandar a mensagem para o cloud mqtt e o cloud mqqt vai direcionar para a minha tabela do SAP HANA database. Para isso usei o tutorial http://www.hivemq.com/blog/build-javascript-mqtt-web-application

 

Porém, nem tudo são flores :/

 

1) Testando pela web (http://www.hivemq.com/demos/websocket-client/) e passando todos os parâmetros correspondentes, eu consigo que o payload seja salvo em minha tabela.

{mode":"sync","messageType":"57cd765743f3f9c473d5","messages":[{"Humidity":25.7, "Temperature": 21.5, "Brightness": 13.0, "timestamp":1413100000}]}

  • WEB - sucesso - 1. Connect - Estabelecendo conexão com o Cloud MQTT.png
  • WEB - sucesso - 2. Subscribed – Subscrevendo o Topic.png
  • WEB - sucesso - 3. Publish – Publicando a mensagem no Topic.png
  • WEB - sucesso - 4. Salvando na tabela do SAP HANA database.png

2) Ainda testando via  web (http://www.hivemq.com/demos/websocket-client/) e passando todos os parâmetros correspondentes, e não consigo que o payload que eu estou gerando no código da minha aplicação salve os dados na minha tabela do banco sap hana.

{"mode":"sync","messageType":"57cd765743f3f9c473d5","messages":[{"Humidity":"99.1","Temperature":"99.2","Brightness":"99.3","Timestamp":"1999999999"}]}

  • WEB - erro - 3. Publish – Publicando a mensagem no Topic.png
  • WEB - erro - 4. NÃO Salvando na tabela do SAP HANA database.png

 

3) Testando direto pela minha aplicação, o payload gerado não está salvando os dados na minha tabela do SAP HANA database.

{"mode":"sync","messageType":"57cd765743f3f9c473d5","messages":[{"Humidity":"99.1","Temperature":"99.2","Brightness":"99.3","Timestamp":"1999999999"}]}

  • APP - erro - 2. Publish - Publicação realizada.png
  • APP - erro - 3. NÃO salvando na tabela do SAP HANA database.png

 

4) Meu código javascript

<script>

          //Using the HiveMQ public Broker, with a random client Id

        var client = new Messaging.Client("m12.cloudmqtt.com", 39388, "bnuser" + parseInt(Math.random() * 100, 10));

         //Gets  called if the websocket/mqtt connection gets disconnected for any reason

        client.onConnectionLost = function(responseObject) {

            //Depending on your scenario you could implement a reconnect logic here

            alert("connection lost: " + responseObject.errorMessage);

        };

         //Gets called whenever you receive a message for your subscriptions

        client.onMessageArrived = function(message) {

            //Do something with the push message you received

           // $('#messages').append('<span>Topic: ' + message.destinationName + '  | ' + message.payloadString + '</span><br/>');

console.log("Message Arrived: " + message.payloadString);

  console.log("Topic:     " + message.destinationName);

  console.log("QoS:       " + message.qos);

  console.log("Retained:  " + message.retained);

  // Read Only, set if message might be a duplicate sent from broker

  console.log("Duplicate: " + message.duplicate);

};

       //Connect Options

        var options = {

            userName: "tyanxvet",

            password: "fmZYiSylGtjD",

            useSSL: true,

            timeout: 3,

                 

            //Gets Called if the connection has sucessfully been established

            onSuccess: function() {

                alert("Connected");

            },

            //Gets Called if the connection could not be established

            onFailure: function(message) {

                alert("Connection failed: " + message.errorMessage);

            }

        };

         var pl = new Object();

        pl.mode = "sync";

        pl.messageType = "57cd765743f3f9c473d5";

         var topic = "iot/data/iotmmss0016095593trial/v1/dc71fe1f-f710-4c06-a9f3-579d28a05e64";

        var mensagem = new Object();

  

        //Creates a new Messaging.Message Object and sends it to the HiveMQ MQTT Broker

        var publish = function(payload, topic, qos) {

                                             

            mensagem.Humidity = document.getElementById("humidity").value;

            mensagem.Temperature = document.getElementById("temperature").value;

            mensagem.Brightness = document.getElementById("brightness").value;

            mensagem.Timestamp = document.getElementById("timestamp").value;

             pl.messages = new Array();

            pl.messages[0] = mensagem;

            console.log(JSON.stringify(pl));

             //Send your message (also possible to serialize it as JSON or protobuf or just use a string, no limitations)

            var message = new Messaging.Message(payload);

            message.destinationName = topic;

            message.qos = 0;

                       //message.retained = true;

            client.send(message);

        }

 

        function refreshPage() {

            window.location.reload();

        }

    </script>

 

5) Meu código HTML

<body>

    <fieldset>

        <legend>Send Data</legend>

        <p>Humidity:

            <input type="text" id="humidity">

        </p>

        <p>Temperature:

            <input type="text" id="temperature">

        </p>

        <p>Brightness:

            <input type="text" id="brightness">

        </p>

        <p>Timestamp:

            <input type="text" id="timestamp">

        </p>

        <button onclick="client.connect(options);">1. Connect</button>

        <button onclick="client.subscribe(topic, {qos: 2}); alert('Subscribed');">2. Subscribe</button>

        <button onclick="publish(JSON.stringify(pl),topic, 2);">3. Publish</button>

        <button onclick="client.disconnect();">4. Disconect</button>

        <div id="messages"></div>

    </fieldset>

</body>

 

Para mim parece que o problema é na montagem do payload da minha aplicação, mas pode ser que o problema seja outro e eu não fui capaz de identificar. Caso o problema seja realmente o payload, como eu devo ajustá-lo? Tentei algumas formas mas todas fotam sem sucesso ://

 

Alguém pode me ajudar??? 


Att, 
Tata Cardeal

 

APP - 1. Tela.png

APP - erro - 2. Publish - Publicação realizada.png

APP - erro - 3. NÃO salvando na tabela do SAP HANA database.png

Cloud MQTT criado.png

SAP HANA database - Tabela para salvar dados.png

SAP HANA database.png

WEB - erro - 3. Publish – Publicando a mensagem no Topic.png

WEB - erro - 4. NÃO Salvando na tabela do SAP HANA database.png

WEB - sucesso - 1. Connect - Estabelecendo conexão com o Cloud MQTT.png

WEB - sucesso - 2. Subscribed – Subscrevendo o Topic.png

WEB - sucesso - 3. Publish – Publicando a mensagem no Topic.png

WEB - sucesso - 4. Salvando na tabela do SAP HANA database.png

Compartilhar este post


Link para o post
Compartilhar em outros sites

Crie uma conta ou entre para comentar

Você precisar ser um membro para fazer um comentário

Criar uma conta

Crie uma nova conta em nossa comunidade. É fácil!

Crie uma nova conta

Entrar

Já tem uma conta? Faça o login.

Entrar Agora
Entre para seguir isso  

×