1、通信中间件中，实现停止TCP服务和恢复TCP服务功能， 2、测试系统中增加本功能的测试项。

liurunyu

2024-07-29 e7d48d79b04175165144f4c8b079f2da3fec63cb

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

@@ -13,11 +13,11 @@
   
   
   public static void onOffLine(RtuSessionStatus sta){
      StOnOffLine st = new StOnOffLine() ;
      st.rtuAddr = sta.rtuAddr ;
      st.onOff_trueFalse = sta.onTrueOffLine ;
      st.ip = sta.ip ;
      st.port = sta.port ;
//      StOnOffLine st = new StOnOffLine() ;
//      st.rtuAddr = sta.rtuAddr ;
//      st.onOff_trueFalse = sta.onTrueOffLine ;
//      st.ip = sta.ip ;
//      st.port = sta.port ;
      
//      if(member == null){
//         log.error("出错，未能得到处理RTU（地址为" + sta.rtuAddr + "）状态数据的数据中间件，可能数据中间件未启动或脱离的集群！");
@@ -28,11 +28,11 @@
   }
   
   public static void onLine(String rtuAddr, String ip, Integer port){
      StOnOffLine st = new StOnOffLine() ;
      st.rtuAddr = rtuAddr ;
      st.onOff_trueFalse = true ;
      st.ip = ip ;
      st.port = port ;
//      StOnOffLine st = new StOnOffLine() ;
//      st.rtuAddr = rtuAddr ;
//      st.onOff_trueFalse = true ;
//      st.ip = ip ;
//      st.port = port ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -44,9 +44,9 @@
   }
   
   public static void offLine(String rtuAddr){
      StOnOffLine st = new StOnOffLine() ;
      st.rtuAddr = rtuAddr ;
      st.onOff_trueFalse = false ;
//      StOnOffLine st = new StOnOffLine() ;
//      st.rtuAddr = rtuAddr ;
//      st.onOff_trueFalse = false ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -58,10 +58,10 @@
   }
   
   public static void upData(String rtuAddr, Integer bufferLen){
      StUpData st = new StUpData() ;
      st.rtuAddr = rtuAddr ;
      st.upBufferLen = bufferLen ;
      st.isReport = false ;
//      StUpData st = new StUpData() ;
//      st.rtuAddr = rtuAddr ;
//      st.upBufferLen = bufferLen ;
//      st.isReport = false ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -73,10 +73,10 @@
   }
   
   public static void upReport(String rtuAddr, Integer bufferLen){
      StUpData st = new StUpData() ;
      st.rtuAddr = rtuAddr ;
      st.upBufferLen = bufferLen ;
      st.isReport = true ;
//      StUpData st = new StUpData() ;
//      st.rtuAddr = rtuAddr ;
//      st.upBufferLen = bufferLen ;
//      st.isReport = true ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -88,9 +88,9 @@
   }
   
   public static void downData(String rtuAddr, Integer bufferLen){
      StDownData st = new StDownData() ;
      st.rtuAddr = rtuAddr ;
      st.downBufferLen = bufferLen ;
//      StDownData st = new StDownData() ;
//      st.rtuAddr = rtuAddr ;
//      st.downBufferLen = bufferLen ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -102,9 +102,9 @@
   }
   
   public static void commandSuccess(String rtuAddr){
      StCommandResult st = new StCommandResult() ;
      st.rtuAddr = rtuAddr ;
      st.isSuccess = true ;
//      StCommandResult st = new StCommandResult() ;
//      st.rtuAddr = rtuAddr ;
//      st.isSuccess = true ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -116,9 +116,9 @@
   }
   
   public static void commandFailure(String rtuAddr){
      StCommandResult st = new StCommandResult() ;
      st.rtuAddr = rtuAddr ;
      st.isSuccess = false ;
//      StCommandResult st = new StCommandResult() ;
//      st.rtuAddr = rtuAddr ;
//      st.isSuccess = false ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){
@@ -130,9 +130,9 @@
   }
   
   public static void commandFail2Success(String rtuAddr){
      StCommandResult st = new StCommandResult() ;
      st.rtuAddr = rtuAddr ;
      st.fail2Success = true ;
//      StCommandResult st = new StCommandResult() ;
//      st.rtuAddr = rtuAddr ;
//      st.fail2Success = true ;
      
//      Address member = JgUnit.getInstance().getJgMembers().getDataMwMemberByRtuAddr(rtuAddr) ;
//      if(member == null){