1

zj

2024-10-29 ff955adf5a6dda63dd09068eba743efb9553488d

 src/main/java/com/nq/ws/WebSocketClientBeanConfig.java

@@ -39,10 +39,28 @@
        } catch (Exception e) {
        }

        try {
            USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")),EStockType.US);
            usWebsocketRunClient.connect();
            usWebsocketRunClient.setConnectionLostTimeout(0);
            new Thread(() -> {
                while (true) {
                    try {
                        Thread.sleep(8000);
                        usWebsocketRunClient.send("heartbeat".getBytes());
                    } catch (Exception e) {
                        usWebsocketRunClient.reconnect();
                        usWebsocketRunClient.setConnectionLostTimeout(0);
                    }
                }
            }).start();
        } catch (Exception e) {
        }


        return retMap;
    }



}