VUE+WebSocket实现实时推送
data() {return {id: 1,webSock: null,lockReconnect: false, //避免重复连接}
},
mounted() {// 调取websocket方法 写在mounted方法中this.initWebSocket()
},
methods: {// 发送websockwt请求initWebSocket() {let websocketUrl = 'ws://192.168.3.52:6078/bolt'// WebSocket与普通的请求所用协议有所不同,ws等同于http,wss等同于httpsthis.webSock = new WebSocket(websocketUrl)this.webSock.onopen = this.webSocketOnOpenthis.webSock.onerror = this.webSocketOnErrorthis.webSock.onmessage = this.webSocketOnMessagethis.webSock.onclose = this.webSocketClose},webSocketOnOpen() {console.log('WebSocket连接成功')// 传递参数 不需要传参就不传this.webSocketSend(this.id)},webSocketOnMessage(e) {//接收数据console.log('WebSocket 接受数据')console.log(e)将接收的数据转为json格式var jsonObj = JSON.parse(e.data)console.log(jsonObj)},webSocketClose(e) {console.log('断开连接', e)this.lockReconnect = falsethis.reconnect()},webSocketOnError(e) {console.log('报错信息', e)},webSocketSend(Data) {//发送数据发送this.webSock.send(Data)},// 断开重连操作reconnect() {if (this.lockReconnect) returnthis.lockReconnect = truelet _this = this//没连接上会一直重连,设置延迟避免请求过多setTimeout(function () {_this.initWebSocket()_this.lockReconnect = false// _this.isOne = 1;}, 2000)},
}
VUE+WebSocket实现实时推送
data() {return {id: 1,webSock: null,lockReconnect: false, //避免重复连接}
},
mounted() {// 调取websocket方法 写在mounted方法中this.initWebSocket()
},
methods: {// 发送websockwt请求initWebSocket() {let websocketUrl = 'ws://192.168.3.52:6078/bolt'// WebSocket与普通的请求所用协议有所不同,ws等同于http,wss等同于httpsthis.webSock = new WebSocket(websocketUrl)this.webSock.onopen = this.webSocketOnOpenthis.webSock.onerror = this.webSocketOnErrorthis.webSock.onmessage = this.webSocketOnMessagethis.webSock.onclose = this.webSocketClose},webSocketOnOpen() {console.log('WebSocket连接成功')// 传递参数 不需要传参就不传this.webSocketSend(this.id)},webSocketOnMessage(e) {//接收数据console.log('WebSocket 接受数据')console.log(e)将接收的数据转为json格式var jsonObj = JSON.parse(e.data)console.log(jsonObj)},webSocketClose(e) {console.log('断开连接', e)this.lockReconnect = falsethis.reconnect()},webSocketOnError(e) {console.log('报错信息', e)},webSocketSend(Data) {//发送数据发送this.webSock.send(Data)},// 断开重连操作reconnect() {if (this.lockReconnect) returnthis.lockReconnect = truelet _this = this//没连接上会一直重连,设置延迟避免请求过多setTimeout(function () {_this.initWebSocket()_this.lockReconnect = false// _this.isOne = 1;}, 2000)},
}