|
|
@@ -5,38 +5,38 @@ let messageCallback = null
|
|
|
let errorCallback = null
|
|
|
let wsUrl = process.env.SOCKET_Url
|
|
|
let tryTime = 0
|
|
|
-
|
|
|
+
|
|
|
// 接收ws后端返回的数据
|
|
|
-function websocketonmessage (e) {
|
|
|
+function websocketonmessage (e) {
|
|
|
messageCallback(JSON.parse(e.data))
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 发起websocket连接
|
|
|
* @param {Object} agentData 需要向后台传递的参数数据
|
|
|
*/
|
|
|
function websocketSend (agentData) {
|
|
|
- // 加延迟是为了尽量让ws连接状态变为OPEN
|
|
|
- setTimeout(() => {
|
|
|
+ // 加延迟是为了尽量让ws连接状态变为OPEN
|
|
|
+ setTimeout(() => {
|
|
|
// 添加状态判断，当为OPEN时，发送消息
|
|
|
- if (websock.readyState === websock.OPEN) { // websock.OPEN = 1
|
|
|
+ if (websock.readyState === websock.OPEN) { // websock.OPEN = 1
|
|
|
// 发给后端的数据需要字符串化
|
|
|
websock.send(JSON.stringify(agentData))
|
|
|
}
|
|
|
- if (websock.readyState === websock.CLOSED) { // websock.CLOSED = 3
|
|
|
+ if (websock.readyState === websock.CLOSED) { // websock.CLOSED = 3
|
|
|
console.log('websock.readyState=3')
|
|
|
- Message.error('ws连接异常，请稍候重试')
|
|
|
+ // Message.error('ws连接异常，请稍候重试')
|
|
|
errorCallback()
|
|
|
}
|
|
|
}, 500)
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
// 关闭ws连接
|
|
|
-function websocketclose (e) {
|
|
|
+function websocketclose (e) {
|
|
|
// e.code === 1000 表示正常关闭。 无论为何目的而创建, 该链接都已成功完成任务。
|
|
|
// e.code !== 1000 表示非正常关闭。
|
|
|
if (e && e.code !== 1000) {
|
|
|
- Message.error('ws连接异常，请稍候重试')
|
|
|
+ // Message.error('ws连接异常，请稍候重试')
|
|
|
errorCallback()
|
|
|
// // 如果需要设置异常重连则可替换为下面的代码，自行进行测试
|
|
|
// if (tryTime < 10) {
|
|
|
@@ -55,35 +55,35 @@ function websocketclose (e) {
|
|
|
function websocketOpen (e) {
|
|
|
// console.log('ws连接成功')
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
// 初始化weosocket
|
|
|
-function initWebSocket () {
|
|
|
+function initWebSocket () {
|
|
|
if (typeof (WebSocket) === 'undefined') {
|
|
|
Message.error('您的浏览器不支持WebSocket，无法获取数据')
|
|
|
return false
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
// const token = Cookies.get('token')
|
|
|
// // ws请求完整地址
|
|
|
// const requstWsUrl = wsUrl + '?' + token
|
|
|
// websock = new WebSocket(requstWsUrl)
|
|
|
websock = new WebSocket(wsUrl)
|
|
|
-
|
|
|
+
|
|
|
websock.onmessage = function (e) {
|
|
|
websocketonmessage(e)
|
|
|
- }
|
|
|
+ }
|
|
|
websock.onopen = function () {
|
|
|
websocketOpen()
|
|
|
}
|
|
|
websock.onerror = function () {
|
|
|
- Message.error('ws连接异常，请稍候重试')
|
|
|
+ // Message.error('ws连接异常，请稍候重试')
|
|
|
errorCallback()
|
|
|
}
|
|
|
websock.onclose = function (e) {
|
|
|
websocketclose(e)
|
|
|
- }
|
|
|
+ }
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 发起websocket请求函数
|
|
|
* @param {string} url ws连接地址
|
|
|
@@ -91,7 +91,7 @@ function initWebSocket () {
|
|
|
* @param {function} successCallback 接收到ws数据，对数据进行处理的回调函数
|
|
|
* @param {function} errCallback ws连接错误的回调函数
|
|
|
*/
|
|
|
-export function sendWebsocket (url, agentData, successCallback, errCallback) {
|
|
|
+export function sendWebsocket (url, agentData, successCallback, errCallback) {
|
|
|
|
|
|
wsUrl+=url
|
|
|
initWebSocket()
|
|
|
@@ -99,7 +99,7 @@ export function sendWebsocket (url, agentData, successCallback, errCallback) {
|
|
|
errorCallback = errCallback
|
|
|
websocketSend(agentData)
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 关闭websocket函数
|
|
|
*/
|
|
|
@@ -109,4 +109,3 @@ export function closeWebsocket () {
|
|
|
websock.onclose() // 关闭websocket
|
|
|
}
|
|
|
}
|
|
|
-
|
