修改采集地址

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

@@ -1,6 +1,7 @@
 package com.game.business.task;
 
 import com.game.business.util.Common;
+import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -9,6 +10,7 @@ import javax.websocket.Session;
 import java.io.IOException;
 
 @Component
+@Log4j2
 public class WebSokcetTask {
 
     @Value("${websocket.switch}")
@@ -21,83 +23,116 @@ public class WebSokcetTask {
 //        }
 
         if(Common.sessionMap.containsKey(Common.GAME_ONE_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_ONE_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_ONE_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try {
+                Session session = Common.sessionMap.get(Common.GAME_ONE_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_ONE_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏one连接异常：{}",e.getMessage());
             }
+
         }
 
         if(Common.sessionMap.containsKey(Common.GAME_TWO_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_TWO_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_TWO_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try {
+                Session session = Common.sessionMap.get(Common.GAME_TWO_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_TWO_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏two连接异常：{}",e.getMessage());
             }
         }
 
         if(Common.sessionMap.containsKey(Common.GAME_THREES_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_THREES_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_THREES_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try{
+                Session session = Common.sessionMap.get(Common.GAME_THREES_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_THREES_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏three连接异常：{}",e.getMessage());
             }
         }
 
         if(Common.sessionMap.containsKey(Common.GAME_FOUR_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_FOUR_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_FOUR_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try{
+                Session session = Common.sessionMap.get(Common.GAME_FOUR_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_FOUR_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏four连接异常：{}",e.getMessage());
             }
         }
 
         if(Common.sessionMap.containsKey(Common.GAME_FIVE_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_FIVE_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_FIVE_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try{
+                Session session = Common.sessionMap.get(Common.GAME_FIVE_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_FIVE_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏five连接异常：{}",e.getMessage());
             }
         }
 
 
         if(Common.sessionMap.containsKey(Common.GAME_SIX_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_SIX_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_SIX_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try {
+                Session session = Common.sessionMap.get(Common.GAME_SIX_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_SIX_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏six连接异常：{}",e.getMessage());
             }
         }
 
         if(Common.sessionMap.containsKey(Common.GAME_SEVEN_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_SEVEN_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_SEVEN_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try{
+                Session session = Common.sessionMap.get(Common.GAME_SEVEN_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_SEVEN_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏seven连接异常：{}",e.getMessage());
             }
         }
 
         if(Common.sessionMap.containsKey(Common.GAME_EIGHT_CODE)){
-            Session session = Common.sessionMap.get(Common.GAME_EIGHT_CODE);
-            if(!session.isOpen()){
-                Common.sessionMap.remove(Common.GAME_EIGHT_CODE);
-                session.close();
-            }else{
-                session.getBasicRemote().sendText("ping");
+            try{
+                Session session = Common.sessionMap.get(Common.GAME_EIGHT_CODE);
+                if(!session.isOpen()){
+                    Common.sessionMap.remove(Common.GAME_EIGHT_CODE);
+                    session.close();
+                }else{
+                    session.getBasicRemote().sendText("ping");
+                }
+            }catch (Exception e){
+                log.info("游戏eight连接异常：{}",e.getMessage());
             }
         }
     }

game-business/src/main/java/com/game/business/util/Common.java

@@ -46,8 +46,8 @@ public class Common {
     public static final String WS_GAME_ONE_URL = "ws://119.29.174.68:8000/ws";
     public static final String WS_GAME_ONE_REMARK_URL = "ws://81.71.95.104:8000/ws";
 
-    public static final String WS_GAME_TWO_URL = "ws://101.32.77.236:8000/ws";
-    public static final String WS_GAME_TWO_REMARK_URL = "ws://43.154.141.151:8000/ws";
+    public static final String WS_GAME_TWO_URL = "ws://119.91.57.12:8000/ws";
+    public static final String WS_GAME_TWO_REMARK_URL = "ws://114.132.246.138:8000/ws";
 
     public static final String WS_GAME_THREES_URL = "ws://114.132.186.201:8000/ws";
     public static final String WS_GAME_THREES_REMARK_URL = "ws://43.138.214.132:8000/ws";