正在显示
4 个修改的文件
包含
14 行增加
和
5 行删除
此 diff 太大无法显示。
| @@ -27,7 +27,7 @@ import Server from "config/Server"; | @@ -27,7 +27,7 @@ import Server from "config/Server"; | ||
| 27 | import UTF8 from 'utf-8'; | 27 | import UTF8 from 'utf-8'; |
| 28 | 28 | ||
| 29 | let loger = Loger.getLoger('McuClient'); | 29 | let loger = Loger.getLoger('McuClient'); |
| 30 | -let _sdkInfo = {"version": "v1.9.15.20170420", "author": "www.3mang.com"}; | 30 | +let _sdkInfo = {"version": "v1.9.16.20170420", "author": "www.3mang.com"}; |
| 31 | 31 | ||
| 32 | //APE | 32 | //APE |
| 33 | let _sass; | 33 | let _sass; |
| @@ -39,7 +39,11 @@ class EverSocket extends Emiter { | @@ -39,7 +39,11 @@ class EverSocket extends Emiter { | ||
| 39 | this._clear(); | 39 | this._clear(); |
| 40 | } | 40 | } |
| 41 | switchSocketIp(ip,port) { | 41 | switchSocketIp(ip,port) { |
| 42 | + if(port){ | ||
| 42 | this.wsURL = 'ws://' + ip + ':' + port; | 43 | this.wsURL = 'ws://' + ip + ':' + port; |
| 44 | + }else { | ||
| 45 | + this.wsURL = 'ws://' + ip; | ||
| 46 | + } | ||
| 43 | } | 47 | } |
| 44 | get connected() { | 48 | get connected() { |
| 45 | return this._connected; | 49 | return this._connected; |
| @@ -81,13 +85,13 @@ class EverSocket extends Emiter { | @@ -81,13 +85,13 @@ class EverSocket extends Emiter { | ||
| 81 | window.clearTimeout(this.reConnectionTimeout); | 85 | window.clearTimeout(this.reConnectionTimeout); |
| 82 | this.reConnectionCounter++; | 86 | this.reConnectionCounter++; |
| 83 | if (this.reConnectionCounter > MCU_MAX_RECONNECTION) { | 87 | if (this.reConnectionCounter > MCU_MAX_RECONNECTION) { |
| 84 | - loger.warn('已经达到最大重连次数!'); | 88 | + loger.warn('MCU断线重连->已经达到最大重连次数!'); |
| 85 | this._emit(EverSocket.ERROR, EverSocket.ERR_SOCKET_RECONNECT_FAILED); | 89 | this._emit(EverSocket.ERROR, EverSocket.ERR_SOCKET_RECONNECT_FAILED); |
| 86 | this.reConnectionCounter=0; | 90 | this.reConnectionCounter=0; |
| 87 | } | 91 | } |
| 88 | 92 | ||
| 89 | this.reConnectionTimeout = window.setTimeout(() => { | 93 | this.reConnectionTimeout = window.setTimeout(() => { |
| 90 | - loger.log('WebSocket重新建立->', this.reConnectionCounter); | 94 | + loger.log('MCU断线重连->', this.reConnectionCounter); |
| 91 | window.clearTimeout(this.reConnectionTimeout); | 95 | window.clearTimeout(this.reConnectionTimeout); |
| 92 | this._newConnection(); | 96 | this._newConnection(); |
| 93 | }, EverSocket.RECONN_INTERVAL); | 97 | }, EverSocket.RECONN_INTERVAL); |
| @@ -39,13 +39,18 @@ class MCU extends Emiter { | @@ -39,13 +39,18 @@ class MCU extends Emiter { | ||
| 39 | 39 | ||
| 40 | // EverSocket连接断开 | 40 | // EverSocket连接断开 |
| 41 | _everSocketCloseHandler() { | 41 | _everSocketCloseHandler() { |
| 42 | + //如果已经是断开状态,不需要多次发送异常消息 | ||
| 43 | + if (GlobalConfig.getCurrentStatus().code == GlobalConfig.statusCode_3.code) { | ||
| 44 | + loger.warn('已经断开连接->'); | ||
| 45 | + return; | ||
| 46 | + } | ||
| 42 | GlobalConfig.setCurrentStatus(GlobalConfig.statusCode_3); | 47 | GlobalConfig.setCurrentStatus(GlobalConfig.statusCode_3); |
| 43 | this._emit(MessageTypes.MCU_ERROR, MessageTypes.ERR_SOCKET_DISCONNECT); | 48 | this._emit(MessageTypes.MCU_ERROR, MessageTypes.ERR_SOCKET_DISCONNECT); |
| 44 | } | 49 | } |
| 45 | 50 | ||
| 46 | //EverSocket错误异常 | 51 | //EverSocket错误异常 |
| 47 | _everSocketErrorHandler(_errorCode) { | 52 | _everSocketErrorHandler(_errorCode) { |
| 48 | - this._emit(MessageTypes.MCU_ERROR, _errorCode); | 53 | + //this._emit(MessageTypes.MCU_ERROR, _errorCode); |
| 49 | //如果自动重连次数已经达到最大值,重新选点 | 54 | //如果自动重连次数已经达到最大值,重新选点 |
| 50 | if (_errorCode == everSocket.ERR_SOCKET_RECONNECT_FAILED) { | 55 | if (_errorCode == everSocket.ERR_SOCKET_RECONNECT_FAILED) { |
| 51 | this._emit(MessageTypes.SWITCH_MCU_IP); | 56 | this._emit(MessageTypes.SWITCH_MCU_IP); |
| @@ -224,7 +229,7 @@ class MCU extends Emiter { | @@ -224,7 +229,7 @@ class MCU extends Emiter { | ||
| 224 | switchMCUIp(_classInfo) { | 229 | switchMCUIp(_classInfo) { |
| 225 | if (_classInfo && _classInfo.MCUServerIP) { | 230 | if (_classInfo && _classInfo.MCUServerIP) { |
| 226 | this.classInfo.MCUServerIP = _classInfo.MCUServerIP; | 231 | this.classInfo.MCUServerIP = _classInfo.MCUServerIP; |
| 227 | - this.classInfo.MCUServerPort = _classInfo.MCUServerIP; | 232 | + this.classInfo.MCUServerPort = _classInfo.MCUServerPort; |
| 228 | if (this._everSocket) { | 233 | if (this._everSocket) { |
| 229 | this._everSocket.switchSocketIp(this.classInfo.MCUServerIP, this.classInfo.MCUServerPort); | 234 | this._everSocket.switchSocketIp(this.classInfo.MCUServerIP, this.classInfo.MCUServerPort); |
| 230 | } | 235 | } |
-
请 注册 或 登录 后发表评论