1

zj

2026-01-14 afb9b1cefb1c2d2f57fe8f0f3c19efa354669c66

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

@@ -29,15 +29,15 @@
//        } catch (Exception e) {
//            log.error("jpWebsocketRunClient 异常: {}", e.getMessage());
//        }
//        try {
//            USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")), EStockType.US);
//            usWebsocketRunClient.connect();
//            usWebsocketRunClient.setConnectionLostTimeout(0);
//            startHeartbeatThread(usWebsocketRunClient);
//            retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient);
//        } catch (Exception e) {
//            log.error("usWebsocketRunClient 异常: {}", e.getMessage());
//        }
        try {
            USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")), EStockType.US);
            usWebsocketRunClient.connect();
            usWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(usWebsocketRunClient);
            retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient);
        } catch (Exception e) {
            log.error("usWebsocketRunClient 异常: {}", e.getMessage());
        }
        return retMap;
    }