1

zyy

2 days ago 01b3fecb2d1b03861a72d53a7afea6ca557a209c

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

@@ -20,15 +20,15 @@
    public Map<String, WebSocketClient> websocketRunClientMap() {

        Map<String, WebSocketClient> retMap = new HashMap<>(2);
//        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 {
            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();