update...

潘钊
1 parent a308a846
Showing 3 changed files with 46 additions and 5 deletions
src/main/java/com/bsth/data/gpsdata/client/ClientApp.java
src/main/java/com/bsth/data/gpsdata/client/pd/handler/PdClientHandler.java
src/main/java/com/bsth/data/gpsdata/client/pf/handler/PfClientHandler.java
@@ -21,6 +21,10 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
  
 import java.net.InetSocketAddress;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.TimeUnit;
  
 /**
  * Created by panzhao on 2017/5/4.
@@ -40,6 +44,17 @@ public class ClientApp {
  
     static Logger logger = LoggerFactory.getLogger(ClientApp.class);
  
+    private ScheduledExecutorService sexec = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
+
+        @Override
+        public Thread newThread(Runnable r) {
+            // TODO Auto-generated method stub
+            Thread t = new Thread(r);
+            t.setName("SessionCheckExecutor");
+            return t;
+        }
+    });
+
     public static boolean dconnect(String device) {
         boolean flag = false;
         try {
@@ -62,6 +77,7 @@ public class ClientApp {
             flag = true;
  
             logger.info("dconnect...");
+            pdSession = session;
             //SessionManager.getInstance().register(device, session);
         } catch (Exception e) {
             e.printStackTrace();
@@ -87,6 +103,7 @@ public class ClientApp {
             flag = true;
  
             logger.info("fconnect...");
+            pfSession = session;
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -95,7 +112,7 @@ public class ClientApp {
  
     public void init() {
         //exec = Executors.newFixedThreadPool(4);
-        //sexec.scheduleAtFixedRate(new SessionChecker(), 1, 1, TimeUnit.MINUTES);
+        sexec.scheduleAtFixedRate(new SessionChecker(), 1, 1, TimeUnit.MINUTES);
         /*******************************浦东********************************/
         pdDataConnector = new NioSocketConnector();
  
@@ -141,4 +158,30 @@ public class ClientApp {
  
         gpsBeforeBuffer.init();
     }
+
+
+    static IoSession pdSession;
+    static IoSession pfSession;
+    final class SessionChecker implements Runnable {
+
+        @Override
+        public void run() {
+            // TODO Auto-generated method stub
+            try {
+
+                if(!pdSession.isActive()){
+                    logger.warn("浦东设备注销");
+                    ClientApp.pdreconn();
+                }
+
+                if(!pfSession.isActive()){
+                    logger.warn("浦东转发设备注销");
+                    ClientApp.pfreconn();
+                }
+            } catch (Exception e) {
+                logger.error("SessionChecker异常", e);
+            }
+        }
+
+    }
 }
 \ No newline at end of file
 package com.bsth.data.gpsdata.client.pd.handler;
  
-import com.bsth.data.gpsdata.client.ClientApp;
 import com.bsth.data.gpsdata.client.GpsBeforeBuffer;
 import com.bsth.data.gpsdata.client.msg.IMessageBody;
 import com.bsth.data.gpsdata.client.pd.protocol.PdMessage;
@@ -45,7 +44,7 @@ public class PdClientHandler extends IoHandlerAdapter{
     		log.info("连网关设备编号:" + deviceId + "断开连接");
     		log.warn(deviceId + "网关设备注销");
  
-            ClientApp.dconnect(deviceId);
+            //ClientApp.dconnect(deviceId);
         } else {
         	log.info("连网关设备编号:" + deviceId + "断开连接");
         }
 package com.bsth.data.gpsdata.client.pf.handler;
  
-import com.bsth.data.gpsdata.client.ClientApp;
 import com.bsth.data.gpsdata.client.GpsBeforeBuffer;
 import com.bsth.data.gpsdata.client.common.Protocol2BizUtil;
 import com.bsth.data.gpsdata.client.msg.IMessageBody;
@@ -44,7 +43,7 @@ public class PfClientHandler extends IoHandlerAdapter{
         	//SessionManager.getInstance().unregister(deviceId);
     		log.info("连老网关设备编号:" + deviceId + "断开连接");
     		log.warn(deviceId + "老网关设备注销");
-			ClientApp.fconnect(deviceId);
+			//ClientApp.fconnect(deviceId);
         }
     }