| | |
| | | InetSocketAddress socketAddress = (InetSocketAddress) ctx.channel().remoteAddress(); |
| | | |
| | | log.info("连接终端掉线,IP={},port={}", socketAddress.getAddress(), socketAddress.getPort()); |
| | | |
| | | //ClientEngine.defaultChannel = null; |
| | | |
| | | } |
| | | |
| | |
| | | msgStr+= strMsg; |
| | | |
| | | if(msgStr.endsWith("AABBCC")){ |
| | | |
| | | log.info("消息接收完整开始解析,IP={},port={},msg={}", socketAddress.getAddress(), socketAddress.getPort(), msgStr); |
| | | |
| | | if (null == analysisService) { |
| | |
| | | }catch (Exception e){ |
| | | log.error(e.getMessage(),e); |
| | | } |
| | | |
| | | msgStr = ""; |
| | | }else{ |
| | | log.info("消息不完整,等待消息完整,IP={},port={},msg={}", socketAddress.getAddress(), socketAddress.getPort(), strMsg); |
| | | |