停掉转发..

潘钊
1 parent 0d4cbfc4
Showing 1 changed file with 10 additions and 10 deletions
src/main/java/com/bsth/client/ClientApp.java
@@ -32,7 +32,7 @@ import java.util.concurrent.*;
 public class ClientApp implements CommandLineRunner{
     private static NioSocketConnector pdDataConnector;
-    private static NioSocketConnector pfDataConnector;
+    //private static NioSocketConnector pfDataConnector;
     @Autowired
     private PdClientHandler pdClient;
@@ -91,7 +91,7 @@ public class ClientApp implements CommandLineRunner{
         });
     }
-    public static void pfconnect(final String device) {
+/*    public static void pfconnect(final String device) {
         exec.submit(new Runnable() {
             @Override
@@ -105,15 +105,15 @@ public class ClientApp implements CommandLineRunner{
                 System.out.println("重连, cost time: " + (System.currentTimeMillis() - now));
             }
         });
-    }
+    }*/
     public static void pdreconn(){
         pdconnect(ConfigUtil.get("forward.device.name"));
     }
-    public static void pfreconn(){
+    /*public static void pfreconn(){
         pfconnect(ConfigUtil.get("forward.device.name"));
-    }
+    }*/
     public void destroy(){
         try {
@@ -122,7 +122,7 @@ public class ClientApp implements CommandLineRunner{
             sexec.shutdownNow();
             pdDataConnector.dispose(true);
-            pfDataConnector.dispose(true);
+            //pfDataConnector.dispose(true);
         } catch (Exception e) {
             logger.error("", e);
         }
@@ -137,7 +137,7 @@ public class ClientApp implements CommandLineRunner{
         pfSession.closeNow();
     }
-    public static boolean fconnect(String device) {
+/*    public static boolean fconnect(String device) {
         boolean flag = false;
         try {
             ConnectFuture con = pfDataConnector.connect(new InetSocketAddress(ConfigUtil.get("gps.server.pf"),  Integer.parseInt(ConfigUtil.get("gps.port.pf"))));
@@ -152,7 +152,7 @@ public class ClientApp implements CommandLineRunner{
             e.printStackTrace();
         }
         return flag;
-    }
+    }*/
     public void init() {
         logger.warn("socket client init...");
@@ -231,10 +231,10 @@ public class ClientApp implements CommandLineRunner{
                     ClientApp.pdreconn();
                 }
-                if(!pfSession.isActive()){
+                /*if(!pfSession.isActive()){
                     logger.warn("浦东转发设备注销");
                     ClientApp.pfreconn();
-                }
+                }*/
             } catch (Exception e) {
                 logger.error("SessionChecker异常", e);
             }