websoekct调整

game-business/src/main/java/com/game/business/task/WebSokcetTask.java

@@ -10,7 +10,7 @@ import java.io.IOException;
 @Component
 public class WebSokcetTask {
 
-//    @Scheduled(cron = "0 0/1 * * * ? ")
+    @Scheduled(cron = "0/5 * * * * ? ")
     public void liveDividedTask() throws IOException {
 
         if(Common.sessionMap.containsKey(Common.GAME_ONE_CODE)){
@@ -18,6 +18,8 @@ public class WebSokcetTask {
             if(!session.isOpen()){
                 Common.sessionMap.remove(Common.GAME_ONE_CODE);
                 session.close();
+            }else{
+                session.getBasicRemote().sendText("ping");
             }
         }
 
@@ -26,6 +28,8 @@ public class WebSokcetTask {
             if(!session.isOpen()){
                 Common.sessionMap.remove(Common.GAME_TWO_CODE);
                 session.close();
+            }else{
+                session.getBasicRemote().sendText("ping");
             }
         }
     }

game-business/src/main/java/com/game/business/websocket/client/GameOneClient.java

@@ -34,7 +34,7 @@ public class GameOneClient {
         System.out.println("game one 游戏已连接 server");
         // 发送游戏编码
         session.getBasicRemote().sendText("ping");
-//        Common.sessionMap.put(Common.GAME_ONE_CODE, session);
+        Common.sessionMap.put(Common.GAME_ONE_CODE, session);
     }
 
     @OnClose
@@ -70,7 +70,7 @@ public class GameOneClient {
             System.out.println("game one 接收数据" + message);
 
             if(message.equals("pong")){
-                session.getBasicRemote().sendText("ping");
+//                session.getBasicRemote().sendText("ping");
                 return;
             }
 

game-business/src/main/java/com/game/business/websocket/client/GameTwoClient.java

@@ -23,7 +23,7 @@ public class GameTwoClient {
     public void onOpen(Session session) throws Exception{
         System.out.println("game two 游戏已连接 server");
         session.getBasicRemote().sendText("ping");
-//        Common.sessionMap.put(Common.GAME_TWO_CODE, session);
+        Common.sessionMap.put(Common.GAME_TWO_CODE, session);
     }
 
     @OnClose
@@ -59,7 +59,7 @@ public class GameTwoClient {
             System.out.println("game two 接收数据" + message);
 
             if(message.equals("pong")){
-                session.getBasicRemote().sendText("ping");
+//                session.getBasicRemote().sendText("ping");
                 return;
             }