yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

websocket test

This commit is contained in:
Feng Lee 2015-04-28 00:14:21 +08:00
parent 9343a7c419
commit 1b96f93ab7
4 changed files with 2208 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
apps/emqttd/priv/www/mqtt.html Normal file
View File

@ -0,0 +1,63 @@
<html>
<head>
<title>MQTT over WebSocket</title>
</head>
<body>
<h1>MQTT Over WebSocket</h1>
<div id="connect">
<button id="btnConn">Connect</button>
&nbsp; State: <span id="connstate" style="font-weight:bold;"></span>
</div>
<script src="./mqttws31.js"></script>
<script>
var ws;
if (!window.WebSocket) {
alert("WebSocket not supported by this browser");
}
function $(id) {
return document.getElementById(id);
}
// Create a client instance
client = new Paho.MQTT.Client(location.hostname, Number(location.port), "/mqtt/wsocket", "clientId");
// set callback handlers
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
function go() {
// connect the client
client.connect({onSuccess:onConnect});
}
// called when the client connects
function onConnect() {
alert("connected"),
// Once a connection has been made, make a subscription and send a message.
console.log("onConnect");
client.subscribe("/World");
message = new Paho.MQTT.Message("Hello");
message.destinationName = "/World";
client.send(message);
}
// called when the client loses its connection
function onConnectionLost(responseObject) {
if (responseObject.errorCode !== 0) {
console.log("onConnectionLost:"+responseObject.errorMessage);
}
}
// called when a message arrives
function onMessageArrived(message) {
console.log("onMessageArrived:"+message.payloadString);
}
$('btnConn').onclick = function(event) {
go(); return false;
};
</script>
</body>
</html>

2143
apps/emqttd/priv/www/mqttws31.js Normal file
View File

File diff suppressed because it is too large Load Diff

0
apps/emqttd/priv/www/index.html → apps/emqttd/priv/www/websocket.html
View File

3
apps/emqttd/src/emqttd_http.erl
View File

@ -75,7 +75,8 @@ handle(_Method, "/mqtt/wsocket", Req) ->
Req:respond({400, [], <<"Bad Request">>}) Req:respond({400, [], <<"Bad Request">>})
end; end;
handle('GET', "/mqtt/" ++ File, Req) -> handle('GET', "/" ++ File, Req) ->
lager:info("GET File: ~s", [File]),
mochiweb_request:serve_file(File, docroot(), Req); mochiweb_request:serve_file(File, docroot(), Req);
handle(_Method, _Path, Req) -> handle(_Method, _Path, Req) ->