socket提交

whyclxw

2025-04-27 3ec3bd545335238ecb166477f9b4d1bf701013ee

socket提交

 src/main/java/com/whyc/webSocket/HomeSocket.java

@@ -53,13 +53,10 @@
            @Override
            public void run() {
                try {

                    while (!currentThread().isInterrupted()) {
                        while (!currentThread().isInterrupted()) {
                            Map<String, Object> res = sendHome(userId);
                            session.getBasicRemote().sendObject(new Response().set(1, res));
                            sleep(5000);
                        }
                        Map<String, Object> res = sendHome(userId);
                        session.getBasicRemote().sendObject(new Response().set(1, res));
                        sleep(5000);
                    }
                } catch (Exception e) {
                    this.interrupt();

 src/main/java/com/whyc/webSocket/StationInfSocket.java

@@ -52,13 +52,10 @@
            @Override
            public void run() {
                try {

                    while (!currentThread().isInterrupted()) {
                        while (!currentThread().isInterrupted()) {
                            Response res = stationService.getLeftStation(userId);
                            session.getBasicRemote().sendObject(res);
                            sleep(5000);
                        }
                        Response res = stationService.getLeftStation(userId);
                        session.getBasicRemote().sendObject(res);
                        sleep(5000);
                    }
                } catch (Exception e) {
                    this.interrupt();