|  |  |  | 
|---|
|  |  |  | 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()):"")) ); | 
|---|