日股，美股

zj

2026-01-11 28701d9c708089cd64e3dc813ad1d9079de6528a

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

@@ -1,4 +1,3 @@
/*
package com.nq.ws;

import com.nq.enums.EStockType;
@@ -22,22 +21,22 @@

        Map<String, WebSocketClient> retMap = new HashMap<>(2);
        try {
            WebsocketRunClient hkWebsocketRunClient = new WebsocketRunClient(new URI(PropertiesUtil.getProperty("HK_WS_URL")), EStockType.HK);
            hkWebsocketRunClient.connect();
            hkWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(hkWebsocketRunClient);
            retMap.put(EStockType.HK.getStockKey(), hkWebsocketRunClient);
            JPWebsocketRunClient jpWebsocketRunClient = new JPWebsocketRunClient(new URI(PropertiesUtil.getProperty("JP_WS_URL")), EStockType.JP);
            jpWebsocketRunClient.connect();
            jpWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(jpWebsocketRunClient);
            retMap.put(EStockType.JP.getStockKey(), jpWebsocketRunClient);
        } catch (Exception e) {
            log.error("hkWebsocketRunClient 异常: {}", e.getMessage());
            log.error("jpWebsocketRunClient 异常: {}", e.getMessage());
        }
        try {
            TWWebsocketRunClient twWebsocketRunClient = new TWWebsocketRunClient(new URI(PropertiesUtil.getProperty("TW_WS_URL")), EStockType.TW);
            twWebsocketRunClient.connect();
            twWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(twWebsocketRunClient);
            retMap.put(EStockType.TW.getStockKey(), twWebsocketRunClient);
            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("twWebsocketRunClient 异常: {}", e.getMessage());
            log.error("usWebsocketRunClient 异常: {}", e.getMessage());
        }
        return retMap;
    }
@@ -68,4 +67,4 @@


}
*/