实时通信

store/websocketStore.js

@@ -23,29 +23,16 @@ const store = new Vuex.Store({
 					console.log('WebSocket连接成功！')
 				},
 				fail: e => {
+					setTimeout(() => {
+						dispatch('websocketInit', url)
+					}, 3000)
 					console.log('连接失败' + e)
 				}
 			})
 			state.socketTask.onOpen(() => dispatch('websocketOnOpen'))
 			state.socketTask.onMessage(res => dispatch('websocketOnMessage', res))
-			state.socketTask.onClose(res => {
-				state.socketTask == null
-				state.socketTask = uni.connectSocket({
-					url, // url是websocket连接ip
-					success: () => {
-						console.log('WebSocket连接成功！')
-					},
-					fail: e => {
-						console.log('连接失败' + e)
-					}
-				})
-				console.log('WebSocket连接关闭')
-			});
-			state.socketTask.onError(res => {
-				state.socketTask == null
-				console.log('WebSocket连接错误')
-			});
-
+			state.socketTask.onClose(e => dispatch('websocketOnClose', url));
+			state.socketTask.onError(e => dispatch('websocketOnError', url));
 		},
 		websocketOnOpen({
 			commit
@@ -70,13 +57,19 @@ const store = new Vuex.Store({
 		websocketOnClose({
 			commit,
 			dispatch
-		}) {
+		}, url) {
+			setTimeout(() => {
+				dispatch('websocketInit', url)
+			}, 3000)
 			console.log('WebSocket连接关闭')
 		},
 		websocketOnError({
 			commit,
 			dispatch
-		}) {
+		}, url) {
+			setTimeout(() => {
+				dispatch('websocketInit', url)
+			}, 3000)
 			console.log('WebSocket连接错误')
 		},
 		websocketClose({