wakasann
6/8/2018 - 3:25 AM

Mqtt javascript client test

trymqttjsclient.php
content_copyfile_download
<!DOCTYPE html>
<html>
<head>
	<title>Mqtt Client</title>
</head>
<body>
<input type="text" name="msg" id="msg" />
<input type="button" value="send" onclick="sendMsg()" />
<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.min.js" type="text/javascript"></script>
<script type="text/javascript">
  var host = 'www.example.com';
  var port = Number(15675);
var client = new Paho.MQTT.Client(host, port, "/ws", "local_" + parseInt(Math.random() * 100, 10));
console.log(client);
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
var options = {
    timeout: 30,
	keepAliveInterval: 10,
    onSuccess: function () {
        debug("CONNECTION SUCCESS");
        client.subscribe('order', {qos: 1});
    },
    onFailure: function (message) {
        debug("CONNECTION FAILURE - " + message.errorMessage);
    },
	onSuccess:onConnect,
	userName:"guest2",
	password:"guest2"
};

// 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.
  console.log("onConnect");
  client.subscribe('order', {qos: 1});
  //client.subscribe("order");
}

function debug(obj){
	console.log(obj);
}

// called when the client loses its connection
function onConnectionLost(responseObject) {
	debug("CONNECTION LOST - " + responseObject.errorMessage);
  if (responseObject.errorCode !== 0) {
    console.log("onConnectionLost:"+responseObject.errorMessage);
  }
}

function onConnectionLost(responseObject) {
  if (responseObject.errorCode !== 0) {
    console.log("onConnectionLost:"+responseObject.errorMessage);
  }
}
// called when a message arrives
function onMessageArrived(message) {
  debug("RECEIVE ON " + message.destinationName + " PAYLOAD " + message.payloadString);
  //print_first(message.payloadString);
  console.log("onMessageArrived:"+message.payloadString,new Date());
}

function sendMsg(){
	console.log("you have click");
	var text = document.getElementById("msg").value;
	var message = new Paho.MQTT.Message(text);
    message.destinationName = "order";
    client.send(message);
}
</script>
</body>

</html>