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!

cardealt

Membros
  • Total de itens

    1
  • Registro em

  • Última visita

  1. Javascript MQTT Web Application

    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
×