尝试精简websocket 传输...

潘钊
1 parent ef08a724
Showing 3 changed files with 45 additions and 56 deletions
src/main/java/com/bsth/data/directive/DirectivesPstThread.java
src/main/java/com/bsth/data/directive/GatewayHttpUtils.java
src/main/java/com/bsth/data/gpsdata_v2/DataHandleProcess.java
@@ -45,7 +45,8 @@ public class DirectivesPstThread extends Thread {
         for (int i = 0; i < 1000; i++) {
             try {
                 directive = list.poll();
-
+                //日期
+                directive.setRq(fmtyyyyMMdd.print(directive.getTimestamp()));
                 if (directive instanceof D60) {
                     D60 d60 = (D60) directive;
                     if(d60.isDispatch()){
@@ -56,8 +57,6 @@ public class DirectivesPstThread extends Thread {
                             continue;
                         }
                     }
-                    //日期
-                    d60.setRq(fmtyyyyMMdd.print(d60.getTimestamp()));
                     d60Repository.save(d60);
                 }
@@ -12,61 +12,51 @@ import org.apache.http.util.EntityUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
 /**
- * 
- * @ClassName: GatewayHttpUtils 
- * @Description: TODO(和网关HTTP通讯工具类) 
  * @author PanZhao
- * @date 2016年8月14日 下午9:50:46 
- *
+ * @ClassName: GatewayHttpUtils
+ * @Description: TODO(和网关HTTP通讯工具类)
+ * @date 2016年8月14日 下午9:50:46
  */
 public class GatewayHttpUtils {
-	static Logger logger = LoggerFactory.getLogger(GatewayHttpUtils.class);
-	
-	static String url;
-	
-	static{
-		url = ConfigUtil.get("http.send.directive");
-	}
-	
-	public static  int postJson(String jsonStr){
-		logger.info("send : " + jsonStr);
-		
-		CloseableHttpClient httpClient = null;
-		int code = -1;
-		try{
-			httpClient = HttpClients.createDefault();
-			
-			//超时时间
-			RequestConfig requestConfig = RequestConfig.custom()  
-			        .setConnectTimeout(1500).setConnectionRequestTimeout(1000)
-			        .setSocketTimeout(1500).build();
-			
-			HttpPost post = new HttpPost(url);
-			
-			post.setConfig(requestConfig);
-			
-			post.setEntity(new StringEntity(jsonStr, "utf-8"));
-		
-			CloseableHttpResponse response = httpClient.execute(post);
+    static Logger logger = LoggerFactory.getLogger(GatewayHttpUtils.class);
+
+    static String url;
+    static CloseableHttpClient httpClient = null;
+    static HttpPost post;
+    static RequestConfig requestConfig;
+    static CloseableHttpResponse response;
+
+    static {
+        url = ConfigUtil.get("http.send.directive");
+        httpClient = HttpClients.createDefault();
+        post = new HttpPost(url);
+        requestConfig = RequestConfig.custom()
+                .setConnectTimeout(2000).setConnectionRequestTimeout(1000)
+                .setSocketTimeout(2000).build();
+        post.setConfig(requestConfig);
+    }
+
+    public static int postJson(String jsonStr) {
+        logger.info("send : " + jsonStr);
+
+        int code = -1;
+        try {
+            post.setEntity(new StringEntity(jsonStr, "utf-8"));
+
+            response = httpClient.execute(post);
+
+            JSONObject json = JSONObject.parseObject(EntityUtils.toString(response.getEntity()));
+            if (null != json && json.getInteger("errCode") == 0)
+                code = 0;
+            else
+                logger.error("和网关http通讯失败，rs: " + json);
-			JSONObject json = JSONObject.parseObject(EntityUtils.toString(response.getEntity()));
-			if(null != json && json.getInteger("errCode") == 0)
-				code = 0;
-			else
-				logger.error("和网关http通讯失败，rs: " + json);
-		}catch(Exception e){
-			logger.error("", e);
-		}finally {
-			try {
-				if(httpClient != null)
-					httpClient.close();
-			} catch (IOException e) {
-				logger.error("", e);
-			}
-		}
-		return code;
-	}
+            if (null != response)
+                response.close();
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+        return code;
+    }
 }
@@ -123,7 +123,7 @@ public class DataHandleProcess {
                         if (Math.abs(gps.getTimestamp() - gps.getServerTimestamp()) > 1000 * 60 * 20)
                             continue;
-                        //gpsStateProcess.process(gps);//状态处理
+                        gpsStateProcess.process(gps);//状态处理
                         stationInsideProcess.process(gps);//场站内外判定
                         reverseRouteProcess.process(gps);//反向路由处理
                         abnormalStateProcess.process(gps);//超速越界