整理版本

zhubaomin

2025-04-07 1a2b07f01ba4616fd9e894dddf474b56d020158c

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpIoSessionCallback.java

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

   /**
@@ -26,16 +32,16 @@
   @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, "网络连接关闭");
           }

          log.info("网络连接关闭，"
                + (rtuAddr==null?"":("终端地址是：" + rtuAddr))) ;
                //+ (session==null?"":(session.getRemoteAddress() == null?"":(session.getRemoteAddress().toString()==null?"":("终端网址是：" + session.getRemoteAddress().toString()))))) ;
                //+ (session==null?"":(session.getRemoteAddress() == null?"":(session.getRemoteAddress().toString()==null?"":("，终端网址是：" + session.getRemoteAddress().toString()))))) ;
      }
    }
   /**
@@ -43,10 +49,10 @@
     */
    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()):""))
                + (session==null?"":(session.getRemoteAddress() != null?("，终端网址是：" + session.getRemoteAddress().toString()):""))
                + "\n异常消息：" + cause.getMessage(), cause);
       }
    }
@@ -55,10 +61,10 @@
     * 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()):"")) );
             + (session==null?"":(session.getRemoteAddress() != null?("，终端网址是：" + session.getRemoteAddress().toString()):"")) );
    }

    /**