1、通信协议要增加版本号（目的为远程升级准备），原来没有版本号的协议默认为版本号为1，所以调整了程序命名； 2、流浪控制器与控制器数据库表都增加了协议...

liurunyu

2024-11-01 001f24d4efd7b818bc2224b976c82faf4f9e564c

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

@@ -124,6 +124,27 @@
         return null ;
      }
   }

   /**
    * 得到所有在线与离线数量统计
    * @return [0]=在线数量，[2]上线过，但当前离线的数量
    */
   public static Integer[] allOnLineStateStatistics(){
      synchronized (sessionTable){
         Integer[] arr = new Integer[]{0, 0} ;
         Iterator<Entry<String, TcpSession>> it = sessionTable.entrySet().iterator() ;
         Entry<String, TcpSession> entry = null ;
         while(it.hasNext()){
            entry = it.next() ;
            if(entry.getValue().ioSession.isConnected()){
               arr[0]++ ;
            }else{
               arr[1]++ ;
            }
         }
         return arr ;
      }
   }
   
   /**
    * 得到所有在线情况
@@ -141,6 +162,25 @@
         return map ;
      }
   }


   /**
    * 得到部分在线情况
    * @return
    */
   public static HashMap<String, Boolean> partOnLine(String[] rtuAddrArrGrp){
      synchronized (sessionTable){
         HashMap<String, Boolean> map = new HashMap<String, Boolean>();
         for(String rtuAddr : rtuAddrArrGrp){
            TcpSession tcpSe = sessionTable.get(rtuAddr) ;
            if(tcpSe != null){
               map.put(rtuAddr, tcpSe.ioSession.isConnected()) ;
            }
         }
         return map ;
      }
   }

   /**
    * 得到所有RTU连接状态情况
    * @return