yml配置

zyy

2025-08-23 d0ceb7b82a0ccd7e553bca7abe2459e923bf1ddf

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

@@ -1,6 +1,5 @@
package com.nq.ws;


import com.nq.enums.EStockType;
import com.nq.utils.PropertiesUtil;
import lombok.extern.slf4j.Slf4j;
@@ -22,22 +21,22 @@

        Map<String, WebSocketClient> retMap = new HashMap<>(2);
        try {
            WebsocketRunClient usWebsocketRunClient = new WebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")),EStockType.US);
            usWebsocketRunClient.connect();
            usWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(usWebsocketRunClient);
            retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient);
            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("usWebsocketRunClient 异常: {}", e.getMessage());
            log.error("hkWebsocketRunClient 异常: {}", e.getMessage());
        }
        try {
            MXWebsocketRunClient mxWebsocketRunClient = new MXWebsocketRunClient(new URI(PropertiesUtil.getProperty("MX_WS_URL")),EStockType.MX);
            mxWebsocketRunClient.connect();
            mxWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(mxWebsocketRunClient);
            retMap.put(EStockType.MX.getStockKey(), mxWebsocketRunClient);
            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("mxWebsocketRunClient 异常: {}", e.getMessage());
            log.error("twWebsocketRunClient 异常: {}", e.getMessage());
        }
        return retMap;
    }