From 7d91779d2bb2bfec7f4f803a9e2cf65b90e401c6 Mon Sep 17 00:00:00 2001 From: 819527061@qq.com <123456> Date: 星期二, 25 六月 2024 15:23:37 +0800 Subject: [PATCH] soket --- store/index.js | 29 ++++++++++++++++++----------- 1 files changed, 18 insertions(+), 11 deletions(-) diff --git a/store/index.js b/store/index.js index a7eed82..e283eaa 100644 --- a/store/index.js +++ b/store/index.js @@ -220,7 +220,11 @@ state.globalisLogin = payload console.log(state.globalisLogin, '鍏ㄥ眬鐧诲綍鐘舵�佹敼鍙樹簡') }, + changesocketTask(state, payload) { + state.socketTask = payload + }, setWebsocketData(state, data) { + console.log(data,'data-----') state.websocketData = data }, // 鏀瑰彉閲嶈繛鐘舵�� @@ -250,7 +254,7 @@ actions: { websocketInit({ state, dispatch, commit }) { let wsUrl = `${webSocketUrl}?access_token=${uni.getStorageSync('token')}` - state.socketTast = uni.connectSocket({ + state.socketTask = uni.connectSocket({ url: wsUrl, header: { CLIENT_TOC: 'Y' }, success: res => { @@ -268,17 +272,17 @@ } }) - state.socketTast.onOpen(() => dispatch('websocketOnOpen')) - state.socketTast.onMessage(result => dispatch('websocketOnMessage', result.data)) - state.socketTast.onClose(e => dispatch('websocketOnClose', e)) - state.socketTast.onError(e => dispatch('websocketOnError', e)) + state.socketTask.onOpen(() => dispatch('websocketOnOpen')) + state.socketTask.onMessage(result => dispatch('websocketOnMessage', result.data)) + state.socketTask.onClose(e => dispatch('websocketOnClose', e)) + state.socketTask.onError(e => dispatch('websocketOnError', e)) }, websocketOnOpen({ state, commit }) { console.log('ws鎵撳紑') clearInterval(state.reconnectTimeOut) clearInterval(state.globalIntervalId) state.globalIntervalId = setInterval(() => { - state.socketTast.send({ + state.socketTask.send({ data: JSON.stringify({ type: 'ping' }), success(e) { console.log(e, '鍙戦�佸績璺虫垚鍔�') @@ -287,14 +291,14 @@ }, 30000) }, websocketOnClose({ state, commit, dispatch }, e) { - if (!state.socketTast) return + if (!state.socketTask) return console.log('ws鍏抽棴', e) - state.socketTast.close(e => { + state.socketTask.close(e => { commit('changeisconnect', false) }) clearInterval(state.globalIntervalId) clearInterval(state.reconnectTimeOut) - state.socketTast = null + state.socketTask = null commit('changereconnectState', false) if (state.connectNum <= 6 && state.globalisLogin) { uni.showToast({ @@ -318,7 +322,7 @@ console.log('ws鎶ラ敊', e) clearInterval(state.globalIntervalId) clearInterval(state.reconnectTimeOut) - state.socketTast = null + state.socketTask = null commit('changereconnectState', false) if (state.connectNum < 6 && state.globalisLogin) { uni.showToast({ @@ -351,7 +355,10 @@ }, 5000) } } + }, + getters: { + websocketData:(state) => state.websocketData } }) -export default store \ No newline at end of file +export default store -- Gitblit v1.9.1