MQTT协议 Websocket JS客户端
client = new ("服务器域名", Number(端口号), "客户端ID");//建立客户端实例
({onSuccess:onConnect});//连接服务器并注册连接成功处理事件
function onConnect() {
console.log("onConnected");
("/topic_back");//订阅主题
}
= onConnectionLost;//注册连接断开处理事件
= onMessageArrived;//注册消息接收处理事件
function onConnectionLost(responseObject) {
if ( !== 0) {
console.log("onConnectionLost:"+);
console.log("连接已断开");
}
}
function onMessageArrived(message) {
console.log("收到消息:"+);
}
//发送消息
message = new ("hello");
= "/topic";
client.send(message);