1

zj

2026-01-14 af7f754c7eeb82a7ec7570d1396ff91848d83ca7

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

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

import com.nq.enums.EStockType;
@@ -21,24 +20,24 @@
    public Map<String, WebSocketClient> websocketRunClientMap() {

        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);
        } catch (Exception e) {
            log.error("hkWebsocketRunClient 异常: {}", 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);
        } catch (Exception e) {
            log.error("twWebsocketRunClient 异常: {}", e.getMessage());
        }
//        try {
//            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("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());
//        }
        return retMap;
    }

@@ -68,4 +67,4 @@


}
*/