| | |
| | | public void sessionOpened(IoSession session) throws Exception { |
| | | log.info("网络连接建立,终端网址是:" + session.getRemoteAddress().toString()) ; |
| | | if(session != null) { |
| | | String rtuAddr = (String) session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey); |
| | | String rtuAddr = (String) session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr); |
| | | if(rtuAddr != null && !rtuAddr.trim().equals("")){ |
| | | RtuLogDealer.log(rtuAddr, "网络接入"); |
| | | } |
| | |
| | | @Override |
| | | public void sessionClosed(IoSession session) throws Exception { |
| | | if(session != null){ |
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ; |
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr) ; |
| | | |
| | | if(rtuAddr != null && !rtuAddr.trim().equals("")){ |
| | | //记录状态 |
| | |
| | | */ |
| | | public void exceptionCaught(IoSession session, Throwable cause) throws Exception { |
| | | if(session != null && cause != null){ |
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ; |
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr) ; |
| | | log.error("网络会话发生异常," |
| | | + (rtuAddr==null?"":("终端地址是:" + rtuAddr)) |
| | | + (session==null?"":(session.getRemoteAddress() != null?(",终端网址是:" + session.getRemoteAddress().toString()):"")) |
| | |
| | | * TCP通道发送完数据后,回调的方法,进行后续数据处理 |
| | | */ |
| | | public void messageSended(IoSession session, Object message) throws Exception { |
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ; |
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr) ; |
| | | log.info("网络发送了数据," |
| | | + (rtuAddr==null?"":("终端地址是:" + rtuAddr)) |
| | | + (session==null?"":(session.getRemoteAddress() != null?(",终端网址是:" + session.getRemoteAddress().toString()):"")) ); |