<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title></title>
</head>
<body>
<script src="mqttws31.min.js" type="text/javascript"></script>
<script>
client = new Paho.MQTT.Client("MQTT_IP", Number(61614),'/',"clientId-c2471054-a703-4edc-b7dd-c7ed7b19072a");
client.connect({
useSSL: false,
onSuccess: onConnect
}); //连接服务器并注册连接成功处理事件
function onConnect() {
console.log("onConnected");
client.subscribe("/ID0003/0001/updata/"); //订阅主题
}
client.onConnectionLost = onConnectionLost; //注册连接断开处理事件
client.onMessageArrived = onMessageArrived; //注册消息接收处理事件
function onConnectionLost(responseObject) {
if(responseObject.errorCode !== 0) {
console.log("onConnectionLost:" + responseObject.errorMessage);
console.log("连接已断开");
}
}
function onMessageArrived(message) {
msg = message.payloadString;
console.log("收到消息:" + msg);
parseMsg(msg);
}
//发送消息
message = new Paho.MQTT.Message("hello");
message.destinationName = "/topic";
// client.send(message);
function parseMsg(msg) {
//msg="@push-status-14760836-200021200#r";
re = /@([a-z]{1,6})-([a-z]{1,6})-([w]{8,32})-([012]{1,})#/;
if(re.test(msg)) {
console.log("true");
msg = msg.replace('@', '').replace('#', '').replace('r', '').replace('n', '');
console.log("msg:" + msg);
msg = msg.split("-");
if(msg.length == 4) {
console.log("msg[0]:" + msg[0]);
console.log("msg[1]:" + msg[1]);
console.log("msg[2]:" + msg[2]);
console.log("msg[3]:" + msg[3]);
}
} else {
console.log("false");
}
}
</script>
</body>
</html>
