// WebSocket接收消息推送 var ws_url="ws://"+tailIp+"/vmw/webSocket" function openSocket(){ $.ajax({ type : 'post', url : dataUrl + 'abnormal/getAbnormalData', success : function(data) { console.log("数据",data); $("#outText").text(data[0].name+"于"+data[0].time+data[0].content); // location.href = ctxPath + '/index.html'; }, error : function(xhr, textStatus, errorThrown) { var msg = xhr.responseText; var response = JSON.parse(msg); var code = response.code; var message = response.message; if (code == 401) { localStorage.removeItem("token"); } } }); } function sleep(numberMillis) { var now = new Date(); var exitTime = now.getTime() + numberMillis; while (true) { now = new Date(); if (now.getTime() > exitTime) return; } } function oo(userId) { console.log(userId); if (typeof WebSocket == "undefined") { console.log("您的浏览器不支持WebSocket"); } else { var socketUrl = ws_url+"/"+userId; if (this.socket != null) { this.socket.close(); this.socket = null; } try{ this.socket = new WebSocket(socketUrl); }catch (e) { console.log(e.message) } // 打开事件 this.socket.onopen = function () { console.log("websocket已打开"); }; // 获得消息事件 const _this = this this.socket.onmessage = function (msg) { $("#outText").text(msg.data); // console.log(msg.data);//输出从后台接收的信息:“发送测试信息” // _this.todoSomeThing(55)//接收后台发送的请求,主动调用相应的业务接口 }; // 关闭事件 this.socket.onclose = function (e) { console.log("websocket已关闭"); }; // 发生了错误事件 this.socket.onerror = function (e) { console.log(e.message) console.log(e) console.log('websocket发生了错误,错误: ') console.log(e) }; } }