pipIrr-SV.git - Gitblit

			@@ -19,8 +19,10 @@
			public void sessionOpened(IoSession session) throws Exception {
			log.info("网络连接建立，终端网址是：" + session.getRemoteAddress().toString()) ;
			if(session != null) {
			String rtuAddr = (String) session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey);
			RtuLogDealer.log(rtuAddr, "网络接入");
			String rtuAddr = (String) session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr);
			if(rtuAddr != null && !rtuAddr.trim().equals("")){
			RtuLogDealer.log(rtuAddr, "网络接入");
			}
			}
			}

			@@ -30,13 +32,13 @@
			@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){
			if(rtuAddr != null && !rtuAddr.trim().equals("")){
			//记录状态
			RtuStatusDealer.offLine(rtuAddr);
			RtuLogDealer.log(rtuAddr, "网络连接关闭");
			}
			RtuLogDealer.log(rtuAddr, "网络连接关闭");
			log.info("网络连接关闭，"
			+ (rtuAddr==null?"":("终端地址是：" + rtuAddr))) ;
			//+ (session==null?"":(session.getRemoteAddress() == null?"":(session.getRemoteAddress().toString()==null?"":("，终端网址是：" + session.getRemoteAddress().toString()))))) ;
			@@ -47,7 +49,7 @@
			*/
			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()):""))
			@@ -59,7 +61,7 @@
			* 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()):"")) );