1.websocket 订阅

2.盘前数据解析
3.推送—— qlm

src/main/java/com/zx/dataservice/controller/WebSocketController.java

@@ -113,9 +113,12 @@ public class WebSocketController {
 
         try{
             // 数据服务器 id   ：
+
             Session session = map.get( id);               //发送消息给对方
             if(session!=null){
-                session.getBasicRemote().sendText(xMessage);
+                synchronized(session){
+                    session.getBasicRemote().sendText(xMessage);
+                }
             }
         }catch(IOException e) {
             e.printStackTrace();

src/main/java/com/zx/dataservice/task/AnalysisStockRestDataTask.java

@@ -30,13 +30,13 @@ public class AnalysisStockRestDataTask {
     }
 
     @Async("executorAfterStock")
-    @Scheduled(cron = "0/10 * 15,16,17,18 * * ? ")
+    @Scheduled(cron = "0/10 * 15,16,17,18,19,20,21,22,23 * * ? ")
     public void toAnalysisRestAfterData() {
         doTask("after");
     }
 
     @Async("executorInFrontStock")
-    @Scheduled(cron = "0/5 1-30 17 * * ? ")
+    @Scheduled(cron = "0/5 1-30 9 * * ? ")
     public void toAnalysisRestInFrontData() {
         this.choiceStockService.analysisStockRestDataInFront("inFront");
     }