使用場景: 在項目開發中,後端需要處理一連串的邏輯,或者等待第三方的數據返回來進行處理之後在返回給前端,可能時間會很長,而且前端也不知道後端什麼時候能處理好(時間長的話會達到10分鐘左右),如果採用普通的HTTP連接,前後端無法一直保持聯繫,麻煩的時候可能還需要採用輪詢的機制,所以使用WebSock ...
使用場景:
在項目開發中,後端需要處理一連串的邏輯,或者等待第三方的數據返回來進行處理之後在返回給前端,可能時間會很長,而且前端也不知道後端什麼時候能處理好(時間長的話會達到10分鐘左右),如果採用普通的HTTP連接,前後端無法一直保持聯繫,麻煩的時候可能還需要採用輪詢的機制,所以使用WebSocket連接效果還是比較好的。
使用時間:
在界面載入完之後,建上WebSocket連接,此時前端還可以發送普通的HTTP的請求,等到後端處理完之後,通過建立的WebSocket連接返給前端,前端根據返回的數據進行對應的操作。
代碼展示:
<template>
</template>
<script>
export default {
data() {
return{
// 用戶Id
userId:'',
appid:'',
// 事件類型
type:'',
msg:'',
wsUrl:''
}
},
methods: {
//初始化weosocket
initWebSocket() {
if (typeof WebSocket === "undefined") {
alert("您的瀏覽器不支持WebSocket");
return false;
}
const wsuri = 'ws://(後端WebSocket地址)/websocket/' + this.userId + '/' + this.appid // websocket地址
this.websock = new WebSocket(wsuri);
this.websock.onopen = this.websocketonopen;
this.websock.onmessage = this.websocketonmessage;
this.websock.onerror = this.websocketonerror;
this.websock.onclose = this.websocketclose;
},
//連接成功
websocketonopen() {
console.log("WebSocket連接成功");
// 添加心跳檢測,每30秒發一次數據,防止連接斷開(這跟伺服器的設置有關,如果伺服器沒有設置每隔多長時間不發消息斷開,可以不進行心跳設置)
let self = this;
this.timer = setInterval(() => {
try {
self.websock.send('test')
console.log('發送消息');
}catch(err){
console.log('斷開了:' + err);
self.connection()
}
}, 30000)
},
//接收後端返回的數據,可以根據需要進行處理
websocketonmessage(e) {
var vm = this;
let data1Json = JSON.parse(e.data);
console.log(data1Json);
},
//連接建立失敗重連
websocketonerror(e) {
console.log(`連接失敗的信息:`, e);
this.initWebSocket(); // 連接失敗後嘗試重新連接
},
//關閉連接
websocketclose(e) {
console.log("斷開連接", e);
}
},
created() {
if (this.websock) {
this.websock.close(); // 關閉websocket連接
}
this.initWebSocket();
},
destroyed() {
//頁面銷毀時關閉ws連接
if (this.websock) {
this.websock.close(); // 關閉websocket
}
}
};
</script>
問題回顧:
在實際使用的時候遇到的問題:有的時候頁面鏈接還沒有建立上,但是後端已經把數據都處理好了,這個時候推給前端,前端接收不到。
解決方案:
1)簡單的方法:讓後端延遲幾秒再推
優勢:簡單
劣勢:降低了性能
2)優化之後的方法:使用Redis保存用戶的登錄狀態,緩存這個用戶的數據,等到建立連接之後再推,推完就清空Redis