1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
/* eslint-disable */
import { Message } from "element-ui"
import EventBus from '@/utils/bus'
export default function socket(handlerOptions) {
let {
onmessage,
onopen,
// socketUrl
} = handlerOptions
let socketUrl = 'ws://8.142.143.40:8885/websocket/1/1'
let websocket
if ("WebSocket" in window) {
websocket = new WebSocket(socketUrl)
} else {
Message.warning("当前浏览器不支持WebSocket推送，请升级浏览器")
}
let heart = heartCheck(websocket)
websocket.onerror = function() {
console.info("Websocket服务器连接错误")
}
//连接成功建立的回调方法
websocket.onopen = function() {
console.info("Websocket连接成功")
console.log(websocket.readyState);
heart.start()
onopen && onopen()
}
//接收到消息的回调方法
websocket.onmessage = function(event) {
let message = event.data //消息内容
heart.reset() //重置心跳上传时间
onmessage && onmessage(message) //消息业务处理
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function() {
websocket.close()
}
return websocket
}
function heartCheck(websocket) {
return {
timeout: 15000,
timeoutObj: null,
reset: function() {
clearTimeout(this.timeoutObj)
this.start()
},
start: function() {
this.timeoutObj = setInterval(function() {
// if(websocket.readyState==1){
websocket.send("HeartBeat")
console.info("Websocket发送心跳：HeartBeat")
// }
}, this.timeout)
},
}
}
//消息处理
export function receiveMessage(message) {
// 消息接收后处理逻辑 接口访问
console.log(message, '接收到的信息');
EventBus.$emit('dialogAlarm', true)
// let obj = JSON.parse(message)
// return obj
}