mqtt.zip_mqtt_mqtt客户端_Websocket编程

<!DOCTYPE html > <html lang="zh"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1"> <title>MQTT Debug</title> <link href="css/mui.min.css" rel="stylesheet"> <script src="js/jquery-1.11.0.js"></script> <script src="js/mui.min.js"></script> <script src="js/bmqtt.js"></script> <script src="/socket.io/socket.io.js"></script>  <style> .myform { margin-top: 15px; } #mqtt-log-containor { height: 80%; width: 100%; margin-top: 15px; /*background: #000;*/ /*color:green;*/ } #mqtt-log { width: 100%; height: 600px; overflow: auto; } #clear { color: white; } </style> </head> <body> <div class="container" style="padding: 20px"> <div class="well well-lg">MQTT Client</div> <form class="form-inline"> <div class="form-group"> <label class="sr-only" for="mqtt-host">MQTT Host</label> <input type="text" class="form-control" id="mqtt-host" placeholder="MQTT Host"> </div> <div class="form-group"> <label class="sr-only" for="mqtt-port">MQTT Port</label> <input type="text" class="form-control" id="mqtt-port" placeholder="MQTT Port"> </div> <button type="button" class="btn btn-primary" id="connectBtn">连接</button> <button type="button" class="btn btn-danger" id="disconnectBtn">断开</button> </form> <div class="myform" id="subscribe"> <form class="form-inline"> <div class="form-group"> <label class="sr-only" for="mqtt-host">MQTT Host</label> <input type="text" class="form-control" id="mqtt-topic" placeholder="MQTT Topic"> </div> <button type="button" class="btn btn-success" id="subscribeBtn">订阅</button> <button type="button" class="btn btn-warning" id="unsubscribeBtn">退订</button> </form> </div> <div class="panel panel-success" id="mqtt-log-containor"> <div class="panel-heading"> <span class="label label-info">日志</span>  <span class="label label-danger"><a id="clear" rel='nofollow' onclick='return false;'>Clear</a></span> </div> <div class="panel-body" id="mqtt-log"></div> </div> </div> <script> //var client; var topic = []; topic[0] = "jjy_xianxia_少珍"; topic[1] = "10000001_xiazai"; // var mqtt = require('mqtt'); var client = mqtt.connect('ws://120.192.167.84:3000'); console.log("klklkl") client.on('connect', function() { console.log("oooppp") client.subscribe(topic); }); client.on('message', function(topic, message) { // message is Buffer console.log("topic==" + topic) mui.toast(message.toString()) console.log("message=" + message.toString()); //client.end(); }); document.getElementById('connectBtn').addEventListener('tap', function() { client.publish("jjy_xianxia_少珍", 'Hello 线下消费'); }) document.getElementById('disconnectBtn').addEventListener('tap', function() { client.publish("10000001_xiazai", 'Hello pdf推送'); }) </script> </body> </html>